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

Fix function get_primary_node_record()

Browse Source
This commit is contained in:
Ian Barwick
2017-07-05 11:20:32 +09:00
parent 617dee6bd6
commit 614287548d
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
dbutils.c
View File

@@ -1319,6 +1319,8 @@ get_node_record_by_name(PGconn *conn, const char *node_name, t_node_info *node_i
bool bool
get_primary_node_record(PGconn *conn, t_node_info *node_info) get_primary_node_record(PGconn *conn, t_node_info *node_info)
{ {
RecordStatus record_status;
int primary_node_id = get_primary_node_id(conn); int primary_node_id = get_primary_node_id(conn);
if (primary_node_id == UNKNOWN_NODE_ID) if (primary_node_id == UNKNOWN_NODE_ID)
@@ -1326,7 +1328,9 @@ get_primary_node_record(PGconn *conn, t_node_info *node_info)
return false; return false;
} }
return get_node_record(conn, primary_node_id, node_info); record_status = get_node_record(conn, primary_node_id, node_info);
return record_status == RECORD_FOUND ? true : false;
} }
@@ -1646,7 +1650,7 @@ update_node_record_set_upstream(PGconn *conn, int this_node_id, int new_upstream
appendPQExpBuffer(&query, appendPQExpBuffer(&query,
" UPDATE repmgr.nodes " " UPDATE repmgr.nodes "
" SET upstream_node_id = %i " " SET upstream_node_id = %i "
" WHERE id = %i ", " WHERE node_id = %i ",
new_upstream_node_id, new_upstream_node_id,
this_node_id); this_node_id);