Skip to content

Commit

Permalink
minor change
Browse files Browse the repository at this point in the history
Signed-off-by: Roshan Khatri <[email protected]>
  • Loading branch information
roshkhatri committed Jul 3, 2024
1 parent 9e42ada commit e634d6a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/cluster_legacy.c
Original file line number Diff line number Diff line change
Expand Up @@ -3598,9 +3598,9 @@ void clusterSendMessage(clusterLink *link, clusterMsgSendBlock *msgblock) {
/* Helper function to send message to node depending on
* the header type supported by the node. */
void clusterSendPublishMessage(clusterNode *node, int type, clusterMsgSendBlock *msgblock) {
if ((type == CLUSTERMSG_TYPE_PUBLISH || type == CLUSTERMSG_TYPE_PUBLISHSHARD) & !nodeSupportsLightMsgHdr(node)) {
if ((type == CLUSTERMSG_TYPE_PUBLISH || type == CLUSTERMSG_TYPE_PUBLISHSHARD) && !nodeSupportsLightMsgHdr(node)) {
clusterSendMessage(node->link, msgblock);
} else if ((type == CLUSTERMSG_TYPE_PUBLISH_LIGHT || type == CLUSTERMSG_TYPE_PUBLISHSHARD_LIGHT) &
} else if ((type == CLUSTERMSG_TYPE_PUBLISH_LIGHT || type == CLUSTERMSG_TYPE_PUBLISHSHARD_LIGHT) &&
nodeSupportsLightMsgHdr(node)) {
clusterSendMessage(node->link, msgblock);
}
Expand Down

0 comments on commit e634d6a

Please sign in to comment.