Commit 09e3b3b9 authored by antirez's avatar antirez
Browse files

CG: remove unused argument from streamReplyWithRangeFromConsumerPEL().

parent 13ff7bc3
...@@ -41,7 +41,7 @@ ...@@ -41,7 +41,7 @@
#define STREAM_ITEM_FLAG_SAMEFIELDS (1<<1) /* Same fields as master entry. */ #define STREAM_ITEM_FLAG_SAMEFIELDS (1<<1) /* Same fields as master entry. */
void streamFreeCG(streamCG *cg); void streamFreeCG(streamCG *cg);
size_t streamReplyWithRangeFromConsumerPEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamCG *group, streamConsumer *consumer); size_t streamReplyWithRangeFromConsumerPEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamConsumer *consumer);
/* ----------------------------------------------------------------------- /* -----------------------------------------------------------------------
* Low level stream encoding: a radix tree of listpacks. * Low level stream encoding: a radix tree of listpacks.
...@@ -723,7 +723,7 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end ...@@ -723,7 +723,7 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end
* as delivered. */ * as delivered. */
if (group && streamCompareID(start,&group->last_id) <= 0) { if (group && streamCompareID(start,&group->last_id) <= 0) {
return streamReplyWithRangeFromConsumerPEL(c,s,start,end,count, return streamReplyWithRangeFromConsumerPEL(c,s,start,end,count,
group,consumer); consumer);
} }
if (!(flags & STREAM_RWR_RAWENTRIES)) if (!(flags & STREAM_RWR_RAWENTRIES))
...@@ -786,7 +786,7 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end ...@@ -786,7 +786,7 @@ size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end
* seek into the radix tree of the messages in order to emit the full message * seek into the radix tree of the messages in order to emit the full message
* to the client. However clients only reach this code path when they are * to the client. However clients only reach this code path when they are
* fetching the history of already retrieved messages, which is rare. */ * fetching the history of already retrieved messages, which is rare. */
size_t streamReplyWithRangeFromConsumerPEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamCG *group, streamConsumer *consumer) { size_t streamReplyWithRangeFromConsumerPEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamConsumer *consumer) {
raxIterator ri; raxIterator ri;
unsigned char startkey[sizeof(streamID)]; unsigned char startkey[sizeof(streamID)];
unsigned char endkey[sizeof(streamID)]; unsigned char endkey[sizeof(streamID)];
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment