gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 1 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 9fe7cd8f14
commit c7c3b23787
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); lp = lpReplaceInteger(lp,&p,aux+1);
/* Update the listpack with the new pointer. */ /* 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. */ /* Update the number of entries counter. */