Skip to content

Commit

Permalink
Fix droped text
Browse files Browse the repository at this point in the history
Signed-off-by: naglera <[email protected]>
  • Loading branch information
naglera committed Sep 29, 2024
1 parent 10e760f commit 003291f
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions src/replication.c
Original file line number Diff line number Diff line change
Expand Up @@ -3263,9 +3263,7 @@ int dualChannelReplMainConnRecvPsyncReply(connection *conn, sds *err) {
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 003291f

Please sign in to comment.