| /f-stack/app/redis-5.0.5/src/ |
| H A D | blocked.c | 156 listAddNodeTail(server.unblocked_clients,c); in queueClientForReprocessing()
285 listAddNodeTail(clients,receiver); in handleClientsBlockedOnKeys()
347 listAddNodeTail(clients,receiver); in handleClientsBlockedOnKeys()
536 listAddNodeTail(l,c); in blockForKeys()
599 listAddNodeTail(server.ready_keys,rl); in signalKeyAsReady()
|
| H A D | pubsub.c | 76 listAddNodeTail(clients,c); in pubsubSubscribeChannel()
133 listAddNodeTail(c->pubsub_patterns,pattern); in pubsubSubscribePattern()
138 listAddNodeTail(server.pubsub_patterns,pat); in pubsubSubscribePattern()
|
| H A D | adlist.h | 77 list *listAddNodeTail(list *list, void *value);
|
| H A D | adlist.c | 114 list *listAddNodeTail(list *list, void *value) in listAddNodeTail() function
273 if (listAddNodeTail(copy, value) == NULL) { in listDup()
|
| H A D | multi.c | 254 listAddNodeTail(clients,c); in watchForKey()
260 listAddNodeTail(c->watched_keys,wk); in watchForKey()
|
| H A D | bio.c | 139 listAddNodeTail(bio_jobs[type],job); in bioCreateBackgroundJob()
|
| H A D | redis-cli.c | 3377 listAddNodeTail(cluster_manager.nodes, node); in clusterManagerLoadInfoFromNode()
3564 listAddNodeTail(cluster_manager.errors, err); in clusterManagerOnError()
3912 listAddNodeTail(owners, n); in clusterManagerFixOpenSlot()
3931 listAddNodeTail(migrating, n); in clusterManagerFixOpenSlot()
3944 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
3964 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
4035 listAddNodeTail(importing, n); in clusterManagerFixOpenSlot()
4445 listAddNodeTail(moved, item); in clusterManagerComputeReshardTable()
5174 listAddNodeTail(sources, n); in clusterManagerCommandReshard()
5283 listAddNodeTail(involved, n); in clusterManagerCommandRebalance()
[all …]
|
| H A D | db.c | 590 listAddNodeTail(keys, key); in scanCallback()
591 if (val) listAddNodeTail(keys, val); in scanCallback()
718 listAddNodeTail(keys,createStringObjectFromLongLong(ll)); in scanGenericCommand()
728 listAddNodeTail(keys, in scanGenericCommand()
|
| H A D | networking.c | 77 listAddNodeTail(server.clients,c); in linkClient()
286 listAddNodeTail(c->reply, tail); in _addReplyStringToList()
425 listAddNodeTail(c->reply,NULL); /* NULL is our placeholder. */ in addDeferredMultiBulkLength()
954 listAddNodeTail(server.clients_to_close,c); in freeClientAsync()
|
| H A D | module.c | 3077 listAddNodeTail(ctx->module->types,mt); in RM_CreateDataType()
3655 listAddNodeTail(moduleUnblockedClients,bc); in RM_UnblockClient()
3963 listAddNodeTail(moduleKeyspaceSubscribers, sub); in RM_SubscribeToKeyspaceEvents()
4757 listAddNodeTail(sapi->module->usedby,ctx->module); in RM_GetSharedAPI()
4758 listAddNodeTail(ctx->module->using,sapi->module); in RM_GetSharedAPI()
4891 listAddNodeTail(moduleCommandFilters, filter); in RM_RegisterCommandFilter()
4892 listAddNodeTail(ctx->module->filters, filter); in RM_RegisterCommandFilter()
|
| H A D | sort.c | 269 listAddNodeTail(operations,createSortOperation( in sortCommand()
|
| H A D | replication.c | 513 listAddNodeTail(server.slaves,c); in masterTryPartialResynchronization()
691 listAddNodeTail(server.slaves,c); in syncCommand()
2464 listAddNodeTail(server.clients_waiting_acks,c); in waitCommand()
|
| H A D | redis-benchmark.c | 408 listAddNodeTail(config.clients,c); in createClient()
|
| H A D | scripting.c | 1603 listAddNodeTail(ldb.logs,entry); in ldbLog()
1683 listAddNodeTail(ldb.children,(void*)(unsigned long)cp); in ldbStartSession()
|
| H A D | config.c | 169 listAddNodeTail(server.loadmodule_queue,loadmod); in queueLoadModule()
1637 listAddNodeTail(l,(void*)(long)linenum);
|
| H A D | defrag.c | 440 listAddNodeTail(db->defrag_later, key); in defragLater()
|
| H A D | ziplist.c | 1895 listAddNodeTail(ref,sdsnewlen(buf, buflen)); in ziplistTest()
|
| H A D | aof.c | 149 listAddNodeTail(server.aof_rewrite_buf_blocks,block); in aofRewriteBufferAppend()
|
| H A D | server.c | 3698 listAddNodeTail(server.monitors,c); in monitorCommand()
|
| H A D | sentinel.c | 713 listAddNodeTail(sentinel.scripts_queue,sj); in sentinelScheduleScriptExecution()
|
| H A D | cluster.c | 755 listAddNodeTail(l,fr); in clusterNodeAddFailureReport()
|