caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-22 16:18:28 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Removes dead code (#7642)

Browse Source 
Appears to be handled by server.stream_node_max_bytes in reality.
This commit is contained in:
Itamar Haber 2020-08-11 08:11:47 +03:00 committed by GitHub
parent d6220f12a9
commit efe92ee546
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/t_stream.c
View File

@ -31,8 +31,6 @@
#include "endianconv.h" #include "endianconv.h"
#include "stream.h" #include "stream.h"
#define STREAM_BYTES_PER_LISTPACK 2048
/* Every stream item inside the listpack, has a flags field that is used to /* 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" * mark the entry as deleted, or having the same field as the "master"
* entry at the start of the listpack> */ * 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 * C_ERR if an ID was given via 'use_id', but adding it failed since the
* current top ID is greater or equal. */ * current top ID is greater or equal. */
int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_id, streamID *use_id) { int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_id, streamID *use_id) {
/* Generate the new entry ID. */ /* Generate the new entry ID. */
streamID id; streamID id;
if (use_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 /* Check that the new ID is greater than the last entry ID
* or return an error. Automatically generated IDs might * 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. */ part. */
if (streamCompareID(&id,&s->last_id) <= 0) return C_ERR; if (streamCompareID(&id,&s->last_id) <= 0) return C_ERR;