Home
last modified time | relevance | path

Searched refs:listLength (Results 1 – 22 of 22) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dpubsub.c53 listLength(c->pubsub_patterns); in clientSubscriptionsCount()
106 if (listLength(clients) == 0) { in pubsubUnsubscribeChannel()
119 listLength(c->pubsub_patterns)); in pubsubUnsubscribeChannel()
170 listLength(c->pubsub_patterns)); in pubsubUnsubscribePattern()
194 listLength(c->pubsub_patterns)); in pubsubUnsubscribeAllChannels()
219 listLength(c->pubsub_patterns)); in pubsubUnsubscribeAllPatterns()
250 if (listLength(server.pubsub_patterns)) { in pubsubPublishMessage()
369 addReplyLongLong(c,l ? listLength(l) : 0); in pubsubCommand()
373 addReplyLongLong(c,listLength(server.pubsub_patterns)); in pubsubCommand()
H A Dblocked.c116 while (listLength(server.unblocked_clients)) { in processUnblockedClients()
247 while(listLength(server.ready_keys) != 0) { in handleClientsBlockedOnKeys()
257 while(listLength(l) != 0) { in handleClientsBlockedOnKeys()
275 int numclients = listLength(clients); in handleClientsBlockedOnKeys()
336 int numclients = listLength(clients); in handleClientsBlockedOnKeys()
559 if (listLength(l) == 0) in unblockClientWaitingData()
H A Dslowlog.c130 while (listLength(server.slowlog) > server.slowlog_max_len) in slowlogPushEntryIfNeeded()
136 while (listLength(server.slowlog) > 0) in slowlogReset()
157 addReplyLongLong(c,listLength(server.slowlog)); in slowlogCommand()
H A Dnetworking.c246 if (listLength(c->reply) > 0) return C_ERR; in _addReplyToBuffer()
638 if (listLength(src->reply)) in AddReplyFromClient()
660 return c->bufpos || listLength(c->reply); in clientHasPendingReplies()
677 if (listLength(server.clients) > server.maxclients) { in acceptCommonHandler()
785 while (listLength(server.slaves)) { in disconnectSlaves()
958 while (listLength(server.clients_to_close)) { in freeClientsInAsyncFreeQueue()
1019 if (listLength(c->reply) == 0) in writeToClient()
1085 int processed = listLength(server.clients_pending_write); in handleClientsWithPendingWrites()
1601 if (listLength(c->reply) > lol) lol = listLength(c->reply); in getClientsMaxBuffers()
1686 (int) listLength(client->pubsub_patterns), in catClientInfoString()
[all …]
H A Dmulti.c212 if (listLength(server.monitors) && !server.loading) in execCommand()
269 if (listLength(c->watched_keys) == 0) return; in unwatchAllKeys()
282 if (listLength(clients) == 0) in unwatchAllKeys()
H A Dadlist.h57 #define listLength(l) ((l)->len) macro
H A Dreplication.c118 serverAssert(listLength(server.slaves) == 0); in freeReplicationBacklog()
189 if (server.repl_backlog == NULL && listLength(slaves) == 0) return; in replicationFeedSlaves()
192 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
694 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) { in syncCommand()
2361 if (listLength(server.repl_scriptcache_fifo) == server.repl_scriptcache_size) in replicationScriptCacheAdd()
2595 listLength(server.slaves)) in replicationCron()
2645 if (listLength(server.slaves)) { in replicationCron()
2670 if (listLength(server.slaves) == 0 && server.repl_backlog_time_limit && in replicationCron()
2704 if (listLength(server.slaves) == 0 && in replicationCron()
2706 listLength(server.repl_scriptcache_fifo) != 0) in replicationCron()
H A Dredis-cli.c3747 switch (listLength(nodes)){ in clusterManagerFixSlotsCoverage()
3756 if (listLength(none) > 0) { in clusterManagerFixSlotsCoverage()
3783 if (listLength(single) > 0) { in clusterManagerFixSlotsCoverage()
3814 if (listLength(multi) > 0) { in clusterManagerFixSlotsCoverage()
4017 if (listLength(owners) > 1) { in clusterManagerFixOpenSlot()
4043 if (listLength(migrating) == 1 && listLength(importing) == 1) { in clusterManagerFixOpenSlot()
4056 else if (listLength(migrating) == 0 && listLength(importing) > 0) { in clusterManagerFixOpenSlot()
4091 else if (listLength(migrating) == 1 && listLength(importing) > 1) { in clusterManagerFixOpenSlot()
4199 assert(listLength(owners) > 1); in clusterManagerFixMultipleSlotOwners()
4369 if (listLength(owners) > 1) { in clusterManagerCheckCluster()
[all …]
H A Dobject.c987 if (listLength(server.slaves)) { in getMemoryOverheadData()
1003 if (listLength(server.clients)) { in getMemoryOverheadData()
1033 if (listLength(server.repl_scriptcache_fifo) > 0) { in getMemoryOverheadData()
1034 mem += listLength(server.repl_scriptcache_fifo) * (sizeof(listNode) + in getMemoryOverheadData()
1136 long numslaves = listLength(server.slaves); in getMemoryDoctorReport()
1137 long numclients = listLength(server.clients)-numslaves; in getMemoryDoctorReport()
H A Dserver.c972 int numclients = listLength(server.clients); in clientsCron()
1206 listLength(server.clients)-listLength(server.slaves), in serverCron()
1207 listLength(server.slaves), in serverCron()
1396 if (listLength(server.clients_waiting_acks)) in beforeSleep()
1404 if (listLength(server.unblocked_clients)) in beforeSleep()
2429 if (listLength(server.monitors) && in call()
2741 if (listLength(server.ready_keys)) in processCommand()
3221 listLength(server.clients)-listLength(server.slaves), in genRedisInfoString()
3482 listLength(server.pubsub_patterns), in genRedisInfoString()
3548 listLength(server.slaves)); in genRedisInfoString()
[all …]
H A Devict.c354 int slaves = listLength(server.slaves); in freeMemoryGetNotCountedMemory()
454 int slaves = listLength(server.slaves); in freeMemoryIfNeeded()
H A Dbio.c175 if (listLength(bio_jobs[type]) == 0) { in bioProcessBackgroundJobs()
H A Dadlist.c333 if (listLength(list) <= 1) return; in listRotate()
H A Dscripting.c581 if (listLength(c->reply) == 0 && c->bufpos < PROTO_REPLY_CHUNK_BYTES) { in luaRedisGenericCommand()
591 while(listLength(c->reply)) { in luaRedisGenericCommand()
1630 proto = sdscatfmt(proto,"*%i\r\n", (int)listLength(ldb.logs)); in ldbSendLogs()
1631 while(listLength(ldb.logs)) { in ldbSendLogs()
1758 return listLength(ldb.children); in ldbPendingChildren()
H A Dmodule.c2819 while(listLength(c->reply)) { in RM_Call()
3708 while (listLength(moduleUnblockedClients)) { in moduleHandleBlockedClients()
3972 if (listLength(moduleKeyspaceSubscribers) == 0) return; in moduleNotifyKeyspaceEvent()
4916 if (listLength(moduleCommandFilters) == 0) return; in moduleCallCommandFilters()
5193 } else if (listLength(module->types)) { in moduleUnload()
5196 } else if (listLength(module->usedby)) { in moduleUnload()
H A Ddb.c712 listLength(keys) < (unsigned long)count); in scanGenericCommand()
788 addReplyMultiBulkLen(c, listLength(keys)); in scanGenericCommand()
H A Daof.c153 numblocks = listLength(server.aof_rewrite_buf_blocks); in aofRewriteBufferAppend()
827 listLength(fakeClient->reply) == 0); in loadAppendOnlyFile()
H A Dsentinel.c716 if (listLength(sentinel.scripts_queue) > SENTINEL_SCRIPT_MAX_QUEUE) { in sentinelScheduleScriptExecution()
730 serverAssert(listLength(sentinel.scripts_queue) <= in sentinelScheduleScriptExecution()
889 addReplyMultiBulkLen(c,listLength(sentinel.scripts_queue)); in sentinelPendingScriptsCommand()
3356 listLength(sentinel.scripts_queue), in sentinelInfoCommand()
H A Drdb.c2252 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
2256 clientids = zmalloc(sizeof(uint64_t)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
H A Dconfig.c1759 if (listLength(l) == 0) dictDelete(state->option_to_line,o);
2034 while(listLength(l)) {
H A Dziplist.c1901 assert(listLength(ref) == ziplistLen(zl)); in ziplistTest()
H A Dcluster.c816 return listLength(node->fail_reports); in clusterNodeFailureReportsCount()
2029 listLength(server.pubsub_patterns)) in clusterProcessPacket()