gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

XCLAIM: Create the consumer only on successful claims.

Browse Source 
Fixes #6744.
This commit is contained in:
antirez 2020-01-08 10:10:11 +01:00
parent 0af467d18f
commit 7080a28efc
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/t_stream.c
View File

@ -2246,7 +2246,7 @@ void xclaimCommand(client *c) {
} }
/* Do the actual claiming. */ /* Do the actual claiming. */
streamConsumer *consumer = streamLookupConsumer(group,c->argv[3]->ptr,1); streamConsumer *consumer = NULL;
void *arraylenptr = addReplyDeferredLen(c); void *arraylenptr = addReplyDeferredLen(c);
size_t arraylen = 0; size_t arraylen = 0;
for (int j = 5; j <= last_id_arg; j++) { for (int j = 5; j <= last_id_arg; j++) {
@ -2298,6 +2298,8 @@ void xclaimCommand(client *c) {
if (nack->consumer) if (nack->consumer)
raxRemove(nack->consumer->pel,buf,sizeof(buf),NULL); raxRemove(nack->consumer->pel,buf,sizeof(buf),NULL);
/* Update the consumer and idle time. */ /* Update the consumer and idle time. */
if (consumer == NULL)
consumer = streamLookupConsumer(group,c->argv[3]->ptr,1);
nack->consumer = consumer; nack->consumer = consumer;
nack->delivery_time = deliverytime; nack->delivery_time = deliverytime;
/* Set the delivery attempts counter if given, otherwise /* Set the delivery attempts counter if given, otherwise