Home
last modified time | relevance | path

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

/redis-3.2.3/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()
361 addReplyLongLong(c,l ? listLength(l) : 0); in pubsubCommand()
365 addReplyLongLong(c,listLength(server.pubsub_patterns)); in pubsubCommand()
H A Dslowlog.c118 while (listLength(server.slowlog) > server.slowlog_max_len) in slowlogPushEntryIfNeeded()
124 while (listLength(server.slowlog) > 0) in slowlogReset()
135 addReplyLongLong(c,listLength(server.slowlog)); in slowlogCommand()
H A Dnetworking.c198 serverAssert(listLength(reply) > 0); in dupLastObjectIfNeeded()
220 if (listLength(c->reply) > 0) return C_ERR; in _addReplyToBuffer()
235 if (listLength(c->reply) == 0) { in _addReplyObjectToList()
270 if (listLength(c->reply) == 0) { in _addReplySdsToList()
298 if (listLength(c->reply) == 0) { in _addReplyStringToList()
612 return c->bufpos || listLength(c->reply); in clientHasPendingReplies()
737 while (listLength(server.slaves)) { in disconnectSlaves()
890 while (listLength(server.clients_to_close)) { in freeClientsInAsyncFreeQueue()
1375 if (listLength(c->reply) > lol) lol = listLength(c->reply); in getClientsMaxBuffers()
1459 (int) listLength(client->pubsub_patterns), in catClientInfoString()
[all …]
H A Dmulti.c180 if (listLength(server.monitors) && !server.loading) in execCommand()
237 if (listLength(c->watched_keys) == 0) return; in unwatchAllKeys()
250 if (listLength(clients) == 0) in unwatchAllKeys()
H A Dreplication.c122 serverAssert(listLength(server.slaves) == 0); in freeReplicationBacklog()
181 if (server.repl_backlog == NULL && listLength(slaves) == 0) return; in replicationFeedSlaves()
184 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
689 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) in syncCommand()
1747 if (listLength(server.slaves) == 0) { in replicationUnsetMaster()
2062 if (listLength(server.repl_scriptcache_fifo) == server.repl_scriptcache_size) in replicationScriptCacheAdd()
2318 if (listLength(server.slaves)) { in replicationCron()
2339 if (listLength(server.slaves) == 0 && server.repl_backlog_time_limit && in replicationCron()
2356 if (listLength(server.slaves) == 0 && in replicationCron()
2358 listLength(server.repl_scriptcache_fifo) != 0) in replicationCron()
H A Dadlist.h57 #define listLength(l) ((l)->len) macro
H A Dblocked.c113 while (listLength(server.unblocked_clients)) { in processUnblockedClients()
H A Dserver.c988 int numclients = listLength(server.clients); in clientsCron()
1159 listLength(server.clients)-listLength(server.slaves), in serverCron()
1160 listLength(server.slaves), in serverCron()
1343 if (listLength(server.clients_waiting_acks)) in beforeSleep()
1347 if (listLength(server.unblocked_clients)) in beforeSleep()
2226 if (listLength(server.monitors) && in call()
2522 if (listLength(server.ready_keys)) in processCommand()
2921 listLength(server.clients)-listLength(server.slaves), in genRedisInfoString()
3176 listLength(server.slaves)); in genRedisInfoString()
3187 if (listLength(server.slaves)) { in genRedisInfoString()
[all …]
H A Dbio.c170 if (listLength(bio_jobs[type]) == 0) { in bioProcessBackgroundJobs()
H A Dt_list.c667 if (listLength(l) == 0) in unblockClientWaitingData()
790 while(listLength(server.ready_keys) != 0) { in handleClientsBlockedOnLists()
800 while(listLength(l) != 0) { in handleClientsBlockedOnLists()
819 int numclients = listLength(clients); in handleClientsBlockedOnLists()
H A Dadlist.c325 if (listLength(list) <= 1) return; in listRotate()
H A Dscripting.c558 if (listLength(c->reply) == 0 && c->bufpos < PROTO_REPLY_CHUNK_BYTES) { in luaRedisGenericCommand()
568 while(listLength(c->reply)) { in luaRedisGenericCommand()
1564 proto = sdscatfmt(proto,"*%i\r\n", (int)listLength(ldb.logs)); in ldbSendLogs()
1565 while(listLength(ldb.logs)) { in ldbSendLogs()
1691 return listLength(ldb.children); in ldbPendingChildren()
H A Daof.c152 numblocks = listLength(server.aof_rewrite_buf_blocks); in aofRewriteBufferAppend()
702 serverAssert(fakeClient->bufpos == 0 && listLength(fakeClient->reply) == 0); in loadAppendOnlyFile()
H A Ddb.c579 listLength(keys) < (unsigned long)count); in scanGenericCommand()
655 addReplyMultiBulkLen(c, listLength(keys)); in scanGenericCommand()
H A Drdb.c1600 fds = zmalloc(sizeof(int)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
1604 clientids = zmalloc(sizeof(uint64_t)*listLength(server.slaves)); in rdbSaveToSlavesSockets()
H A Dsentinel.c694 if (listLength(sentinel.scripts_queue) > SENTINEL_SCRIPT_MAX_QUEUE) { in sentinelScheduleScriptExecution()
708 serverAssert(listLength(sentinel.scripts_queue) <= in sentinelScheduleScriptExecution()
866 addReplyMultiBulkLen(c,listLength(sentinel.scripts_queue)); in sentinelPendingScriptsCommand()
3250 listLength(sentinel.scripts_queue), in sentinelInfoCommand()
H A Dconfig.c1417 if (listLength(l) == 0) dictDelete(state->option_to_line,o);
1691 while(listLength(l)) {
H A Dziplist.c1731 assert(listLength(ref) == ziplistLen(zl)); in ziplistTest()
H A Dcluster.c774 return listLength(node->fail_reports); in clusterNodeFailureReportsCount()
1912 listLength(server.pubsub_patterns)) in clusterProcessPacket()