From 6d34ff3645e97e4537ae9136ef4e015591142d01 Mon Sep 17 00:00:00 2001 From: antirez Date: Thu, 7 Jun 2018 14:30:25 +0200 Subject: [PATCH] Streams: max node limits only checked if non zero. --- src/t_stream.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/t_stream.c b/src/t_stream.c index e5d29764..71ed6318 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -241,9 +241,11 @@ int streamAppendItem(stream *s, robj **argv, int numfields, streamID *added_id, * if we need to switch to the next one. 'lp' will be set to NULL if * the current node is full. */ if (lp != NULL) { - if (lp_bytes > server.stream_node_max_bytes) { + if (server.stream_node_max_bytes && + lp_bytes > server.stream_node_max_bytes) + { lp = NULL; - } else { + } else if (server.stream_node_max_entries) { int64_t count = lpGetInteger(lpFirst(lp)); if (count > server.stream_node_max_entries) lp = NULL; }