fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 09:00:51 +00:00
Code Issues Projects Releases Wiki Activity

Cluster: call clusterHandleSlaveFailover() when our master is down.

Browse Source
This commit is contained in:
antirez 2013-03-13 12:44:02 +01:00
parent ae94fe7e48
commit 3d448bda39
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/cluster.c
View File

@ -1242,6 +1242,22 @@ void clusterPropagatePublish(robj *channel, robj *message) {
clusterSendPublish(NULL, channel, message); clusterSendPublish(NULL, channel, message);
} }
/* -----------------------------------------------------------------------------
* SLAVE node specific functions
* -------------------------------------------------------------------------- */
/* This function is called if we are a slave node and our master serving
* a non-zero amount of hash slots is in PFAIL state.
*
* The gaol of this function is:
* 1) To check if we are able to perform a failover, is our data updated?
* 2) Ask reachable masters the authorization to perform the failover.
* 3) Check if there is the majority of masters agreeing we should failover.
* 4) Perform the failover informing all the other nodes.
*/
void clusterHandleSlaveFailover(void) {
}
/* ----------------------------------------------------------------------------- /* -----------------------------------------------------------------------------
* CLUSTER cron job * CLUSTER cron job
* -------------------------------------------------------------------------- */ * -------------------------------------------------------------------------- */
@ -1377,6 +1393,16 @@ void clusterCron(void) {
server.cluster->myself->slaveof->port); server.cluster->myself->slaveof->port);
} }
/* If we are a slave and our master is down, but is serving slots,
* call the function that handles the failover. */
if (server.cluster->myself->flags & REDIS_NODE_SLAVE &&
server.cluster->myself->slaveof &&
server.cluster->myself->slaveof->flags & REDIS_NODE_FAIL &&
server.cluster->myself->slaveof->numslots != 0)
{
clusterHandleSlaveFailover();
}
if (update_state) clusterUpdateState(); if (update_state) clusterUpdateState();
} }