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

repmgr: clean up standby follow code

Browse Source
This commit is contained in:
Ian Barwick
2017-03-13 13:26:24 +09:00
parent 65213449a6
commit ea6fff7827
1 changed files with 17 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
repmgr.c
View File

@@ -4778,18 +4778,27 @@ do_standby_follow(void)
PQfinish(conn); PQfinish(conn);
conn = establish_db_connection_quiet(upstream_node_record.conninfo_str);
if (PQstatus(conn) != CONNECTION_OK) if (upstream_query_result != 1)
{ {
log_info("unable to connect to old upstream node %i to remove replication slot\n", log_warning(_("unable to retrieve node record for old upstream node %i"),
original_upstream_node_id); original_upstream_node_id);
log_hint("if reusing this node, you should manually remove any inactive replication slots\n");
} }
else else
{ {
drop_replication_slot_if_exists(conn, conn = establish_db_connection_quiet(upstream_node_record.conninfo_str);
original_upstream_node_id, if (PQstatus(conn) != CONNECTION_OK)
local_node_record.slot_name); {
log_info(_("unable to connect to old upstream node %i to remove replication slot\n"),
original_upstream_node_id);
log_hint(_("if reusing this node, you should manually remove any inactive replication slots\n"));
}
else
{
drop_replication_slot_if_exists(conn,
original_upstream_node_id,
local_node_record.slot_name);
}
} }
} }