Lines Matching refs:ln
197 listNode *ln; in dupLastObjectIfNeeded() local
199 ln = listLast(reply); in dupLastObjectIfNeeded()
200 cur = listNodeValue(ln); in dupLastObjectIfNeeded()
204 listNodeValue(ln) = new; in dupLastObjectIfNeeded()
206 return listNodeValue(ln); in dupLastObjectIfNeeded()
443 listNode *ln = (listNode*)node; in setDeferredMultiBulkLength() local
449 len = listNodeValue(ln); in setDeferredMultiBulkLength()
453 if (ln->next != NULL) { in setDeferredMultiBulkLength()
454 next = listNodeValue(ln->next); in setDeferredMultiBulkLength()
462 listDelNode(c->reply,ln->next); in setDeferredMultiBulkLength()
738 listNode *ln = listFirst(server.slaves); in disconnectSlaves() local
739 freeClient((client*)ln->value); in disconnectSlaves()
747 listNode *ln; in unlinkClient() local
757 ln = listSearchKey(server.clients,c); in unlinkClient()
758 serverAssert(ln != NULL); in unlinkClient()
759 listDelNode(server.clients,ln); in unlinkClient()
770 ln = listSearchKey(server.clients_pending_write,c); in unlinkClient()
771 serverAssert(ln != NULL); in unlinkClient()
772 listDelNode(server.clients_pending_write,ln); in unlinkClient()
779 ln = listSearchKey(server.unblocked_clients,c); in unlinkClient()
780 serverAssert(ln != NULL); in unlinkClient()
781 listDelNode(server.unblocked_clients,ln); in unlinkClient()
787 listNode *ln; in freeClient() local
847 ln = listSearchKey(l,c); in freeClient()
848 serverAssert(ln != NULL); in freeClient()
849 listDelNode(l,ln); in freeClient()
865 ln = listSearchKey(server.clients_to_close,c); in freeClient()
866 serverAssert(ln != NULL); in freeClient()
867 listDelNode(server.clients_to_close,ln); in freeClient()
891 listNode *ln = listFirst(server.clients_to_close); in freeClientsInAsyncFreeQueue() local
892 client *c = listNodeValue(ln); in freeClientsInAsyncFreeQueue()
896 listDelNode(server.clients_to_close,ln); in freeClientsInAsyncFreeQueue()
1000 listNode *ln; in handleClientsWithPendingWrites() local
1004 while((ln = listNext(&li))) { in handleClientsWithPendingWrites()
1005 client *c = listNodeValue(ln); in handleClientsWithPendingWrites()
1007 listDelNode(server.clients_pending_write,ln); in handleClientsWithPendingWrites()
1367 listNode *ln; in getClientsMaxBuffers() local
1372 while ((ln = listNext(&li)) != NULL) { in getClientsMaxBuffers()
1373 c = listNodeValue(ln); in getClientsMaxBuffers()
1471 listNode *ln; in getAllClientsInfoString() local
1477 while ((ln = listNext(&li)) != NULL) { in getAllClientsInfoString()
1478 client = listNodeValue(ln); in getAllClientsInfoString()
1486 listNode *ln; in clientCommand() local
1566 while ((ln = listNext(&li)) != NULL) { in clientCommand()
1567 client = listNodeValue(ln); in clientCommand()
1834 listNode *ln; in flushSlavesOutputBuffers() local
1837 while((ln = listNext(&li))) { in flushSlavesOutputBuffers()
1838 client *slave = listNodeValue(ln); in flushSlavesOutputBuffers()
1886 listNode *ln; in clientsArePaused() local
1895 while ((ln = listNext(&li)) != NULL) { in clientsArePaused()
1896 c = listNodeValue(ln); in clientsArePaused()