github/repmgr
1
0
Fork 0
mirror of https://github.com/EnterpriseDB/repmgr.git synced 2026-03-26 00:26:30 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

do_failover() -> do_primary_failover()

Browse Source
This commit is contained in:
Ian Barwick
2015-01-16 17:28:51 +09:00
parent b09f987341
commit 5c4e77f8e2
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
repmgrd.c
View File

@@ -43,8 +43,7 @@
#include "access/xlogdefs.h" #include "access/xlogdefs.h"
/* /*
* Struct to keep info about the nodes, used in the voting process in * Struct to store node information
* do_failover()
*/ */
typedef struct s_node_info typedef struct s_node_info
{ {
@@ -95,7 +94,7 @@ static void update_node_record_set_upstream(PGconn *conn, int this_node_id, int
static void update_shared_memory(char *last_wal_standby_applied); static void update_shared_memory(char *last_wal_standby_applied);
static void update_registration(void); static void update_registration(void);
static void do_failover(void); static void do_primary_failover(void);
static t_node_info get_node_info(PGconn *conn,char *cluster, int node_id); static t_node_info get_node_info(PGconn *conn,char *cluster, int node_id);
static XLogRecPtr lsn_to_xlogrecptr(char *lsn, bool *format_ok); static XLogRecPtr lsn_to_xlogrecptr(char *lsn, bool *format_ok);
@@ -718,8 +717,8 @@ standby_monitor(void)
// ZZZ if upstream is not cluster primary (i.e. cascading standby), // ZZZ if upstream is not cluster primary (i.e. cascading standby),
// we need to handle failover differently // we need to handle failover differently
do_failover(); do_primary_failover();
log_debug("standby_monitor() - returning from do_failover()\n"); // ZZZ log_debug("standby_monitor() - returning from do_primary_failover()\n"); // ZZZ
return; return;
} }
} }
@@ -850,10 +849,14 @@ standby_monitor(void)
} }
// ZZZ this handles failovers where node's upstream is cluster primary /*
* do_primary_failover()
*
* Handles failover to new cluster primary
*/
static void static void
do_failover(void) do_primary_failover(void)
{ {
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN]; char sqlquery[QUERY_STR_LEN];