diff options
| author | antirez <antirez@gmail.com> | 2018-01-19 16:39:09 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | ccdae09046e05dae4d2e23a8a98a3ab7305c8d76 (patch) | |
| tree | 6112435b1dfbd42014a05329aa80013265b08f75 /src/blocked.c | |
| parent | b8e52321612f3fa7a3a78779700d74df99b154cf (diff) | |
| download | redis-ccdae09046e05dae4d2e23a8a98a3ab7305c8d76.tar.gz | |
CG: add & populate group+consumer in the blocking state.
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/blocked.c b/src/blocked.c index f438c3353..d560a8f38 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -442,7 +442,9 @@ void unblockClientWaitingData(client *c) { } if (c->bpop.xread_group) { decrRefCount(c->bpop.xread_group); + decrRefCount(c->bpop.xread_consumer); c->bpop.xread_group = NULL; + c->bpop.xread_consumer = NULL; } } |