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

get_master_connection(): possible to use is_standby() now

Browse Source
This commit is contained in:
Ian Barwick
2015-11-16 17:49:02 +09:00
parent dd7f9b79ae
commit 3ab91730c3
1 changed files with 10 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
dbutils.c
View File

@@ -588,7 +588,6 @@ get_master_connection(PGconn *standby_conn, char *cluster,
{ {
PGconn *master_conn = NULL; PGconn *master_conn = NULL;
PGresult *res1; PGresult *res1;
PGresult *res2;
char sqlquery[QUERY_STR_LEN]; char sqlquery[QUERY_STR_LEN];
char master_conninfo_stack[MAXCONNINFO]; char master_conninfo_stack[MAXCONNINFO];
char *master_conninfo = &*master_conninfo_stack; char *master_conninfo = &*master_conninfo_stack;
@@ -626,6 +625,8 @@ get_master_connection(PGconn *standby_conn, char *cluster,
for (i = 0; i < PQntuples(res1); i++) for (i = 0; i < PQntuples(res1); i++)
{ {
int is_node_standby;
/* initialize with the values of the current node being processed */ /* initialize with the values of the current node being processed */
node_id = atoi(PQgetvalue(res1, i, 0)); node_id = atoi(PQgetvalue(res1, i, 0));
strncpy(master_conninfo, PQgetvalue(res1, i, 1), MAXCONNINFO); strncpy(master_conninfo, PQgetvalue(res1, i, 1), MAXCONNINFO);
@@ -637,26 +638,19 @@ get_master_connection(PGconn *standby_conn, char *cluster,
if (PQstatus(master_conn) != CONNECTION_OK) if (PQstatus(master_conn) != CONNECTION_OK)
continue; continue;
/* is_node_standby = is_standby(master_conn);
* Can't use the is_standby() function here because on error that
* function closes the connection passed and exits. This still needs
* to close master_conn first.
*/
res2 = PQexec(master_conn, "SELECT pg_catalog.pg_is_in_recovery()");
if (PQresultStatus(res2) != PGRES_TUPLES_OK) if (is_node_standby == -1)
{ {
log_err(_("unable to retrieve recovery state from this node: %s\n"), log_err(_("unable to retrieve recovery state from this node: %s\n"),
PQerrorMessage(master_conn)); PQerrorMessage(master_conn));
PQclear(res2);
PQfinish(master_conn); PQfinish(master_conn);
continue; continue;
} }
/* if false, this is the master */ /* if is_standby() returns 0, queried node is the master */
if (strcmp(PQgetvalue(res2, 0, 0), "f") == 0) if (is_node_standby == 0)
{ {
PQclear(res2);
PQclear(res1); PQclear(res1);
log_debug(_("get_master_connection(): current master node is %i\n"), node_id); log_debug(_("get_master_connection(): current master node is %i\n"), node_id);
@@ -667,12 +661,10 @@ get_master_connection(PGconn *standby_conn, char *cluster,
return master_conn; return master_conn;
} }
else
{
/* if it is a standby, clear info */ /* if it is a standby, clear connection info and continue*/
PQclear(res2); PQfinish(master_conn);
PQfinish(master_conn);
}
} }
/* /*