diff options
| author | Oran Agra <oran@redislabs.com> | 2021-09-26 18:46:22 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-09-26 18:46:22 +0300 |
| commit | 5a4ab7c7d2da1773c5ed3dcfc6e367b5af03a33e (patch) | |
| tree | b903974bde3801ca8181b97f1e3d6910272b5bca /src/t_stream.c | |
| parent | 66002530466a45bce85e4930364f1b153c44840b (diff) | |
| download | redis-5a4ab7c7d2da1773c5ed3dcfc6e367b5af03a33e.tar.gz | |
Fix stream sanitization for non-int first value (#9553)
This was recently broken in #9321 when we validated stream IDs to be
integers but did that after to the stepping next record instead of before.
Diffstat (limited to 'src/t_stream.c')
| -rw-r--r-- | src/t_stream.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 4fa562417..1968475fa 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -3603,12 +3603,12 @@ int streamValidateListpackIntegrity(unsigned char *lp, size_t size, int deep) { p = next; if (!lpValidateNext(lp, &next, size)) return 0; /* entry id */ - p = next; if (!lpValidateNext(lp, &next, size)) return 0; lpGetIntegerIfValid(p, &valid_record); if (!valid_record) return 0; p = next; if (!lpValidateNext(lp, &next, size)) return 0; lpGetIntegerIfValid(p, &valid_record); if (!valid_record) return 0; + p = next; if (!lpValidateNext(lp, &next, size)) return 0; if (!(flags & STREAM_ITEM_FLAG_SAMEFIELDS)) { /* num-of-fields */ |