diff options
| author | antirez <antirez@gmail.com> | 2017-11-17 13:47:50 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2017-12-01 10:24:25 +0100 |
| commit | 6919280cc5eb9a35887ddaa528053380d584327a (patch) | |
| tree | 2172d3b4491f7f2e04a396de88e098f3ccbea219 | |
| parent | ee3490ec481c7f1ef89fe685b03c2b5f171d335b (diff) | |
| download | redis-6919280cc5eb9a35887ddaa528053380d584327a.tar.gz | |
Streams: fix reverse iteration next node jumping.
| -rw-r--r-- | src/t_stream.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 945fc28c0..f64824c9b 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -540,7 +540,11 @@ int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields) { * entry is composed of, and jump backward N times to seek * its start. */ int lp_count = lpGetInteger(si->lp_ele); - if (lp_count == 0) break; /* We reached the master entry. */ + if (lp_count == 0) { /* We reached the master entry. */ + si->lp = NULL; + si->lp_ele = NULL; + break; + } while(lp_count--) si->lp_ele = lpPrev(si->lp,si->lp_ele); } |