diff options
| author | Guy Benoish <guy.benoish@redislabs.com> | 2019-10-10 09:47:48 +0200 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2019-11-19 17:27:57 +0100 |
| commit | 69b1b5be6b67c65fede8c4120962d4edb887633b (patch) | |
| tree | f627fb6b195cbe09d16f49bd1df558941bd9da8c | |
| parent | 1fd97ee7f192beec7dbde44ee0adee39d9eb6547 (diff) | |
| download | redis-69b1b5be6b67c65fede8c4120962d4edb887633b.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 d7f924cf7..ae1516423 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -245,17 +245,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. */ |