From efe92ee5462f65b6a4dabb3d578a31bedcad2f33 Mon Sep 17 00:00:00 2001 From: Itamar Haber Date: Tue, 11 Aug 2020 08:11:47 +0300 Subject: [PATCH] Removes dead code (#7642) Appears to be handled by server.stream_node_max_bytes in reality. --- src/t_stream.c | 6 ++---- 1 file 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;