diff --git a/src/cluster_legacy.c b/src/cluster_legacy.c index 0b54d1661d..d9a364d3a8 100644 --- a/src/cluster_legacy.c +++ b/src/cluster_legacy.c @@ -4115,7 +4115,7 @@ void clusterPropagatePublish(robj *channel, robj **messages, int count, int shar if (nodeSupportsLightMsgHdr(node)) { clusterSendMessage(node->link, msgblock_light); } else { - nodes_not_supporting_light_header ++; + nodes_not_supporting_light_header++; continue; } } @@ -4126,7 +4126,7 @@ void clusterPropagatePublish(robj *channel, robj **messages, int count, int shar } else { server.cluster->is_light_hdr_supported = 1; } - + if (!server.cluster->is_light_hdr_supported) { for (i = 0; i < count; i++) { listRewind(nodes_for_slot, &li);