Lines Matching refs:numfields
175 int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_id, streamID *use_i… in streamAppendItem() argument
262 lp = lpAppendInteger(lp,numfields); in streamAppendItem()
263 for (int64_t i = 0; i < numfields; i++) { in streamAppendItem()
290 if (numfields == master_fields_count) { in streamAppendItem()
334 lp = lpAppendInteger(lp,numfields); in streamAppendItem()
335 for (int64_t i = 0; i < numfields; i++) { in streamAppendItem()
342 int64_t lp_count = numfields; in streamAppendItem()
347 lp_count += numfields+1; in streamAppendItem()
533 int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields) { in streamIteratorGetID() argument
617 *numfields = si->master_fields_count; in streamIteratorGetID()
619 *numfields = lpGetInteger(si->lp_ele); in streamIteratorGetID()
654 *numfields : *numfields*2; in streamIteratorGetID()
767 int64_t numfields; in streamDeleteItem() local
768 if (streamIteratorGetID(&si,&myid,&numfields)) { in streamDeleteItem()
902 int64_t numfields; in streamReplyWithRange() local
919 while(streamIteratorGetID(&si,&id,&numfields)) { in streamReplyWithRange()
930 addReplyMultiBulkLen(c,numfields*2); in streamReplyWithRange()
933 while(numfields--) { in streamReplyWithRange()
1852 int64_t numfields; in xsetidCommand() local
1853 streamIteratorGetID(&si,&maxid,&numfields); in xsetidCommand()
2246 int64_t numfields; in xclaimCommand() local
2249 if (streamIteratorGetID(&myiterator,&item_id,&numfields)) found = 1; in xclaimCommand()