Commit 1a0cea33 authored by antirez's avatar antirez
Browse files

Cluster: initialize senderConfigEpoch and senderCurrentEpoch for warnings suppression.

parent eb95d288
...@@ -869,7 +869,7 @@ int clusterProcessPacket(clusterLink *link) { ...@@ -869,7 +869,7 @@ int clusterProcessPacket(clusterLink *link) {
uint32_t totlen = ntohl(hdr->totlen); uint32_t totlen = ntohl(hdr->totlen);
uint16_t type = ntohs(hdr->type); uint16_t type = ntohs(hdr->type);
uint16_t flags = ntohs(hdr->flags); uint16_t flags = ntohs(hdr->flags);
uint64_t senderCurrentEpoch, senderConfigEpoch; uint64_t senderCurrentEpoch = 0, senderConfigEpoch = 0;
clusterNode *sender; clusterNode *sender;
server.cluster->stats_bus_messages_received++; server.cluster->stats_bus_messages_received++;
...@@ -1684,7 +1684,7 @@ void clusterHandleSlaveFailover(void) { ...@@ -1684,7 +1684,7 @@ void clusterHandleSlaveFailover(void) {
server.cluster->currentEpoch++; server.cluster->currentEpoch++;
server.cluster->failover_auth_epoch = server.cluster->currentEpoch; server.cluster->failover_auth_epoch = server.cluster->currentEpoch;
redisLog(REDIS_WARNING,"Starting a failover election for epoch %llu.", redisLog(REDIS_WARNING,"Starting a failover election for epoch %llu.",
server.cluster->currentEpoch); (unsigned long long) server.cluster->currentEpoch);
clusterRequestFailoverAuth(); clusterRequestFailoverAuth();
server.cluster->failover_auth_sent = 1; server.cluster->failover_auth_sent = 1;
clusterDoBeforeSleep(CLUSTER_TODO_SAVE_CONFIG| clusterDoBeforeSleep(CLUSTER_TODO_SAVE_CONFIG|
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment