Skip to content

Commit

Permalink
Naming fix
Browse files Browse the repository at this point in the history
  • Loading branch information
JohnSully committed Apr 5, 2024
1 parent c50e2d4 commit 66be482
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/replication.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1157,7 +1157,7 @@ class replicationBuffer {
}
}

void putSlavesOnline() {
void putReplicasOnline() {
for (auto replica : replicas) {
std::unique_lock<fastlock> ul(replica->lock);
// If we put the replica online before the output is drained then it will get immediately closed
Expand Down Expand Up @@ -1295,7 +1295,7 @@ int rdbSaveSnapshotForReplication(rdbSaveInfo *rsi) {
auto usec = ustime() - timeStart;
serverLog(LL_NOTICE, "Transferred %zuMB total (%zuMB data) in %.2f seconds. (%.2fGbit/s)", spreplBuf->cbWritten()/1024/1024, cbData/1024/1024, usec/1000000.0, (spreplBuf->cbWritten()*8.0)/(usec/1000000.0)/1000000000.0);
if (retval == C_OK) {
replBuf.putSlavesOnline();
replBuf.putReplicasOnline();
}
});

Expand Down

0 comments on commit 66be482

Please sign in to comment.