Reset partition state to be TrySync when session break (OpenAtomFound…

…ation#626)
Icemap · May 15, 2019 · d474ba8 · d474ba8
1 parent 16531a0
commit d474ba8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/pika_rm.cc b/src/pika_rm.cc
@@ -517,6 +517,7 @@ Status SyncSlavePartition::CheckSyncTimeout(uint64_t now, bool* del) {
         m_info_.PartitionId() << " Not Found";
     }
     partition->SetReplState(ReplState::kTryConnect);
+    g_pika_server->MarkTryConnectDone();
     *del = true;
   }
   return Status::OK();
@@ -1008,7 +1009,8 @@ Status PikaReplicaManager::CheckSyncTimeout(uint64_t now) {
   }
   for (auto& partition_info : to_del) {
     sync_slave_partitions_.erase(partition_info);
-    LOG(INFO) << "SyncTimeout Delete Master Node Success, partition: " << partition_info.ToString();
+    LOG(INFO) << "SyncTimeout Delete Master Node Success, partition: " << partition_info.ToString()
+      << " Reset state TryConnect";
   }
   return Status::OK();
 }

diff --git a/third/blackwidow b/third/blackwidow