Searched refs:streamReplyWithRange (Results 1 – 4 of 4) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | stream.h | 101 size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end, size_t count, int…
|
| H A D | t_stream.c | 898 size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end, size_t count, int… in streamReplyWithRange() function 1028 if (streamReplyWithRange(c,s,&thisid,&thisid,1,0,NULL,NULL, in streamReplyWithRangeFromConsumerPEL() 1297 streamReplyWithRange(c,s,&startid,&endid,count,rev,NULL,NULL,0,NULL); in xrangeGenericCommand() 1526 streamReplyWithRange(c,s,&start,NULL,count,0, in xreadCommand() 2292 size_t emitted = streamReplyWithRange(c,o->ptr,&id,&id,1,0, in xclaimCommand() 2537 count = streamReplyWithRange(c,s,&start,&end,1,0,NULL,NULL, in xinfoCommand() 2541 count = streamReplyWithRange(c,s,&start,&end,1,1,NULL,NULL, in xinfoCommand()
|
| H A D | blocked.c | 447 streamReplyWithRange(receiver,s,&start,NULL, in handleClientsBlockedOnKeys()
|
| /f-stack/app/redis-5.0.5/ |
| H A D | 00-RELEASENOTES | 829 Improve streamReplyWithRange() top comment. 889 Fix typo in streamReplyWithRange() top comment.
|