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

"standby follow": check for replication slot availability on target node

Browse Source
This commit is contained in:
Ian Barwick
2018-02-02 15:01:23 +09:00
parent 65bf203a89
commit 6c81e54f76
3 changed files with 69 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
repmgr-action-standby.c
View File

@@ -1679,6 +1679,33 @@ do_standby_follow(void)
primary_id);
}
/* if replication slots in use, check at least one free slot is available */
if (config_file_options.use_replication_slots)
{
int free_slots = get_free_replication_slots(primary_conn);
if (free_slots < 0)
{
log_error(_("unable to determine number of free replication slots on the primary"));
PQfinish(primary_conn);
exit(ERR_BAD_CONFIG);
}
if (free_slots == 0)
{
log_error(_("no free replication slots available on the primary"));
log_hint(_("consider increasing \"max_replication_slots\""));
PQfinish(primary_conn);
exit(ERR_BAD_CONFIG);
}
else if (runtime_options.dry_run == true)
{
log_info(_("replication slots in use, %i free slots on the primary"),
free_slots);
}
}
/* XXX check this is not current upstream anyway */
/* check replication connection */
initialize_conninfo_params(&repl_conninfo, false);
@@ -1700,6 +1727,7 @@ do_standby_follow(void)
log_info(_("replication connection to primary node was successful"));
}
/* check system_identifiers match */
local_system_identifier = get_system_identifier(config_file_options.data_directory);
success = identify_system(repl_conn, &primary_identification);
@@ -1728,7 +1756,7 @@ do_standby_follow(void)
log_detail(_("system identifier is %lu"), local_system_identifier);
}
/* TODO: check timelines*/
/* TODO: check timelines */
PQfinish(repl_conn);
free_conninfo_params(&repl_conninfo);