diff options
| author | Brennan <31714723+BCathcart@users.noreply.github.com> | 2022-11-01 22:26:44 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-01 19:26:44 -0700 |
| commit | 47c493e070c8ac59ccc34d694700bca8ec517fbc (patch) | |
| tree | 3badf9ecdb5b62ceece2e317a90cf2d472559aa5 /src/cluster.h | |
| parent | 4a8a62505134094f8de0ca293da932c3d009df15 (diff) | |
| download | redis-47c493e070c8ac59ccc34d694700bca8ec517fbc.tar.gz | |
Re-design cluster link send buffer to improve memory management (#11343)
Re-design cluster link send queue to improve memory management
Diffstat (limited to 'src/cluster.h')
| -rw-r--r-- | src/cluster.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/cluster.h b/src/cluster.h index 75516716f..f27072f20 100644 --- a/src/cluster.h +++ b/src/cluster.h @@ -35,7 +35,9 @@ struct clusterNode; typedef struct clusterLink { mstime_t ctime; /* Link creation time */ connection *conn; /* Connection to remote node */ - sds sndbuf; /* Packet send buffer */ + list *send_msg_queue; /* List of messages to be sent */ + size_t head_msg_send_offset; /* Number of bytes already sent of message at head of queue */ + unsigned long long send_msg_queue_mem; /* Memory in bytes used by message queue */ char *rcvbuf; /* Packet reception buffer */ size_t rcvbuf_len; /* Used size of rcvbuf */ size_t rcvbuf_alloc; /* Allocated size of rcvbuf */ |