diff --git a/lib/MySQL_Monitor.cpp b/lib/MySQL_Monitor.cpp index 3ae7e0774..480148c44 100644 --- a/lib/MySQL_Monitor.cpp +++ b/lib/MySQL_Monitor.cpp @@ -2213,6 +2213,7 @@ __exit_monitor_replication_lag_thread: //rc=(*proxy_sqlite3_prepare_v2)(mondb, query, -1, &statement, 0); rc = mmsd->mondb->prepare_v2(query, &statement); ASSERT_SQLITE_OK(rc, mmsd->mondb); + // 'replication_lag' to be feed to 'replication_lag_action' int repl_lag=-2; rc=(*proxy_sqlite3_bind_text)(statement, 1, mmsd->hostname, -1, SQLITE_TRANSIENT); ASSERT_SQLITE_OK(rc, mmsd->mondb); rc=(*proxy_sqlite3_bind_int)(statement, 2, mmsd->port); ASSERT_SQLITE_OK(rc, mmsd->mondb); @@ -2267,6 +2268,8 @@ __exit_monitor_replication_lag_thread: mmsd->result=NULL; } else { rc=(*proxy_sqlite3_bind_null)(statement, 5); ASSERT_SQLITE_OK(rc, mmsd->mondb); + // 'replication_lag_check' timed out, we set 'repl_lag' to '-3' to avoid server to be 're-enabled'. + repl_lag=-3; } rc=(*proxy_sqlite3_bind_text)(statement, 6, mmsd->mysql_error_msg, -1, SQLITE_TRANSIENT); ASSERT_SQLITE_OK(rc, mmsd->mondb); SAFE_SQLITE3_STEP2(statement);