diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2019-12-26 15:31:37 +0530 |
|---|---|---|
| committer | Guy Benoish <guy.benoish@redislabs.com> | 2019-12-26 15:31:37 +0530 |
| commit | 1f75ce30dfdb1c8c4df8474f9580f2aff032cfb4 (patch) | |
| tree | 2fa3174e9ec6d93e6af4e0802473d7be39c81f2a /src/stream.h | |
| parent | 324e22accf457edc996971bc97f5474349cd7c4c (diff) | |
| download | redis-1f75ce30dfdb1c8c4df8474f9580f2aff032cfb4.tar.gz | |
Stream: Handle streamID-related edge cases
This commit solves several edge cases that are related to
exhausting the streamID limits: We should correctly calculate
the succeeding streamID instead of blindly incrementing 'seq'
This affects both XREAD and XADD.
Other (unrelated) changes:
Reply with a better error message when trying to add an entry
to a stream that has exhausted last_id
Diffstat (limited to 'src/stream.h')
| -rw-r--r-- | src/stream.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/stream.h b/src/stream.h index 7de769ba1..b69073994 100644 --- a/src/stream.h +++ b/src/stream.h @@ -111,5 +111,6 @@ streamNACK *streamCreateNACK(streamConsumer *consumer); void streamDecodeID(void *buf, streamID *id); int streamCompareID(streamID *a, streamID *b); void streamFreeNACK(streamNACK *na); +void streamIncrID(streamID *id); #endif |