fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-05-16 20:41:19 +00:00
Code Issues Projects Releases Wiki Activity

Fix streamIteratorRemoveEntry() to update elements count.

Browse Source 
Close #4989.
This commit is contained in:
antirez 2018-06-06 11:40:19 +02:00
parent 1317bab0d1
commit 3502d1f16b
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/t_stream.c
View File

@ -691,6 +691,9 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) {
aux = lpGetInteger(p);
lp = lpReplaceInteger(lp,&p,aux+1);
/* Update the number of entries counter. */
si->stream->length--;
/* Re-seek the iterator to fix the now messed up state. */
streamID start, end;
if (si->rev) {