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

Stream: update the listpack pointer in streamTrimByLength().

Browse Source
This commit is contained in:
antirez 2018-03-01 17:25:59 +01:00
parent b4e6961fec
commit 4ee8d1377f
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

@ -422,6 +422,9 @@ int64_t streamTrimByLength(stream *s, size_t maxlen, int approx) {
/* TODO: perform a garbage collection. */ /* TODO: perform a garbage collection. */
} }
/* Update the listpack with the new pointer. */
raxInsert(s->rax,ri.key,ri.key_len,lp,NULL);
break; /* If we are here, there was enough to delete in the current break; /* If we are here, there was enough to delete in the current
node, so no need to go to the next node. */ node, so no need to go to the next node. */
} }