Searched refs:listFirst (Results 1 – 13 of 13) sorted by relevance
117 ln = listFirst(server.unblocked_clients); in processUnblockedClients()258 listNode *ln = listFirst(l); in handleClientsBlockedOnKeys()278 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnKeys()340 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnKeys()
58 #define listFirst(l) ((l)->head) macro
180 ln = listFirst(bio_jobs[type]); in bioProcessBackgroundJobs()
786 listNode *ln = listFirst(server.slaves); in disconnectSlaves()959 listNode *ln = listFirst(server.clients_to_close); in freeClientsInAsyncFreeQueue()998 o = listNodeValue(listFirst(c->reply)); in writeToClient()1003 listDelNode(c->reply,listFirst(c->reply)); in writeToClient()1015 listDelNode(c->reply,listFirst(c->reply)); in writeToClient()
592 clientReplyBlock *o = listNodeValue(listFirst(c->reply)); in luaRedisGenericCommand()595 listDelNode(c->reply,listFirst(c->reply)); in luaRedisGenericCommand()1576 while((ln = listFirst(log)) != NULL) in ldbFlushLog()1632 listNode *ln = listFirst(ldb.logs); in ldbSendLogs()
934 listNode *head = listFirst(db->defrag_later); in defragLaterStep()946 head = listFirst(db->defrag_later); in defragLaterStep()
3796 listNode *fn = listFirst(nodes); in clusterManagerFixSlotsCoverage()3918 if (listLength(owners) == 1) owner = listFirst(owners)->value; in clusterManagerFixOpenSlot()4044 clusterManagerNode *src = listFirst(migrating)->value; in clusterManagerFixOpenSlot()4045 clusterManagerNode *dst = listFirst(importing)->value; in clusterManagerFixOpenSlot()4093 clusterManagerNode *src = listFirst(migrating)->value; in clusterManagerFixOpenSlot()4152 clusterManagerNode *n = listFirst(migrating)->value; in clusterManagerFixOpenSlot()4169 clusterManagerNode *n = listFirst(migrating)->value; in clusterManagerFixOpenSlot()4203 if (!owner) owner = listFirst(owners)->value; in clusterManagerFixMultipleSlotOwners()4234 listNode *ln = listFirst(cluster_manager.nodes); in clusterManagerCheckCluster()4918 clusterManagerNode *first = listFirst(cluster_manager.nodes)->value; in clusterManagerCommandAddNode()
739 node = listFirst(keys); in scanGenericCommand()789 while ((node = listFirst(keys)) != NULL) { in scanGenericCommand()
1753 listNode *ln = listFirst(l);2035 listNode *ln = listFirst(l);
2820 clientReplyBlock *o = listNodeValue(listFirst(c->reply)); in RM_Call()2823 listDelNode(c->reply,listFirst(c->reply)); in RM_Call()3709 ln = listFirst(moduleUnblockedClients); in moduleHandleBlockedClients()
1035 sdsZmallocSize(listNodeValue(listFirst(server.repl_scriptcache_fifo)))); in getMemoryOverheadData()
105 ln = listFirst(server.aof_rewrite_buf_blocks); in aofChildWriteDiffData()
991 head = listFirst(server.clients); in clientsCron()