Lines Matching refs:arraylen
900 size_t arraylen = 0; in streamReplyWithRange() local
992 arraylen++; in streamReplyWithRange()
993 if (count && count == arraylen) break; in streamReplyWithRange()
996 if (arraylen_ptr) setDeferredMultiBulkLength(c,arraylen_ptr,arraylen); in streamReplyWithRange()
997 return arraylen; in streamReplyWithRange()
1020 size_t arraylen = 0; in streamReplyWithRangeFromConsumerPEL() local
1024 while(raxNext(&ri) && (!count || arraylen < count)) { in streamReplyWithRangeFromConsumerPEL()
1045 arraylen++; in streamReplyWithRangeFromConsumerPEL()
1048 setDeferredMultiBulkLength(c,arraylen_ptr,arraylen); in streamReplyWithRangeFromConsumerPEL()
1049 return arraylen; in streamReplyWithRangeFromConsumerPEL()
1467 size_t arraylen = 0; in xreadCommand() local
1507 arraylen++; in xreadCommand()
1508 if (arraylen == 1) arraylen_ptr = addDeferredMultiBulkLength(c); in xreadCommand()
1534 if (arraylen) { in xreadCommand()
1535 setDeferredMultiBulkLength(c,arraylen_ptr,arraylen); in xreadCommand()
1993 size_t arraylen = 0; in xpendingCommand() local
2000 arraylen++; in xpendingCommand()
2002 setDeferredMultiBulkLength(c,arraylen_ptr,arraylen); in xpendingCommand()
2030 size_t arraylen = 0; in xpendingCommand() local
2035 arraylen++; in xpendingCommand()
2057 setDeferredMultiBulkLength(c,arraylen_ptr,arraylen); in xpendingCommand()
2227 size_t arraylen = 0; in xclaimCommand() local
2296 arraylen++; in xclaimCommand()
2308 setDeferredMultiBulkLength(c,arraylenptr,arraylen); in xclaimCommand()