Lines Matching refs:repl_backlog
79 serverAssert(server.repl_backlog == NULL); in createReplicationBacklog()
80 server.repl_backlog = zmalloc(server.repl_backlog_size); in createReplicationBacklog()
102 if (server.repl_backlog != NULL) { in resizeReplicationBacklog()
108 zfree(server.repl_backlog); in resizeReplicationBacklog()
109 server.repl_backlog = zmalloc(server.repl_backlog_size); in resizeReplicationBacklog()
119 zfree(server.repl_backlog); in freeReplicationBacklog()
120 server.repl_backlog = NULL; in freeReplicationBacklog()
137 memcpy(server.repl_backlog+server.repl_backlog_idx,p,thislen); in feedReplicationBacklog()
189 if (server.repl_backlog == NULL && listLength(slaves) == 0) return; in replicationFeedSlaves()
192 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
212 if (server.repl_backlog) feedReplicationBacklogWithObject(selectcmd); in replicationFeedSlaves()
228 if (server.repl_backlog) { in replicationFeedSlaves()
293 if (server.repl_backlog) feedReplicationBacklog(buf,buflen); in replicationFeedSlavesFromMasterStream()
388 addReplySds(c,sdsnewlen(server.repl_backlog + j, thislen)); in addReplyReplicationBacklog()
492 if (!server.repl_backlog || in masterTryPartialResynchronization()
694 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) { in syncCommand()
1316 if (server.repl_backlog == NULL) createReplicationBacklog(); in readSyncBulkPayload()
1571 if (server.repl_backlog == NULL) createReplicationBacklog(); in slaveTryPartialResynchronization()
2671 server.repl_backlog && server.masterhost == NULL) in replicationCron()