diff options
| author | zhaozhao.zz <zhaozhao.zz@alibaba-inc.com> | 2018-08-04 01:06:53 +0800 |
|---|---|---|
| committer | zhaozhao.zz <zhaozhao.zz@alibaba-inc.com> | 2018-08-04 01:06:53 +0800 |
| commit | a3a146052509b2d3a58e36d3511ef238153b6ac3 (patch) | |
| tree | 891f9c7c2d42ed9ce9edb9bf78ac2f773972ce82 | |
| parent | 39c70e728b5af0c50989ffbc05e568099f3e081b (diff) | |
| download | redis-a3a146052509b2d3a58e36d3511ef238153b6ac3.tar.gz | |
Streams: update listpack with new pointer in XDEL
| -rw-r--r-- | src/t_stream.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 77fbf4645..c5d3c7f9d 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -724,6 +724,9 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) { p = lpNext(lp,p); /* Seek deleted field. */ aux = lpGetInteger(p); lp = lpReplaceInteger(lp,&p,aux+1); + + /* Update the listpack with the new pointer. */ + raxInsert(si->stream->rax,si->ri.key,si->ri.key_len,lp,NULL); } /* Update the number of entries counter. */ |