Skip to content

Commit

Permalink
Fix droped text
Browse files Browse the repository at this point in the history
Signed-off-by: naglera <anagler123@gmail.com>
  • Loading branch information
naglera committed Sep 29, 2024
1 parent 10e760f commit 5dfb259
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions src/replication.c
Original file line number Diff line number Diff line change
Expand Up @@ -3264,8 +3264,6 @@ void dualChannelSetupMainConnForPsync(connection *conn) {
char *err = NULL;
int ret;

REPL_STATE_RECEIVE_PING_REPLY && server.repl_state <= REPL_STATE_RECEIVE_PSYNC_REPLY;

switch (server.repl_state) {
case REPL_STATE_SEND_HANDSHAKE:
ret = dualChannelReplMainConnSendHandshake(conn, &err);
Expand All @@ -3286,7 +3284,8 @@ void dualChannelSetupMainConnForPsync(connection *conn) {
break;
case REPL_STATE_RECEIVE_PSYNC_REPLY:
ret = dualChannelReplMainConnRecvPsyncReply(conn, &err);
if (ret == C_OK && server.repl_rdb_channel_state != REPL_DUAL_CHANNEL_STATE_NONE) server.repl_state = REPL_STATE_TRANSFER;
if (ret == C_OK && server.repl_rdb_channel_state != REPL_DUAL_CHANNEL_STATE_NONE)
server.repl_state = REPL_STATE_TRANSFER;
/* In case the RDB is already loaded, the repl_state will be set during establishPrimaryConnection. */
break;
default:
Expand Down

0 comments on commit 5dfb259

Please sign in to comment.