Lines Matching refs:ln
175 listNode *ln; in replicationFeedSlaves() local
216 while((ln = listNext(&li))) { in replicationFeedSlaves()
217 client *slave = ln->value; in replicationFeedSlaves()
256 while((ln = listNext(&li))) { in replicationFeedSlaves()
257 client *slave = ln->value; in replicationFeedSlaves()
280 listNode *ln; in replicationFeedSlavesFromMasterStream() local
295 while((ln = listNext(&li))) { in replicationFeedSlavesFromMasterStream()
296 client *slave = ln->value; in replicationFeedSlavesFromMasterStream()
305 listNode *ln; in replicationFeedMonitors() local
336 while((ln = listNext(&li))) { in replicationFeedMonitors()
337 client *monitor = ln->value; in replicationFeedMonitors()
568 listNode *ln; in startBgsaveForReplication() local
593 while((ln = listNext(&li))) { in startBgsaveForReplication()
594 client *slave = ln->value; in startBgsaveForReplication()
599 listDelNode(server.slaves,ln); in startBgsaveForReplication()
612 while((ln = listNext(&li))) { in startBgsaveForReplication()
613 client *slave = ln->value; in startBgsaveForReplication()
711 listNode *ln; in syncCommand() local
715 while((ln = listNext(&li))) { in syncCommand()
716 slave = ln->value; in syncCommand()
721 if (ln && ((c->slave_capa & slave->slave_capa) == slave->slave_capa)) { in syncCommand()
943 listNode *ln; in updateSlavesWaitingBgsave() local
949 while((ln = listNext(&li))) { in updateSlavesWaitingBgsave()
950 client *slave = ln->value; in updateSlavesWaitingBgsave()
2081 listNode *ln; in roleCommand() local
2090 while((ln = listNext(&li))) { in roleCommand()
2091 client *slave = ln->value; in roleCommand()
2282 listNode *ln; in refreshGoodSlavesCount() local
2289 while((ln = listNext(&li))) { in refreshGoodSlavesCount()
2290 client *slave = ln->value; in refreshGoodSlavesCount()
2363 listNode *ln = listLast(server.repl_scriptcache_fifo); in replicationScriptCacheAdd() local
2364 sds oldest = listNodeValue(ln); in replicationScriptCacheAdd()
2368 listDelNode(server.repl_scriptcache_fifo,ln); in replicationScriptCacheAdd()
2421 listNode *ln; in replicationCountAcksByOffset() local
2425 while((ln = listNext(&li))) { in replicationCountAcksByOffset()
2426 client *slave = ln->value; in replicationCountAcksByOffset()
2477 listNode *ln = listSearchKey(server.clients_waiting_acks,c); in unblockClientWaitingReplicas() local
2478 serverAssert(ln != NULL); in unblockClientWaitingReplicas()
2479 listDelNode(server.clients_waiting_acks,ln); in unblockClientWaitingReplicas()
2489 listNode *ln; in processClientsWaitingReplicas() local
2492 while((ln = listNext(&li))) { in processClientsWaitingReplicas()
2493 client *c = ln->value; in processClientsWaitingReplicas()
2590 listNode *ln; in replicationCron() local
2629 while((ln = listNext(&li))) { in replicationCron()
2630 client *slave = ln->value; in replicationCron()
2647 listNode *ln; in replicationCron() local
2650 while((ln = listNext(&li))) { in replicationCron()
2651 client *slave = ln->value; in replicationCron()
2721 listNode *ln; in replicationCron() local
2725 while((ln = listNext(&li))) { in replicationCron()
2726 client *slave = ln->value; in replicationCron()