Rename wating rax to just wait

Signed-off-by: naglera <[email protected]>
naglera · Jun 30, 2024 · 01cc5e8 · 01cc5e8
1 parent 4ea06f9
commit 01cc5e8
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/src/rdb.c b/src/rdb.c
@@ -3557,7 +3557,7 @@ int rdbSaveToReplicasSockets(int req, rdbSaveInfo *rsi) {
                  * to inform it with the save end offset.*/
                 sendCurrentOffsetToReplica(replica);
                 /* Make sure repl traffic is appended to the replication backlog */                
-                addReplicaToPsyncWaitingRax(replica);
+                addReplicaToPsyncWait(replica);
             } else {
                 server.rdb_pipe_numconns++;
             }

diff --git a/src/replication.c b/src/replication.c
@@ -208,7 +208,7 @@ void rebaseReplicationBuffer(long long base_repl_offset) {
  * On COB overrun, association is deleted and the RDB connection 
  * is dropped.
  */
-void addReplicaToPsyncWaitingRax(client* replica) {
+void addReplicaToPsyncWait(client* replica) {
     listNode *ln = NULL;
     replBufBlock *tail = NULL;
     if (server.repl_backlog == NULL) {
@@ -230,7 +230,7 @@ void addReplicaToPsyncWaitingRax(client* replica) {
 }
 
 /* Attach waiting psync replicas with new replication backlog head. */
-void addReplicaToPsyncWaitingRaxRetrospect(void) {
+void addReplicaToPsyncWaitRetrospect(void) {
     listNode *ln = listFirst(server.repl_buffer_blocks);
     replBufBlock *head = ln ? listNodeValue(ln) : NULL;
     raxIterator iter;
@@ -249,7 +249,7 @@ void addReplicaToPsyncWaitingRaxRetrospect(void) {
     raxStop(&iter);
 }
 
-void removeReplicaFromPsyncWaitingRax(client* replica) {
+void removeReplicaFromPsyncWait(client* replica) {
     listNode *ln;
     replBufBlock *o;
     /* Get replBufBlock pointed by this replica */ 
@@ -462,7 +462,7 @@ void feedReplicationBuffer(char *s, size_t len) {
         }
         if (empty_backlog && raxSize(server.replicas_waiting_psync) > 0) {
             /* Increase refcount for pending replicas. */
-            addReplicaToPsyncWaitingRaxRetrospect();
+            addReplicaToPsyncWaitRetrospect();
         }
 
         /* For output buffer of replicas. */
@@ -864,7 +864,7 @@ int primaryTryPartialResynchronization(client *c, long long psync_offset) {
     c->flags |= CLIENT_REPLICA;
     if (c->flags & CLIENT_REPL_MAIN_CONN && lookupRdbClientByID(c->associated_rdb_client_id)) {
         c->repl_state = REPLICA_STATE_BG_RDB_LOAD;
-        removeReplicaFromPsyncWaitingRax(c);
+        removeReplicaFromPsyncWait(c);
     } else {
          c->repl_state = REPLICA_STATE_ONLINE;
     }

diff --git a/src/server.h b/src/server.h
@@ -2997,7 +2997,7 @@ void abortFailover(const char *err);
 const char *getFailoverStateString(void);
 void abortRdbConnectionSync(void);
 int sendCurrentOffsetToReplica(client* replica);
-void addReplicaToPsyncWaitingRax(client* replica);
+void addReplicaToPsyncWait(client* replica);
 
 /* Generic persistence functions */
 void startLoadingFile(size_t size, char *filename, int rdbflags);