Commit abf06fd5 authored by antirez's avatar antirez
Browse files

Cluster: log global cluster state change.

parent 3dad8196
...@@ -1450,7 +1450,7 @@ int clusterDelSlot(int slot) { ...@@ -1450,7 +1450,7 @@ int clusterDelSlot(int slot) {
* Cluster state evaluation function * Cluster state evaluation function
* -------------------------------------------------------------------------- */ * -------------------------------------------------------------------------- */
void clusterUpdateState(void) { void clusterUpdateState(void) {
int j; int j, initial_state = server.cluster->state;
/* Start assuming the state is OK. We'll turn it into FAIL if there /* Start assuming the state is OK. We'll turn it into FAIL if there
* are the right conditions. */ * are the right conditions. */
...@@ -1482,6 +1482,11 @@ void clusterUpdateState(void) { ...@@ -1482,6 +1482,11 @@ void clusterUpdateState(void) {
} }
dictReleaseIterator(di); dictReleaseIterator(di);
} }
/* Log a state change */
if (initial_state != server.cluster->state)
redisLog(REDIS_WARNING,"Cluster state changed: %s",
server.cluster->state == REDIS_CLUSTER_OK ? "ok" : "fail");
} }
/* This function is called after the node startup in order to verify that data /* This function is called after the node startup in order to verify that data
......
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