fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 17:10:50 +00:00
Code Issues Projects Releases Wiki Activity

Streams: fix streamTrimByLength() standalone items skipping.

Browse Source
This commit is contained in:
antirez 2017-09-29 16:16:19 +02:00
parent 0540803288
commit 0248a6b125
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/t_stream.c
View File

@ -383,7 +383,7 @@ int64_t streamTrimByLength(stream *s, size_t maxlen, int approx) {
if (flags & STREAM_ITEM_FLAG_SAMEFIELDS) { if (flags & STREAM_ITEM_FLAG_SAMEFIELDS) {
to_skip = master_fields_count; to_skip = master_fields_count;
} else { } else {
to_skip = lpGetInteger(p); p = lpNext(lp,p); to_skip = lpGetInteger(p);
to_skip = 1+(to_skip*2); to_skip = 1+(to_skip*2);
} }