diff --git a/src/cluster.c b/src/cluster.c index ac44d5651..f037e6dc4 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -781,14 +781,12 @@ int clusterProcessPacket(clusterLink *link) { explen = sizeof(clusterMsg)-sizeof(union clusterMsgData); explen += (sizeof(clusterMsgDataGossip)*count); if (totlen != explen) return 1; - } - if (type == CLUSTERMSG_TYPE_FAIL) { + } else if (type == CLUSTERMSG_TYPE_FAIL) { uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData); explen += sizeof(clusterMsgDataFail); if (totlen != explen) return 1; - } - if (type == CLUSTERMSG_TYPE_PUBLISH) { + } else if (type == CLUSTERMSG_TYPE_PUBLISH) { uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData); explen += sizeof(clusterMsgDataPublish) +