summaryrefslogtreecommitdiff
path: root/src/t_stream.c
diff options
context:
space:
mode:
authorItamar Haber <itamar@redislabs.com>2020-08-11 08:11:47 +0300
committerGitHub <noreply@github.com>2020-08-11 08:11:47 +0300
commitefe92ee5462f65b6a4dabb3d578a31bedcad2f33 (patch)
tree82174ae65d69936fbe596d4cb29cf3a9a1a39fe9 /src/t_stream.c
parentd6220f12a9fafeb07ad86fa91e88383ca2a524c8 (diff)
downloadredis-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.c6
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;