diff --git a/src/cluster.c b/src/cluster.c index 05c17f873..149b9286f 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -1156,6 +1156,7 @@ void clusterBuildMessageHdr(clusterMsg *hdr, int type) { REDIS_CLUSTER_NAMELEN); } hdr->port = htons(server.port); + hdr->flags = htons(server.cluster->myself->flags); hdr->state = server.cluster->state; memset(hdr->configdigest,0,32); /* FIXME: set config digest */ diff --git a/src/redis.h b/src/redis.h index 0eb746759..4408925c2 100644 --- a/src/redis.h +++ b/src/redis.h @@ -648,8 +648,9 @@ typedef struct { char slaveof[REDIS_CLUSTER_NAMELEN]; char configdigest[32]; uint16_t port; /* Sender TCP base port */ + uint16_t flags; /* Sender node flags */ unsigned char state; /* Cluster state from the POV of the sender */ - unsigned char notused[5]; /* Reserved for future use. For alignment. */ + unsigned char notused[3]; /* Reserved for future use. For alignment. */ union clusterMsgData data; } clusterMsg;