diff options
author | Itamar Haber <itamar@redislabs.com> | 2020-08-11 08:11:47 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-08-11 08:11:47 +0300 |
commit | efe92ee5462f65b6a4dabb3d578a31bedcad2f33 (patch) | |
tree | 82174ae65d69936fbe596d4cb29cf3a9a1a39fe9 /src/t_stream.c | |
parent | d6220f12a9fafeb07ad86fa91e88383ca2a524c8 (diff) | |
download | redis-efe92ee5462f65b6a4dabb3d578a31bedcad2f33.tar.gz |
Removes dead code (#7642)
Appears to be handled by server.stream_node_max_bytes in reality.
Diffstat (limited to 'src/t_stream.c')
-rw-r--r-- | src/t_stream.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 79265a6fb..38bdce8e0 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -31,8 +31,6 @@ #include "endianconv.h" #include "stream.h" -#define STREAM_BYTES_PER_LISTPACK 2048 - /* Every stream item inside the listpack, has a flags field that is used to * mark the entry as deleted, or having the same field as the "master" * entry at the start of the listpack> */ @@ -199,7 +197,7 @@ int streamCompareID(streamID *a, streamID *b) { * C_ERR if an ID was given via 'use_id', but adding it failed since the * current top ID is greater or equal. */ int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_id, streamID *use_id) { - + /* Generate the new entry ID. */ streamID id; if (use_id) @@ -209,7 +207,7 @@ int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_ /* Check that the new ID is greater than the last entry ID * or return an error. Automatically generated IDs might - * overflow (and wrap-around) when incrementing the sequence + * overflow (and wrap-around) when incrementing the sequence part. */ if (streamCompareID(&id,&s->last_id) <= 0) return C_ERR; |