Lines Matching refs:listLength
198 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()
346 if (listLength(c->reply) == 0 && (sizeof(c->buf) - c->bufpos) >= 32) { in addReply()
612 return c->bufpos || listLength(c->reply); in clientHasPendingReplies()
629 if (listLength(server.clients) > server.maxclients) { in acceptCommonHandler()
737 while (listLength(server.slaves)) { in disconnectSlaves()
853 if (c->flags & CLIENT_SLAVE && listLength(server.slaves) == 0) in freeClient()
890 while (listLength(server.clients_to_close)) { in freeClientsInAsyncFreeQueue()
1001 int processed = listLength(server.clients_pending_write); in handleClientsWithPendingWrites()
1375 if (listLength(c->reply) > lol) lol = listLength(c->reply); in getClientsMaxBuffers()
1459 (int) listLength(client->pubsub_patterns), in catClientInfoString()
1464 (unsigned long long) listLength(client->reply), in catClientInfoString()
1474 sds o = sdsnewlen(NULL,200*listLength(server.clients)); in getAllClientsInfoString()
1727 return c->reply_bytes + (list_item_size*listLength(c->reply)); in getClientOutputBufferMemoryUsage()