Commit a3a14605 authored by zhaozhao.zz's avatar zhaozhao.zz
Browse files

Streams: update listpack with new pointer in XDEL

parent 39c70e72
...@@ -724,6 +724,9 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) { ...@@ -724,6 +724,9 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) {
p = lpNext(lp,p); /* Seek deleted field. */ p = lpNext(lp,p); /* Seek deleted field. */
aux = lpGetInteger(p); aux = lpGetInteger(p);
lp = lpReplaceInteger(lp,&p,aux+1); 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. */ /* Update the number of entries counter. */
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment