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

Handle unhandled error situation in enable_wal_receiver()

Browse Source
This commit is contained in:
Ian Barwick
2019-03-28 14:52:16 +09:00
parent 98d924685b
commit 3d4b81ba2a
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
sysutils.c
View File

@@ -310,18 +310,26 @@ enable_wal_receiver(PGconn *conn, bool wait_startup)
if (wal_retrieve_retry_interval > WALRECEIVER_DISABLE_TIMEOUT_VALUE) if (wal_retrieve_retry_interval > WALRECEIVER_DISABLE_TIMEOUT_VALUE)
{ {
int new_wal_retrieve_retry_interval = wal_retrieve_retry_interval - WALRECEIVER_DISABLE_TIMEOUT_VALUE; int new_wal_retrieve_retry_interval = wal_retrieve_retry_interval - WALRECEIVER_DISABLE_TIMEOUT_VALUE;
bool success;
log_notice(_("setting \"wal_retrieve_retry_interval\" to %i ms"), log_notice(_("setting \"wal_retrieve_retry_interval\" to %i ms"),
new_wal_retrieve_retry_interval); new_wal_retrieve_retry_interval);
// XXX handle error success = alter_system_int(conn,
alter_system_int(conn, "wal_retrieve_retry_interval",
"wal_retrieve_retry_interval", new_wal_retrieve_retry_interval);
new_wal_retrieve_retry_interval);
if (success == false)
{
log_warning(_("unable to change \"wal_retrieve_retry_interval\""));
return UNKNOWN_PID;
}
pg_reload_conf(conn); pg_reload_conf(conn);
} }
else else
{ {
// XXX add threshold sanity check /* TODO: add threshold sanity check */
log_info(_("\"wal_retrieve_retry_interval\" is %i, not changing"), log_info(_("\"wal_retrieve_retry_interval\" is %i, not changing"),
wal_retrieve_retry_interval); wal_retrieve_retry_interval);
} }