Lines Matching refs:streamEncodeID

135 void streamEncodeID(void *buf, streamID *id) {  in streamEncodeID()  function
257         streamEncodeID(rax_key,&id);  in streamAppendItem()
492         streamEncodeID(si->start_key,start);  in streamIteratorStart()
499         streamEncodeID(si->end_key,end);  in streamIteratorStart()
612             streamEncodeID(buf,id);  in streamIteratorGetID()
952             streamEncodeID(buf,&id);  in streamReplyWithRange()
1017     streamEncodeID(startkey,start);  in streamReplyWithRangeFromConsumerPEL()
1018     if (end) streamEncodeID(endkey,end);  in streamReplyWithRangeFromConsumerPEL()
1896         streamEncodeID(buf,&id);  in xackCommand()
2025         streamEncodeID(startkey,&startid);  in xpendingCommand()
2026         streamEncodeID(endkey,&endid);  in xpendingCommand()
2233         streamEncodeID(buf,&id);  in xclaimCommand()