Lines Matching refs:repl_backlog
78 serverAssert(server.repl_backlog == NULL); in createReplicationBacklog()
79 server.repl_backlog = zmalloc(server.repl_backlog_size); in createReplicationBacklog()
106 if (server.repl_backlog != NULL) { in resizeReplicationBacklog()
112 zfree(server.repl_backlog); in resizeReplicationBacklog()
113 server.repl_backlog = zmalloc(server.repl_backlog_size); in resizeReplicationBacklog()
123 zfree(server.repl_backlog); in freeReplicationBacklog()
124 server.repl_backlog = NULL; in freeReplicationBacklog()
141 memcpy(server.repl_backlog+server.repl_backlog_idx,p,thislen); in feedReplicationBacklog()
181 if (server.repl_backlog == NULL && listLength(slaves) == 0) return; in replicationFeedSlaves()
184 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
204 if (server.repl_backlog) feedReplicationBacklogWithObject(selectcmd); in replicationFeedSlaves()
220 if (server.repl_backlog) { in replicationFeedSlaves()
352 addReplySds(c,sdsnewlen(server.repl_backlog + j, thislen)); in addReplyReplicationBacklog()
367 if (server.repl_backlog == NULL) psync_offset++; in getPsyncInitialOffset()
441 if (!server.repl_backlog || in masterTryPartialResynchronization()
689 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) in syncCommand()
2340 server.repl_backlog) in replicationCron()