diff --git a/src/pika_repl_client_thread.cc b/src/pika_repl_client_thread.cc index 355b373490..2a7c666d81 100644 --- a/src/pika_repl_client_thread.cc +++ b/src/pika_repl_client_thread.cc @@ -42,7 +42,8 @@ void PikaReplClientThread::ReplClientHandle::FdTimeoutHandle(int fd, const std:: } if (ip == g_pika_server->master_ip() && port == g_pika_server->master_port() + kPortShiftReplServer && PIKA_REPL_ERROR != g_pika_server->repl_state() && - PikaReplicaManager::CheckSlaveDBState(ip, port)) { // if state machine in error state, no retry + PikaReplicaManager::CheckSlaveDBState(ip, port)) { + // if state machine equal to kDBNoConnect(execute cmd 'dbslaveof db no one'), no retry LOG(WARNING) << "Master conn timeout : " << ip_port << " try reconnect"; g_pika_server->ResetMetaSyncStatus(); } diff --git a/src/pika_server.cc b/src/pika_server.cc index 57224c5c09..699a9291ce 100644 --- a/src/pika_server.cc +++ b/src/pika_server.cc @@ -602,6 +602,8 @@ int32_t PikaServer::GetSlaveListString(std::string& slave_list_str) { master_boffset.offset - sent_slave_boffset.offset; tmp_stream << "(" << db->DBName() << ":" << lag << ")"; } + } else if (s.ok() && slave_state == SlaveState::kSlaveDbSync){ + tmp_stream << "(" << db->DBName() << ":full syncing)"; } else { tmp_stream << "(" << db->DBName() << ":not syncing)"; }