fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-06-22 13:31:32 +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 0a698e499a
commit b61416bdf4
1 changed files with 3 additions and 0 deletions
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); aux = lpGetInteger(p);
lp = lpReplaceInteger(lp,&p,aux+1); 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. */ /* Re-seek the iterator to fix the now messed up state. */
streamID start, end; streamID start, end;
if (si->rev) { if (si->rev) {