fix: Solve the problem of expired BinlogSync request causing master-slave synchronization to get stuck

morningli · morningli · commit f9425e5d1661 · 2025-03-10T15:07:57.000+08:00
diff --git a/src/pika_repl_bgworker.cc b/src/pika_repl_bgworker.cc
@@ -126,7 +126,8 @@ void PikaReplBgWorker::HandleBGWorkerWriteBinlog(void* arg) {
                    << " expected_session: " << binlog_res.session_id()
                    << ", actual_session:" << slave_db->MasterSessionId();
       LOG(WARNING) << "Check Session failed " << binlog_res.slot().db_name();
-      slave_db->SetReplState(ReplState::kTryConnect);
+      // ignore expired task
+      // slave_db->SetReplState(ReplState::kTryConnect);
       return;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,8 @@ void PikaReplBgWorker::HandleBGWorkerWriteBinlog(void* arg) {`
`126`	`126`	`<< " expected_session: " << binlog_res.session_id()`
`127`	`127`	`<< ", actual_session:" << slave_db->MasterSessionId();`
`128`	`128`	`LOG(WARNING) << "Check Session failed " << binlog_res.slot().db_name();`
`129`		`- slave_db->SetReplState(ReplState::kTryConnect);`
	`129`	`+ // ignore expired task`
	`130`	`+ // slave_db->SetReplState(ReplState::kTryConnect);`
`130`	`131`	`return;`
`131`	`132`	`}`
`132`	`133`