diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2019-10-10 09:47:48 +0200 |
|---|---|---|
| committer | Guy Benoish <guy.benoish@redislabs.com> | 2019-10-10 09:47:48 +0200 |
| commit | 2fae0192e86c4222d8c735fda8a1f35164e1ca92 (patch) | |
| tree | b0003211a56e37820918f3b69744e722df462e42 | |
| parent | ee1cef189fff604f165b2d20a307545840de944e (diff) | |
| download | redis-2fae0192e86c4222d8c735fda8a1f35164e1ca92.tar.gz | |
Fix usage of server.stream_node_max_*
| -rw-r--r-- | src/t_stream.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index 9e7d3d126..ea9a620f1 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -242,17 +242,17 @@ int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_ * the current node is full. */ if (lp != NULL) { if (server.stream_node_max_bytes && - lp_bytes > server.stream_node_max_bytes) + lp_bytes >= server.stream_node_max_bytes) { lp = NULL; } else if (server.stream_node_max_entries) { int64_t count = lpGetInteger(lpFirst(lp)); - if (count > server.stream_node_max_entries) lp = NULL; + if (count >= server.stream_node_max_entries) lp = NULL; } } int flags = STREAM_ITEM_FLAG_NONE; - if (lp == NULL || lp_bytes > server.stream_node_max_bytes) { + if (lp == NULL || lp_bytes >= server.stream_node_max_bytes) { master_id = id; streamEncodeID(rax_key,&id); /* Create the listpack having the master entry ID and fields. */ |