Lines Matching refs:server
78 serverAssert(server.repl_backlog == NULL); in createReplicationBacklog()
79 server.repl_backlog = zmalloc(server.repl_backlog_size); in createReplicationBacklog()
80 server.repl_backlog_histlen = 0; in createReplicationBacklog()
81 server.repl_backlog_idx = 0; in createReplicationBacklog()
86 server.master_repl_offset++; in createReplicationBacklog()
91 server.repl_backlog_off = server.master_repl_offset+1; in createReplicationBacklog()
103 if (server.repl_backlog_size == newsize) return; in resizeReplicationBacklog()
105 server.repl_backlog_size = newsize; in resizeReplicationBacklog()
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()
114 server.repl_backlog_histlen = 0; in resizeReplicationBacklog()
115 server.repl_backlog_idx = 0; in resizeReplicationBacklog()
117 server.repl_backlog_off = server.master_repl_offset+1; in resizeReplicationBacklog()
122 serverAssert(listLength(server.slaves) == 0); in freeReplicationBacklog()
123 zfree(server.repl_backlog); in freeReplicationBacklog()
124 server.repl_backlog = NULL; in freeReplicationBacklog()
134 server.master_repl_offset += len; in feedReplicationBacklog()
139 size_t thislen = server.repl_backlog_size - server.repl_backlog_idx; in feedReplicationBacklog()
141 memcpy(server.repl_backlog+server.repl_backlog_idx,p,thislen); in feedReplicationBacklog()
142 server.repl_backlog_idx += thislen; in feedReplicationBacklog()
143 if (server.repl_backlog_idx == server.repl_backlog_size) in feedReplicationBacklog()
144 server.repl_backlog_idx = 0; in feedReplicationBacklog()
147 server.repl_backlog_histlen += thislen; in feedReplicationBacklog()
149 if (server.repl_backlog_histlen > server.repl_backlog_size) in feedReplicationBacklog()
150 server.repl_backlog_histlen = server.repl_backlog_size; in feedReplicationBacklog()
152 server.repl_backlog_off = server.master_repl_offset - in feedReplicationBacklog()
153 server.repl_backlog_histlen + 1; 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()
187 if (server.slaveseldb != dictid) { in replicationFeedSlaves()
204 if (server.repl_backlog) feedReplicationBacklogWithObject(selectcmd); in replicationFeedSlaves()
217 server.slaveseldb = dictid; in replicationFeedSlaves()
220 if (server.repl_backlog) { in replicationFeedSlaves()
247 listRewind(server.slaves,&li); in replicationFeedSlaves()
281 cmdrepr = sdscatprintf(cmdrepr,"[%d unix:%s] ",dictid,server.unixsocket); in replicationFeedMonitors()
314 if (server.repl_backlog_histlen == 0) { in addReplyReplicationBacklog()
320 server.repl_backlog_size); in addReplyReplicationBacklog()
322 server.repl_backlog_off); in addReplyReplicationBacklog()
324 server.repl_backlog_histlen); in addReplyReplicationBacklog()
326 server.repl_backlog_idx); in addReplyReplicationBacklog()
329 skip = offset - server.repl_backlog_off; in addReplyReplicationBacklog()
334 j = (server.repl_backlog_idx + in addReplyReplicationBacklog()
335 (server.repl_backlog_size-server.repl_backlog_histlen)) % in addReplyReplicationBacklog()
336 server.repl_backlog_size; in addReplyReplicationBacklog()
340 j = (j + skip) % server.repl_backlog_size; in addReplyReplicationBacklog()
344 len = server.repl_backlog_histlen - skip; in addReplyReplicationBacklog()
348 ((server.repl_backlog_size - j) < len) ? in addReplyReplicationBacklog()
349 (server.repl_backlog_size - j) : len; in addReplyReplicationBacklog()
352 addReplySds(c,sdsnewlen(server.repl_backlog + j, thislen)); in addReplyReplicationBacklog()
356 return server.repl_backlog_histlen - skip; in addReplyReplicationBacklog()
364 long long psync_offset = server.master_repl_offset; in getPsyncInitialOffset()
367 if (server.repl_backlog == NULL) psync_offset++; in getPsyncInitialOffset()
396 server.slaveseldb = -1; in replicationSetupSlaveForFullResync()
402 server.runid,offset); in replicationSetupSlaveForFullResync()
425 if (strcasecmp(master_runid, server.runid)) { in masterTryPartialResynchronization()
430 master_runid, server.runid); in masterTryPartialResynchronization()
441 if (!server.repl_backlog || in masterTryPartialResynchronization()
442 psync_offset < server.repl_backlog_off || in masterTryPartialResynchronization()
443 psync_offset > (server.repl_backlog_off + server.repl_backlog_histlen)) in masterTryPartialResynchronization()
447 if (psync_offset > server.master_repl_offset) { in masterTryPartialResynchronization()
460 c->repl_ack_time = server.unixtime; in masterTryPartialResynchronization()
462 listAddNodeTail(server.slaves,c); in masterTryPartialResynchronization()
511 int socket_target = server.repl_diskless_sync && (mincapa & SLAVE_CAPA_EOF); in startBgsaveForReplication()
521 retval = rdbSaveBackground(server.rdb_filename); in startBgsaveForReplication()
528 listRewind(server.slaves,&li); in startBgsaveForReplication()
534 listDelNode(server.slaves,ln); in startBgsaveForReplication()
546 listRewind(server.slaves,&li); in startBgsaveForReplication()
570 if (server.masterhost && server.repl_state != REPL_STATE_CONNECTED) { in syncCommand()
598 server.stat_sync_partial_ok++; in syncCommand()
607 if (master_runid[0] != '?') server.stat_sync_partial_err++; in syncCommand()
617 server.stat_sync_full++; in syncCommand()
622 if (server.repl_disable_tcp_nodelay) in syncCommand()
626 listAddNodeTail(server.slaves,c); in syncCommand()
629 if (server.rdb_child_pid != -1 && in syncCommand()
630 server.rdb_child_type == RDB_CHILD_TYPE_DISK) in syncCommand()
639 listRewind(server.slaves,&li); in syncCommand()
659 } else if (server.rdb_child_pid != -1 && in syncCommand()
660 server.rdb_child_type == RDB_CHILD_TYPE_SOCKET) in syncCommand()
669 if (server.repl_diskless_sync && (c->slave_capa & SLAVE_CAPA_EOF)) { in syncCommand()
673 if (server.repl_diskless_sync_delay) in syncCommand()
679 if (server.aof_child_pid == -1) { in syncCommand()
689 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) in syncCommand()
749 c->repl_ack_time = server.unixtime; in replconfCommand()
760 if (server.masterhost && server.master) replicationSendAck(); in replconfCommand()
786 slave->repl_ack_time = server.unixtime; /* Prevent false timeout. */ in putSlaveOnline()
787 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
816 server.stat_net_output_bytes += nwritten; in sendBulkToSlave()
845 server.stat_net_output_bytes += nwritten; in sendBulkToSlave()
849 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in sendBulkToSlave()
874 listRewind(server.slaves,&li); in updateSlavesWaitingBgsave()
901 slave->repl_ack_time = server.unixtime; /* Timeout otherwise. */ in updateSlavesWaitingBgsave()
908 if ((slave->repldbfd = open(server.rdb_filename,O_RDONLY)) == -1 || in updateSlavesWaitingBgsave()
920 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in updateSlavesWaitingBgsave()
921 … if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) { in updateSlavesWaitingBgsave()
936 return server.repl_state >= REPL_STATE_RECEIVE_PONG && in slaveIsInHandshakeState()
937 server.repl_state <= REPL_STATE_RECEIVE_PSYNC; in slaveIsInHandshakeState()
952 if (write(server.repl_transfer_s,"\n",1) == -1) { in replicationSendNewlineToMaster()
969 server.master = createClient(fd); in replicationCreateMasterClient()
970 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
971 server.master->authenticated = 1; in replicationCreateMasterClient()
972 server.repl_state = REPL_STATE_CONNECTED; in replicationCreateMasterClient()
973 server.master->reploff = server.repl_master_initial_offset; in replicationCreateMasterClient()
974 memcpy(server.master->replrunid, server.repl_master_runid, in replicationCreateMasterClient()
975 sizeof(server.repl_master_runid)); in replicationCreateMasterClient()
978 if (server.master->reploff == -1) in replicationCreateMasterClient()
979 server.master->flags |= CLIENT_PRE_PSYNC; in replicationCreateMasterClient()
1000 if (server.repl_transfer_size == -1) { in readSyncBulkPayload()
1001 if (syncReadLine(fd,buf,1024,server.repl_syncio_timeout*1000) == -1) { in readSyncBulkPayload()
1017 server.repl_transfer_lastio = server.unixtime; in readSyncBulkPayload()
1040 server.repl_transfer_size = 0; in readSyncBulkPayload()
1045 server.repl_transfer_size = strtol(buf+1,NULL,10); in readSyncBulkPayload()
1048 (long long) server.repl_transfer_size); in readSyncBulkPayload()
1057 left = server.repl_transfer_size - server.repl_transfer_read; in readSyncBulkPayload()
1068 server.stat_net_input_bytes += nread; in readSyncBulkPayload()
1086 server.repl_transfer_lastio = server.unixtime; in readSyncBulkPayload()
1087 if (write(server.repl_transfer_fd,buf,nread) != nread) { in readSyncBulkPayload()
1091 server.repl_transfer_read += nread; in readSyncBulkPayload()
1095 if (ftruncate(server.repl_transfer_fd, in readSyncBulkPayload()
1096 server.repl_transfer_read - CONFIG_RUN_ID_SIZE) == -1) in readSyncBulkPayload()
1106 if (server.repl_transfer_read >= in readSyncBulkPayload()
1107 server.repl_transfer_last_fsync_off + REPL_MAX_WRITTEN_BEFORE_FSYNC) in readSyncBulkPayload()
1109 off_t sync_size = server.repl_transfer_read - in readSyncBulkPayload()
1110 server.repl_transfer_last_fsync_off; in readSyncBulkPayload()
1111 rdb_fsync_range(server.repl_transfer_fd, in readSyncBulkPayload()
1112 server.repl_transfer_last_fsync_off, sync_size); in readSyncBulkPayload()
1113 server.repl_transfer_last_fsync_off += sync_size; in readSyncBulkPayload()
1118 if (server.repl_transfer_read == server.repl_transfer_size) in readSyncBulkPayload()
1123 if (rename(server.repl_transfer_tmpfile,server.rdb_filename) == -1) { in readSyncBulkPayload()
1135 aeDeleteFileEvent(server.el,server.repl_transfer_s,AE_READABLE); in readSyncBulkPayload()
1137 if (rdbLoad(server.rdb_filename) != C_OK) { in readSyncBulkPayload()
1143 zfree(server.repl_transfer_tmpfile); in readSyncBulkPayload()
1144 close(server.repl_transfer_fd); in readSyncBulkPayload()
1145 replicationCreateMasterClient(server.repl_transfer_s); in readSyncBulkPayload()
1150 if (server.aof_state != AOF_OFF) { in readSyncBulkPayload()
1201 if (syncWrite(fd,cmd,sdslen(cmd),server.repl_syncio_timeout*1000) in sendSynchronousCommand()
1216 if (syncReadLine(fd,buf,sizeof(buf),server.repl_syncio_timeout*1000) in sendSynchronousCommand()
1222 server.repl_transfer_lastio = server.unixtime; in sendSynchronousCommand()
1292 server.repl_master_initial_offset = -1; in slaveTryPartialResynchronization()
1294 if (server.cached_master) { in slaveTryPartialResynchronization()
1295 psync_runid = server.cached_master->replrunid; in slaveTryPartialResynchronization()
1296 snprintf(psync_offset,sizeof(psync_offset),"%lld", server.cached_master->reploff+1); in slaveTryPartialResynchronization()
1309 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1324 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1344 memset(server.repl_master_runid,0,CONFIG_RUN_ID_SIZE+1); in slaveTryPartialResynchronization()
1346 memcpy(server.repl_master_runid, runid, offset-runid-1); in slaveTryPartialResynchronization()
1347 server.repl_master_runid[CONFIG_RUN_ID_SIZE] = '\0'; in slaveTryPartialResynchronization()
1348 server.repl_master_initial_offset = strtoll(offset,NULL,10); in slaveTryPartialResynchronization()
1350 server.repl_master_runid, in slaveTryPartialResynchronization()
1351 server.repl_master_initial_offset); in slaveTryPartialResynchronization()
1397 if (server.repl_state == REPL_STATE_NONE) { in syncWithMaster()
1412 if (server.repl_state == REPL_STATE_CONNECTING) { in syncWithMaster()
1416 aeDeleteFileEvent(server.el,fd,AE_WRITABLE); in syncWithMaster()
1417 server.repl_state = REPL_STATE_RECEIVE_PONG; in syncWithMaster()
1426 if (server.repl_state == REPL_STATE_RECEIVE_PONG) { in syncWithMaster()
1446 server.repl_state = REPL_STATE_SEND_AUTH; in syncWithMaster()
1450 if (server.repl_state == REPL_STATE_SEND_AUTH) { in syncWithMaster()
1451 if (server.masterauth) { in syncWithMaster()
1452 err = sendSynchronousCommand(SYNC_CMD_WRITE,fd,"AUTH",server.masterauth,NULL); in syncWithMaster()
1454 server.repl_state = REPL_STATE_RECEIVE_AUTH; in syncWithMaster()
1457 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1462 if (server.repl_state == REPL_STATE_RECEIVE_AUTH) { in syncWithMaster()
1470 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1475 if (server.repl_state == REPL_STATE_SEND_PORT) { in syncWithMaster()
1476 sds port = sdsfromlonglong(server.slave_announce_port ? in syncWithMaster()
1477 server.slave_announce_port : server.port); in syncWithMaster()
1483 server.repl_state = REPL_STATE_RECEIVE_PORT; in syncWithMaster()
1488 if (server.repl_state == REPL_STATE_RECEIVE_PORT) { in syncWithMaster()
1497 server.repl_state = REPL_STATE_SEND_IP; in syncWithMaster()
1501 if (server.repl_state == REPL_STATE_SEND_IP && in syncWithMaster()
1502 server.slave_announce_ip == NULL) in syncWithMaster()
1504 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1509 if (server.repl_state == REPL_STATE_SEND_IP) { in syncWithMaster()
1511 "ip-address",server.slave_announce_ip, NULL); in syncWithMaster()
1514 server.repl_state = REPL_STATE_RECEIVE_IP; in syncWithMaster()
1519 if (server.repl_state == REPL_STATE_RECEIVE_IP) { in syncWithMaster()
1528 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1535 if (server.repl_state == REPL_STATE_SEND_CAPA) { in syncWithMaster()
1540 server.repl_state = REPL_STATE_RECEIVE_CAPA; in syncWithMaster()
1545 if (server.repl_state == REPL_STATE_RECEIVE_CAPA) { in syncWithMaster()
1554 server.repl_state = REPL_STATE_SEND_PSYNC; in syncWithMaster()
1562 if (server.repl_state == REPL_STATE_SEND_PSYNC) { in syncWithMaster()
1567 server.repl_state = REPL_STATE_RECEIVE_PSYNC; in syncWithMaster()
1572 if (server.repl_state != REPL_STATE_RECEIVE_PSYNC) { in syncWithMaster()
1575 server.repl_state); in syncWithMaster()
1602 if (syncWrite(fd,"SYNC\r\n",6,server.repl_syncio_timeout*1000) == -1) { in syncWithMaster()
1612 "temp-%d.%ld.rdb",(int)server.unixtime,(long int)getpid()); in syncWithMaster()
1623 if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL) in syncWithMaster()
1632 server.repl_state = REPL_STATE_TRANSFER; in syncWithMaster()
1633 server.repl_transfer_size = -1; in syncWithMaster()
1634 server.repl_transfer_read = 0; in syncWithMaster()
1635 server.repl_transfer_last_fsync_off = 0; in syncWithMaster()
1636 server.repl_transfer_fd = dfd; in syncWithMaster()
1637 server.repl_transfer_lastio = server.unixtime; in syncWithMaster()
1638 server.repl_transfer_tmpfile = zstrdup(tmpfile); in syncWithMaster()
1642 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in syncWithMaster()
1644 server.repl_transfer_s = -1; in syncWithMaster()
1645 server.repl_state = REPL_STATE_CONNECT; in syncWithMaster()
1658 server.masterhost,server.masterport,NET_FIRST_BIND_ADDR); in connectWithMaster()
1665 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
1673 server.repl_transfer_lastio = server.unixtime; in connectWithMaster()
1674 server.repl_transfer_s = fd; in connectWithMaster()
1675 server.repl_state = REPL_STATE_CONNECTING; in connectWithMaster()
1684 int fd = server.repl_transfer_s; in undoConnectWithMaster()
1686 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in undoConnectWithMaster()
1688 server.repl_transfer_s = -1; in undoConnectWithMaster()
1695 serverAssert(server.repl_state == REPL_STATE_TRANSFER); in replicationAbortSyncTransfer()
1697 close(server.repl_transfer_fd); in replicationAbortSyncTransfer()
1698 unlink(server.repl_transfer_tmpfile); in replicationAbortSyncTransfer()
1699 zfree(server.repl_transfer_tmpfile); in replicationAbortSyncTransfer()
1711 if (server.repl_state == REPL_STATE_TRANSFER) { in cancelReplicationHandshake()
1713 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1714 } else if (server.repl_state == REPL_STATE_CONNECTING || in cancelReplicationHandshake()
1718 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1727 sdsfree(server.masterhost); in replicationSetMaster()
1728 server.masterhost = sdsnew(ip); in replicationSetMaster()
1729 server.masterport = port; in replicationSetMaster()
1730 if (server.master) freeClient(server.master); in replicationSetMaster()
1736 server.repl_state = REPL_STATE_CONNECT; in replicationSetMaster()
1737 server.master_repl_offset = 0; in replicationSetMaster()
1738 server.repl_down_since = 0; in replicationSetMaster()
1743 if (server.masterhost == NULL) return; /* Nothing to do. */ in replicationUnsetMaster()
1744 sdsfree(server.masterhost); in replicationUnsetMaster()
1745 server.masterhost = NULL; in replicationUnsetMaster()
1746 if (server.master) { in replicationUnsetMaster()
1747 if (listLength(server.slaves) == 0) { in replicationUnsetMaster()
1752 server.master_repl_offset = server.master->reploff; in replicationUnsetMaster()
1755 freeClient(server.master); in replicationUnsetMaster()
1759 server.repl_state = REPL_STATE_NONE; in replicationUnsetMaster()
1765 server.master = NULL; in replicationHandleMasterDisconnection()
1766 server.repl_state = REPL_STATE_CONNECT; in replicationHandleMasterDisconnection()
1767 server.repl_down_since = server.unixtime; in replicationHandleMasterDisconnection()
1776 if (server.cluster_enabled) { in slaveofCommand()
1785 if (server.masterhost) { in slaveofCommand()
1799 if (server.masterhost && !strcasecmp(server.masterhost,c->argv[1]->ptr) in slaveofCommand()
1800 && server.masterport == port) { in slaveofCommand()
1810 server.masterhost, server.masterport, client); in slaveofCommand()
1820 if (server.masterhost == NULL) { in roleCommand()
1828 addReplyLongLong(c,server.master_repl_offset); in roleCommand()
1830 listRewind(server.slaves,&li); in roleCommand()
1853 addReplyBulkCString(c,server.masterhost); in roleCommand()
1854 addReplyLongLong(c,server.masterport); in roleCommand()
1858 switch(server.repl_state) { in roleCommand()
1868 addReplyLongLong(c,server.master ? server.master->reploff : -1); in roleCommand()
1876 client *c = server.master; in replicationSendAck()
1909 serverAssert(server.master != NULL && server.cached_master == NULL); in replicationCacheMaster()
1917 server.cached_master = server.master; in replicationCacheMaster()
1934 if (server.cached_master == NULL) return; in replicationDiscardCachedMaster()
1937 server.cached_master->flags &= ~CLIENT_MASTER; in replicationDiscardCachedMaster()
1938 freeClient(server.cached_master); in replicationDiscardCachedMaster()
1939 server.cached_master = NULL; in replicationDiscardCachedMaster()
1949 server.master = server.cached_master; in replicationResurrectCachedMaster()
1950 server.cached_master = NULL; in replicationResurrectCachedMaster()
1951 server.master->fd = newfd; in replicationResurrectCachedMaster()
1952 server.master->flags &= ~(CLIENT_CLOSE_AFTER_REPLY|CLIENT_CLOSE_ASAP); in replicationResurrectCachedMaster()
1953 server.master->authenticated = 1; in replicationResurrectCachedMaster()
1954 server.master->lastinteraction = server.unixtime; in replicationResurrectCachedMaster()
1955 server.repl_state = REPL_STATE_CONNECTED; in replicationResurrectCachedMaster()
1958 listAddNodeTail(server.clients,server.master); in replicationResurrectCachedMaster()
1959 if (aeCreateFileEvent(server.el, newfd, AE_READABLE, in replicationResurrectCachedMaster()
1960 readQueryFromClient, server.master)) { in replicationResurrectCachedMaster()
1962 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
1967 if (clientHasPendingReplies(server.master)) { in replicationResurrectCachedMaster()
1968 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()
1969 sendReplyToClient, server.master)) { in replicationResurrectCachedMaster()
1971 freeClientAsync(server.master); /* Close ASAP. */ in replicationResurrectCachedMaster()
1986 if (!server.repl_min_slaves_to_write || in refreshGoodSlavesCount()
1987 !server.repl_min_slaves_max_lag) return; in refreshGoodSlavesCount()
1989 listRewind(server.slaves,&li); in refreshGoodSlavesCount()
1992 time_t lag = server.unixtime - slave->repl_ack_time; in refreshGoodSlavesCount()
1995 lag <= server.repl_min_slaves_max_lag) good++; in refreshGoodSlavesCount()
1997 server.repl_good_slaves_count = good; in refreshGoodSlavesCount()
2033 server.repl_scriptcache_size = 10000; in replicationScriptCacheInit()
2034 server.repl_scriptcache_dict = dictCreate(&replScriptCacheDictType,NULL); in replicationScriptCacheInit()
2035 server.repl_scriptcache_fifo = listCreate(); in replicationScriptCacheInit()
2050 dictEmpty(server.repl_scriptcache_dict,NULL); in replicationScriptCacheFlush()
2051 listRelease(server.repl_scriptcache_fifo); in replicationScriptCacheFlush()
2052 server.repl_scriptcache_fifo = listCreate(); in replicationScriptCacheFlush()
2062 if (listLength(server.repl_scriptcache_fifo) == server.repl_scriptcache_size) in replicationScriptCacheAdd()
2064 listNode *ln = listLast(server.repl_scriptcache_fifo); in replicationScriptCacheAdd()
2067 retval = dictDelete(server.repl_scriptcache_dict,oldest); in replicationScriptCacheAdd()
2069 listDelNode(server.repl_scriptcache_fifo,ln); in replicationScriptCacheAdd()
2073 retval = dictAdd(server.repl_scriptcache_dict,key,NULL); in replicationScriptCacheAdd()
2074 listAddNodeHead(server.repl_scriptcache_fifo,key); in replicationScriptCacheAdd()
2081 return dictFind(server.repl_scriptcache_dict,sha1) != NULL; in replicationScriptCacheExists()
2115 server.get_ack_from_slaves = 1; in replicationRequestAckFromSlaves()
2125 listRewind(server.slaves,&li); in replicationCountAcksByOffset()
2160 listAddNodeTail(server.clients_waiting_acks,c); in waitCommand()
2173 listNode *ln = listSearchKey(server.clients_waiting_acks,c); in unblockClientWaitingReplicas()
2175 listDelNode(server.clients_waiting_acks,ln); in unblockClientWaitingReplicas()
2187 listRewind(server.clients_waiting_acks,&li); in processClientsWaitingReplicas()
2218 if (server.masterhost != NULL) { in replicationGetSlaveOffset()
2219 if (server.master) { in replicationGetSlaveOffset()
2220 offset = server.master->reploff; in replicationGetSlaveOffset()
2221 } else if (server.cached_master) { in replicationGetSlaveOffset()
2222 offset = server.cached_master->reploff; in replicationGetSlaveOffset()
2240 if (server.masterhost && in replicationCron()
2241 (server.repl_state == REPL_STATE_CONNECTING || in replicationCron()
2243 (time(NULL)-server.repl_transfer_lastio) > server.repl_timeout) in replicationCron()
2250 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER && in replicationCron()
2251 (time(NULL)-server.repl_transfer_lastio) > server.repl_timeout) in replicationCron()
2258 if (server.masterhost && server.repl_state == REPL_STATE_CONNECTED && in replicationCron()
2259 (time(NULL)-server.master->lastinteraction) > server.repl_timeout) in replicationCron()
2262 freeClient(server.master); in replicationCron()
2266 if (server.repl_state == REPL_STATE_CONNECT) { in replicationCron()
2268 server.masterhost, server.masterport); in replicationCron()
2277 if (server.masterhost && server.master && in replicationCron()
2278 !(server.master->flags & CLIENT_PRE_PSYNC)) in replicationCron()
2290 if ((replication_cron_loops % server.repl_ping_slave_period) == 0) { in replicationCron()
2292 replicationFeedSlaves(server.slaves, server.slaveseldb, in replicationCron()
2303 listRewind(server.slaves,&li); in replicationCron()
2309 server.rdb_child_type != RDB_CHILD_TYPE_SOCKET)) in replicationCron()
2318 if (listLength(server.slaves)) { in replicationCron()
2322 listRewind(server.slaves,&li); in replicationCron()
2328 if ((server.unixtime - slave->repl_ack_time) > server.repl_timeout) in replicationCron()
2339 if (listLength(server.slaves) == 0 && server.repl_backlog_time_limit && in replicationCron()
2340 server.repl_backlog) in replicationCron()
2342 time_t idle = server.unixtime - server.repl_no_slaves_since; in replicationCron()
2344 if (idle > server.repl_backlog_time_limit) { in replicationCron()
2349 (int) server.repl_backlog_time_limit); in replicationCron()
2356 if (listLength(server.slaves) == 0 && in replicationCron()
2357 server.aof_state == AOF_OFF && in replicationCron()
2358 listLength(server.repl_scriptcache_fifo) != 0) in replicationCron()
2369 if (server.rdb_child_pid == -1 && server.aof_child_pid == -1) { in replicationCron()
2376 listRewind(server.slaves,&li); in replicationCron()
2380 idle = server.unixtime - slave->lastinteraction; in replicationCron()
2389 (!server.repl_diskless_sync || in replicationCron()
2390 max_idle > server.repl_diskless_sync_delay)) in replicationCron()