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

streamIteratorRemoveEntry(): set back lp only if pointer changed.

Browse Source 
Most of the times the pointer will remain the same since integers of
similar size don't take more space in listpacks.

Related to #5210.
This commit is contained in:
antirez 2018-10-02 16:20:40 +02:00
parent ba1d382d42
commit 74f1b91282
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/t_stream.c
View File

@ -726,7 +726,8 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) {
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);
if (si->lp != lp)
raxInsert(si->stream->rax,si->ri.key,si->ri.key_len,lp,NULL);
}
/* Update the number of entries counter. */