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

Attempt to delete replication slot on old primary after switchover

Browse Source
This commit is contained in:
Ian Barwick
2017-08-04 09:29:35 +09:00
committed by Ian Barwick
parent c34f5c1ed1
commit 2c682b31c2
1 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
repmgr-action-standby.c
View File

@@ -2056,6 +2056,25 @@ do_standby_switchover(void)
PQfinish(local_conn); PQfinish(local_conn);
/* clean up remote node */
remote_conn = establish_db_connection(config_file_options.conninfo, false);
// check replication status
if (PQstatus(remote_conn) != CONNECTION_OK)
{
log_error(_("unable to reestablish connection to remote node \"%s\""),
remote_node_record.node_name);
//log_hint(_("")); // depends on replication status
}
else
{
drop_replication_slot_if_exists(remote_conn,
remote_node_record.node_id,
local_node_record.slot_name);
/* TODO warn about any inactive replication slots*/
}
log_notice(_("switchover was successful")); log_notice(_("switchover was successful"));
log_detail(_("node \"%s\" is now primary"), log_detail(_("node \"%s\" is now primary"),
local_node_record.node_name); local_node_record.node_name);
@@ -3398,8 +3417,10 @@ drop_replication_slot_if_exists(PGconn *conn, int node_id, char *slot_name)
t_replication_slot slot_info; t_replication_slot slot_info;
int record_status; int record_status;
record_status = get_slot_record(conn,slot_name, &slot_info); record_status = get_slot_record(conn, slot_name, &slot_info);
log_verbose(LOG_DEBUG, "attempting to delete slot \"%s\" on node %i",
slot_name, node_id);
if (record_status == RECORD_FOUND) if (record_status == RECORD_FOUND)
{ {
if (slot_info.active == false) if (slot_info.active == false)