Lines Matching refs:reply
110 c->reply = listCreate(); in createClient()
113 listSetFreeMethod(c->reply,decrRefCountVoid); in createClient()
114 listSetDupMethod(c->reply,dupClientReplyValue); in createClient()
195 robj *dupLastObjectIfNeeded(list *reply) { in dupLastObjectIfNeeded() argument
198 serverAssert(listLength(reply) > 0); in dupLastObjectIfNeeded()
199 ln = listLast(reply); in dupLastObjectIfNeeded()
220 if (listLength(c->reply) > 0) return C_ERR; in _addReplyToBuffer()
235 if (listLength(c->reply) == 0) { in _addReplyObjectToList()
237 listAddNodeTail(c->reply,o); in _addReplyObjectToList()
240 tail = listNodeValue(listLast(c->reply)); in _addReplyObjectToList()
248 tail = dupLastObjectIfNeeded(c->reply); in _addReplyObjectToList()
253 listAddNodeTail(c->reply,o); in _addReplyObjectToList()
270 if (listLength(c->reply) == 0) { in _addReplySdsToList()
271 listAddNodeTail(c->reply,createObject(OBJ_STRING,s)); in _addReplySdsToList()
274 tail = listNodeValue(listLast(c->reply)); in _addReplySdsToList()
281 tail = dupLastObjectIfNeeded(c->reply); in _addReplySdsToList()
286 listAddNodeTail(c->reply,createObject(OBJ_STRING,s)); in _addReplySdsToList()
298 if (listLength(c->reply) == 0) { in _addReplyStringToList()
301 listAddNodeTail(c->reply,o); in _addReplyStringToList()
304 tail = listNodeValue(listLast(c->reply)); in _addReplyStringToList()
311 tail = dupLastObjectIfNeeded(c->reply); in _addReplyStringToList()
317 listAddNodeTail(c->reply,o); in _addReplyStringToList()
346 if (listLength(c->reply) == 0 && (sizeof(c->buf) - c->bufpos) >= 32) { in addReply()
437 listAddNodeTail(c->reply,createObject(OBJ_STRING,NULL)); in addDeferredMultiBulkLength()
438 return listLast(c->reply); in addDeferredMultiBulkLength()
462 listDelNode(c->reply,ln->next); in setDeferredMultiBulkLength()
602 listRelease(dst->reply); in copyClientOutputBuffer()
603 dst->reply = listDup(src->reply); in copyClientOutputBuffer()
612 return c->bufpos || listLength(c->reply); in clientHasPendingReplies()
831 listRelease(c->reply); in freeClient()
922 o = listNodeValue(listFirst(c->reply)); in writeToClient()
927 listDelNode(c->reply,listFirst(c->reply)); in writeToClient()
939 listDelNode(c->reply,listFirst(c->reply)); in writeToClient()
1375 if (listLength(c->reply) > lol) lol = listLength(c->reply); in getClientsMaxBuffers()
1464 (unsigned long long) listLength(client->reply), in catClientInfoString()
1727 return c->reply_bytes + (list_item_size*listLength(c->reply)); in getClientOutputBufferMemoryUsage()