bugfix: drop item in write queue when slave binlog sync timeout (Open…

…AtomFoundation#945)
yinghuacao282428 · Sep 1, 2020 · d94339f · d94339f
1 parent 041cc20
commit d94339f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/pika_rm.cc b/src/pika_rm.cc
@@ -403,6 +403,7 @@ Status SyncMasterPartition::CheckSyncTimeout(uint64_t now) {
 
   for (auto& node : to_del) {
     coordinator_.SyncPros().RemoveSlaveNode(node.Ip(), node.Port());
+    g_pika_rm->DropItemInWriteQueue(node.Ip(), node.Port());
     LOG(WARNING) << SyncPartitionInfo().ToString() << " Master del Recv Timeout slave success " << node.ToString();
   }
   return Status::OK();