Master => Primary

Signed-off-by: naglera <[email protected]>
valkey-io · Jun 27, 2024 · 72aef9b · 72aef9b
1 parent 2a470ff
commit 72aef9b
Show file tree

Hide file tree

Showing 4 changed files with 93 additions and 93 deletions.
diff --git a/src/networking.c b/src/networking.c
@@ -253,7 +253,7 @@ void putClientInPendingWriteQueue(client *c) {
      * writes at this stage. */
     if (!(c->flags & CLIENT_PENDING_WRITE) &&
         (c->repl_state == REPL_STATE_NONE ||
-         ((c->repl_state == REPLICA_STATE_ONLINE || c->repl_state == SLAVE_STATE_BG_RDB_LOAD) && !c->repl_start_cmd_stream_on_ack))) {
+         ((c->repl_state == REPLICA_STATE_ONLINE || c->repl_state == REPLICA_STATE_BG_RDB_LOAD) && !c->repl_start_cmd_stream_on_ack))) {
         /* Here instead of installing the write handler, we just flag the
          * client and put it into a list of clients that have something
          * to write to the socket. This way before re-entering the event
@@ -4072,7 +4072,7 @@ void flushReplicasOutputBuffers(void) {
          *
          * 3. Obviously if the replica is not ONLINE.
          */
-        if ((replica->repl_state == REPLICA_STATE_ONLINE || replica->repl_state == SLAVE_STATE_BG_RDB_LOAD)
+        if ((replica->repl_state == REPLICA_STATE_ONLINE || replica->repl_state == REPLICA_STATE_BG_RDB_LOAD)
          && !(replica->flags & CLIENT_CLOSE_ASAP) &&
             can_receive_writes && !replica->repl_start_cmd_stream_on_ack && clientHasPendingReplies(replica)) {
             writeToClient(replica, 0);