Searched refs:listNode (Results 1 – 21 of 21) sorted by relevance
36 typedef struct listNode { struct37 struct listNode *prev; argument38 struct listNode *next; argument40 } listNode; typedef43 listNode *next;48 listNode *head;49 listNode *tail;78 void listDelNode(list *list, listNode *node);80 listNode *listNext(listIter *iter);83 listNode *listSearchKey(list *list, void *key);[all …]
61 listNode *current, *next; in listRelease()82 listNode *node; in listAddNodeHead()108 listNode *node; in listAddNodeTail()127 listNode *node; in listInsertNode()159 void listDelNode(list *list, listNode *node) in listDelNode()221 listNode *listNext(listIter *iter) in listNext()223 listNode *current = iter->next; in listNext()246 listNode *node; in listDup()285 listNode *node; in listSearchKey()308 listNode *n; in listIndex()[all …]
110 listNode *ln; in processUnblockedClients()175 listNode *ln; in disconnectAllBlockedClients()
91 listNode *ln; in pubsubUnsubscribeChannel()151 listNode *ln; in pubsubUnsubscribePattern()203 listNode *ln; in pubsubUnsubscribeAllPatterns()228 listNode *ln; in pubsubPublishMessage()235 listNode *ln; in pubsubPublishMessage()
205 listNode *ln; in watchForKey()235 listNode *ln; in unwatchAllKeys()264 listNode *ln; in touchWatchedKey()286 listNode *ln; in touchWatchedKeysOnFlush()
197 listNode *ln; in dupLastObjectIfNeeded()443 listNode *ln = (listNode*)node; in setDeferredMultiBulkLength()738 listNode *ln = listFirst(server.slaves); in disconnectSlaves()747 listNode *ln; in unlinkClient()787 listNode *ln; in freeClient()1000 listNode *ln; in handleClientsWithPendingWrites()1367 listNode *ln; in getClientsMaxBuffers()1471 listNode *ln; in getAllClientsInfoString()1486 listNode *ln; in clientCommand()1834 listNode *ln; in flushSlavesOutputBuffers()[all …]
174 listNode *ln; in replicationFeedSlaves()269 listNode *ln; in replicationFeedMonitors()513 listNode *ln; in startBgsaveForReplication()636 listNode *ln; in syncCommand()869 listNode *ln; in updateSlavesWaitingBgsave()1822 listNode *ln; in roleCommand()1983 listNode *ln; in refreshGoodSlavesCount()2122 listNode *ln; in replicationCountAcksByOffset()2185 listNode *ln; in processClientsWaitingReplicas()2286 listNode *ln; in replicationCron()[all …]
167 listNode *ln; in bioProcessBackgroundJobs()
142 listNode *ln; in slowlogCommand()
80 listNode *ln; in aofRewriteBufferSize()96 listNode *ln; in aofChildWriteDiffData()125 listNode *ln = listLast(server.aof_rewrite_buf_blocks); in aofRewriteBufferAppend()174 listNode *ln; in aofRewriteBufferWrite()
510 listNode *ln; in sortCommand()538 listNode *ln; in sortCommand()
126 listNode *ln; in freeClient()140 listNode *ln = config.clients->head, *next; in freeAllClients()
1508 listNode *ln; in ldbFlushLog()1566 listNode *ln = listFirst(ldb.logs); in ldbSendLogs()1680 listNode *ln = listSearchKey(ldb.children,(void*)(unsigned long)pid); in ldbRemoveChild()1697 listNode *ln; in ldbKillForkedSessions()
801 listNode *ln = listFirst(l); in handleClientsBlockedOnLists()822 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnLists()
695 listNode *ln; in sentinelScheduleScriptExecution()715 listNode *sentinelGetScriptListNodeByPid(pid_t pid) { in sentinelGetScriptListNodeByPid()716 listNode *ln; in sentinelGetScriptListNodeByPid()732 listNode *ln; in sentinelRunPendingScripts()802 listNode *ln; in sentinelCollectTerminatedScripts()843 listNode *ln; in sentinelKillTimedoutScripts()863 listNode *ln; in sentinelPendingScriptsCommand()
1520 listNode *ln; in backgroundSaveDoneHandlerSocket()1583 listNode *ln; in rdbSaveToSlavesSockets()
1411 listNode *ln = listFirst(l);1692 listNode *ln = listFirst(l);
1001 listNode *head; in clientsCron()3189 listNode *ln; in genRedisInfoString()3458 listNode *ln; in freeMemoryIfNeeded()
494 listNode *node, *nextnode; in scanGenericCommand()
694 listNode *ln; in clusterNodeAddFailureReport()724 listNode *ln; in clusterNodeCleanupFailureReports()751 listNode *ln; in clusterNodeDelFailureReport()
1684 listNode *refnode; in ziplistTest()