Lines Matching refs:ln
174 listNode *ln; in replicationFeedSlaves() local
208 while((ln = listNext(&li))) { in replicationFeedSlaves()
209 client *slave = ln->value; in replicationFeedSlaves()
248 while((ln = listNext(&li))) { in replicationFeedSlaves()
249 client *slave = ln->value; in replicationFeedSlaves()
269 listNode *ln; in replicationFeedMonitors() local
300 while((ln = listNext(&li))) { in replicationFeedMonitors()
301 client *monitor = ln->value; in replicationFeedMonitors()
513 listNode *ln; in startBgsaveForReplication() local
529 while((ln = listNext(&li))) { in startBgsaveForReplication()
530 client *slave = ln->value; in startBgsaveForReplication()
534 listDelNode(server.slaves,ln); in startBgsaveForReplication()
547 while((ln = listNext(&li))) { in startBgsaveForReplication()
548 client *slave = ln->value; in startBgsaveForReplication()
636 listNode *ln; in syncCommand() local
640 while((ln = listNext(&li))) { in syncCommand()
641 slave = ln->value; in syncCommand()
646 if (ln && ((c->slave_capa & slave->slave_capa) == slave->slave_capa)) { in syncCommand()
869 listNode *ln; in updateSlavesWaitingBgsave() local
875 while((ln = listNext(&li))) { in updateSlavesWaitingBgsave()
876 client *slave = ln->value; in updateSlavesWaitingBgsave()
1822 listNode *ln; in roleCommand() local
1831 while((ln = listNext(&li))) { in roleCommand()
1832 client *slave = ln->value; in roleCommand()
1983 listNode *ln; in refreshGoodSlavesCount() local
1990 while((ln = listNext(&li))) { in refreshGoodSlavesCount()
1991 client *slave = ln->value; in refreshGoodSlavesCount()
2064 listNode *ln = listLast(server.repl_scriptcache_fifo); in replicationScriptCacheAdd() local
2065 sds oldest = listNodeValue(ln); in replicationScriptCacheAdd()
2069 listDelNode(server.repl_scriptcache_fifo,ln); in replicationScriptCacheAdd()
2122 listNode *ln; in replicationCountAcksByOffset() local
2126 while((ln = listNext(&li))) { in replicationCountAcksByOffset()
2127 client *slave = ln->value; in replicationCountAcksByOffset()
2173 listNode *ln = listSearchKey(server.clients_waiting_acks,c); in unblockClientWaitingReplicas() local
2174 serverAssert(ln != NULL); in unblockClientWaitingReplicas()
2175 listDelNode(server.clients_waiting_acks,ln); in unblockClientWaitingReplicas()
2185 listNode *ln; in processClientsWaitingReplicas() local
2188 while((ln = listNext(&li))) { in processClientsWaitingReplicas()
2189 client *c = ln->value; in processClientsWaitingReplicas()
2286 listNode *ln; in replicationCron() local
2304 while((ln = listNext(&li))) { in replicationCron()
2305 client *slave = ln->value; in replicationCron()
2320 listNode *ln; in replicationCron() local
2323 while((ln = listNext(&li))) { in replicationCron()
2324 client *slave = ln->value; in replicationCron()
2373 listNode *ln; in replicationCron() local
2377 while((ln = listNext(&li))) { in replicationCron()
2378 client *slave = ln->value; in replicationCron()