Lines Matching refs:reply_bytes
111 c->reply_bytes = 0; in createClient()
238 c->reply_bytes += getStringObjectSdsUsedMemory(o); in _addReplyObjectToList()
247 c->reply_bytes -= sdsZmallocSize(tail->ptr); in _addReplyObjectToList()
250 c->reply_bytes += sdsZmallocSize(tail->ptr); in _addReplyObjectToList()
254 c->reply_bytes += getStringObjectSdsUsedMemory(o); in _addReplyObjectToList()
272 c->reply_bytes += sdsZmallocSize(s); in _addReplySdsToList()
280 c->reply_bytes -= sdsZmallocSize(tail->ptr); in _addReplySdsToList()
283 c->reply_bytes += sdsZmallocSize(tail->ptr); in _addReplySdsToList()
287 c->reply_bytes += sdsZmallocSize(s); in _addReplySdsToList()
302 c->reply_bytes += getStringObjectSdsUsedMemory(o); in _addReplyStringToList()
310 c->reply_bytes -= sdsZmallocSize(tail->ptr); in _addReplyStringToList()
313 c->reply_bytes += sdsZmallocSize(tail->ptr); in _addReplyStringToList()
318 c->reply_bytes += getStringObjectSdsUsedMemory(o); in _addReplyStringToList()
452 c->reply_bytes += sdsZmallocSize(len->ptr); in setDeferredMultiBulkLength()
458 c->reply_bytes -= sdsZmallocSize(len->ptr); in setDeferredMultiBulkLength()
459 c->reply_bytes -= getStringObjectSdsUsedMemory(next); in setDeferredMultiBulkLength()
461 c->reply_bytes += sdsZmallocSize(len->ptr); in setDeferredMultiBulkLength()
606 dst->reply_bytes = src->reply_bytes; in copyClientOutputBuffer()
928 c->reply_bytes -= objmem; in writeToClient()
941 c->reply_bytes -= objmem; in writeToClient()
1727 return c->reply_bytes + (list_item_size*listLength(c->reply)); in getClientOutputBufferMemoryUsage()
1817 serverAssert(c->reply_bytes < SIZE_MAX-(1024*64)); in asyncCloseClientOnOutputBufferLimitReached()
1818 if (c->reply_bytes == 0 || c->flags & CLIENT_CLOSE_ASAP) return; in asyncCloseClientOnOutputBufferLimitReached()