| /f-stack/app/redis-5.0.5/src/ |
| H A D | adlist.h | 36 typedef struct listNode { struct
37 struct listNode *prev; argument
38 struct listNode *next; argument
40 } listNode; typedef
43 listNode *next;
48 listNode *head;
49 listNode *tail;
79 void listDelNode(list *list, listNode *node);
81 listNode *listNext(listIter *iter);
84 listNode *listSearchKey(list *list, void *key);
[all …]
|
| H A D | adlist.c | 59 listNode *current, *next; in listEmpty()
90 listNode *node; in listAddNodeHead()
116 listNode *node; in listAddNodeTail()
135 listNode *node; in listInsertNode()
167 void listDelNode(list *list, listNode *node) in listDelNode()
229 listNode *listNext(listIter *iter) in listNext()
231 listNode *current = iter->next; in listNext()
254 listNode *node; in listDup()
293 listNode *node; in listSearchKey()
316 listNode *n; in listIndex()
[all …]
|
| H A D | blocked.c | 113 listNode *ln; in processUnblockedClients()
208 listNode *ln; in disconnectAllBlockedClients()
258 listNode *ln = listFirst(l); in handleClientsBlockedOnKeys()
278 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnKeys()
340 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnKeys()
384 listNode *ln; in handleClientsBlockedOnKeys()
|
| H A D | pubsub.c | 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()
|
| H A D | multi.c | 237 listNode *ln; in watchForKey()
267 listNode *ln; in unwatchAllKeys()
296 listNode *ln; in touchWatchedKey()
318 listNode *ln; in touchWatchedKeysOnFlush()
|
| H A D | replication.c | 175 listNode *ln; in replicationFeedSlaves()
280 listNode *ln; in replicationFeedSlavesFromMasterStream()
305 listNode *ln; in replicationFeedMonitors()
568 listNode *ln; in startBgsaveForReplication()
711 listNode *ln; in syncCommand()
943 listNode *ln; in updateSlavesWaitingBgsave()
2081 listNode *ln; in roleCommand()
2282 listNode *ln; in refreshGoodSlavesCount()
2421 listNode *ln; in replicationCountAcksByOffset()
2489 listNode *ln; in processClientsWaitingReplicas()
[all …]
|
| H A D | networking.c | 259 listNode *ln = listLast(c->reply); in _addReplyStringToList()
431 listNode *ln = (listNode*)node; in setDeferredMultiBulkLength()
786 listNode *ln = listFirst(server.slaves); in disconnectSlaves()
795 listNode *ln; in unlinkClient()
848 listNode *ln; in freeClient()
1084 listNode *ln; in handleClientsWithPendingWrites()
1593 listNode *ln; in getClientsMaxBuffers()
1698 listNode *ln; in getAllClientsInfoString()
1714 listNode *ln; in clientCommand()
2141 listNode *ln; in flushSlavesOutputBuffers()
[all …]
|
| H A D | redis-cli.c | 2106 listNode *ln; in freeClusterManagerNodeFlags()
2150 listNode *ln; in freeClusterManager()
2284 listNode *ln; in clusterManagerRemoveNodeFromList()
2302 listNode *ln; in clusterManagerNodeByName()
2327 listNode *ln; in clusterManagerNodeByAbbreviatedName()
2576 listNode *ln; in clusterManagerNodeFlagString()
2683 listNode *ln; in clusterManagerShowNodes()
2697 listNode *ln; in clusterManagerShowClusterInfo()
3369 listNode *ln; in clusterManagerLoadInfoFromNode()
3540 listNode *ln; in clusterManagerIsConfigConsistent()
[all …]
|
| H A D | bio.c | 172 listNode *ln; in bioProcessBackgroundJobs()
|
| H A D | slowlog.c | 164 listNode *ln; in slowlogCommand()
|
| H A D | sort.c | 510 listNode *ln; in sortCommand()
538 listNode *ln; in sortCommand()
|
| H A D | module.c | 2907 listNode *ln; in moduleTypeLookupModuleByName()
2946 listNode *ln; in moduleTypeLookupModuleByID()
3700 listNode *ln; in moduleHandleBlockedClients()
3975 listNode *ln; in moduleNotifyKeyspaceEvent()
4005 listNode *ln; in moduleUnsubscribeNotifications()
4792 listNode *ln; in moduleUnregisterUsedAPI()
4798 listNode *ln = listSearchKey(used->usedby,module); in moduleUnregisterUsedAPI()
4813 listNode *ln; in moduleUnregisterFilters()
4899 listNode *ln; in RM_UnregisterCommandFilter()
4919 listNode *ln; in moduleCallCommandFilters()
[all …]
|
| H A D | aof.c | 80 listNode *ln; in aofRewriteBufferSize()
96 listNode *ln; in aofChildWriteDiffData()
126 listNode *ln = listLast(server.aof_rewrite_buf_blocks); in aofRewriteBufferAppend()
175 listNode *ln; in aofRewriteBufferWrite()
|
| H A D | redis-benchmark.c | 126 listNode *ln; in freeClient()
140 listNode *ln = config.clients->head, *next; in freeAllClients()
|
| H A D | defrag.c | 303 listNode *ln, *newln; in activeDefragList()
338 listNode *ln, *newln; in activeDefragSdsListAndDict()
934 listNode *head = listFirst(db->defrag_later); in defragLaterStep()
|
| H A D | object.c | 989 listNode *ln; in getMemoryOverheadData()
1005 listNode *ln; in getMemoryOverheadData()
1034 mem += listLength(server.repl_scriptcache_fifo) * (sizeof(listNode) + in getMemoryOverheadData()
|
| H A D | evict.c | 358 listNode *ln; in freeMemoryGetNotCountedMemory()
|
| H A D | scripting.c | 1574 listNode *ln; in ldbFlushLog()
1632 listNode *ln = listFirst(ldb.logs); in ldbSendLogs()
1747 listNode *ln = listSearchKey(ldb.children,(void*)(unsigned long)pid); in ldbRemoveChild()
1764 listNode *ln; in ldbKillForkedSessions()
|
| H A D | sentinel.c | 717 listNode *ln; in sentinelScheduleScriptExecution()
737 listNode *sentinelGetScriptListNodeByPid(pid_t pid) { in sentinelGetScriptListNodeByPid()
738 listNode *ln; in sentinelGetScriptListNodeByPid()
754 listNode *ln; in sentinelRunPendingScripts()
825 listNode *ln; in sentinelCollectTerminatedScripts()
866 listNode *ln; in sentinelKillTimedoutScripts()
886 listNode *ln; in sentinelPendingScriptsCommand()
|
| H A D | rdb.c | 2172 listNode *ln; in backgroundSaveDoneHandlerSocket()
2235 listNode *ln; in rdbSaveToSlavesSockets()
|
| H A D | config.c | 1753 listNode *ln = listFirst(l);
2035 listNode *ln = listFirst(l);
|
| H A D | db.c | 627 listNode *node, *nextnode; in scanGenericCommand()
|
| H A D | ziplist.c | 1854 listNode *refnode; in ziplistTest()
|
| H A D | cluster.c | 736 listNode *ln; in clusterNodeAddFailureReport()
766 listNode *ln; in clusterNodeCleanupFailureReports()
793 listNode *ln; in clusterNodeDelFailureReport()
|
| H A D | server.c | 985 listNode *head; in clientsCron()
3561 listNode *ln; in genRedisInfoString()
|