upstream/redis
1
0
Fork 0
mirror of https://github.com/redis/redis.git synced 2026-05-28 04:02:46 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Merge 64a77caa11 into 138263a1b4

Browse source
This commit is contained in:
sleshep 2026-05-26 16:09:32 +03:00 committed by GitHub
commit 4caaf751bb
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/cluster_legacy.c
View file

@ -3370,9 +3370,8 @@ void handleLinkIOError(clusterLink *link) {
void clusterWriteHandler(connection *conn) {
clusterLink *link = connGetPrivateData(conn);
ssize_t nwritten;
size_t totwritten = 0;
while (totwritten < NET_MAX_WRITES_PER_EVENT && listLength(link->send_msg_queue) > 0) {
while (listLength(link->send_msg_queue) > 0) {
listNode *head = listFirst(link->send_msg_queue);
clusterMsgSendBlock *msgblock = (clusterMsgSendBlock*)head->value;
clusterMsg *msg = getMessageFromSendBlock(msgblock);
@ -3400,8 +3399,6 @@ void clusterWriteHandler(connection *conn) {
listDelNode(link->send_msg_queue, head);
server.stat_cluster_links_memory -= sizeof(listNode);
link->send_msg_queue_mem -= sizeof(listNode) + blocklen;
totwritten += nwritten;
}
if (listLength(link->send_msg_queue) == 0)