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

Add error code ERR_FOLLOW_FAIL

Browse Source
This commit is contained in:
Ian Barwick
2018-03-21 13:11:30 +09:00
parent 81c69e3677
commit 93deab3e96
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
errcode.h
View File

@@ -44,5 +44,6 @@
#define ERR_REGISTRATION_SYNC 20 #define ERR_REGISTRATION_SYNC 20
#define ERR_OUT_OF_MEMORY 21 #define ERR_OUT_OF_MEMORY 21
#define ERR_SWITCHOVER_INCOMPLETE 22 #define ERR_SWITCHOVER_INCOMPLETE 22
#define ERR_FOLLOW_FAIL 23
#endif /* _ERRCODE_H_ */ #endif /* _ERRCODE_H_ */

19
repmgr-action-standby.c
View File

@@ -2081,7 +2081,7 @@ do_standby_follow(void)
log_hint(_("alter \"primary_follow_timeout\" in \"repmgr.conf\" to change this value")); log_hint(_("alter \"primary_follow_timeout\" in \"repmgr.conf\" to change this value"));
} }
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
if (runtime_options.dry_run == true) if (runtime_options.dry_run == true)
@@ -2100,7 +2100,7 @@ do_standby_follow(void)
log_error(_("unable to find record for new upstream node %i"), log_error(_("unable to find record for new upstream node %i"),
runtime_options.upstream_node_id); runtime_options.upstream_node_id);
PQfinish(primary_conn); PQfinish(primary_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
if (runtime_options.dry_run == true) if (runtime_options.dry_run == true)
@@ -2125,7 +2125,7 @@ do_standby_follow(void)
{ {
log_error(_("unable to determine number of free replication slots on the primary")); log_error(_("unable to determine number of free replication slots on the primary"));
PQfinish(primary_conn); PQfinish(primary_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
if (free_slots == 0) if (free_slots == 0)
@@ -2133,7 +2133,7 @@ do_standby_follow(void)
log_error(_("no free replication slots available on the primary")); log_error(_("no free replication slots available on the primary"));
log_hint(_("consider increasing \"max_replication_slots\"")); log_hint(_("consider increasing \"max_replication_slots\""));
PQfinish(primary_conn); PQfinish(primary_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
else if (runtime_options.dry_run == true) else if (runtime_options.dry_run == true)
{ {
@@ -2157,7 +2157,7 @@ do_standby_follow(void)
{ {
log_error(_("unable to establish a replication connection to the primary node")); log_error(_("unable to establish a replication connection to the primary node"));
PQfinish(primary_conn); PQfinish(primary_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
else if (runtime_options.dry_run == true) else if (runtime_options.dry_run == true)
{ {
@@ -2174,7 +2174,7 @@ do_standby_follow(void)
log_error(_("unable to query the primary node's system identification")); log_error(_("unable to query the primary node's system identification"));
PQfinish(primary_conn); PQfinish(primary_conn);
PQfinish(repl_conn); PQfinish(repl_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
if (primary_identification.system_identifier != local_system_identifier) if (primary_identification.system_identifier != local_system_identifier)
@@ -2185,7 +2185,7 @@ do_standby_follow(void)
primary_identification.system_identifier); primary_identification.system_identifier);
PQfinish(primary_conn); PQfinish(primary_conn);
PQfinish(repl_conn); PQfinish(repl_conn);
exit(ERR_BAD_CONFIG); exit(ERR_FOLLOW_FAIL);
} }
else if (runtime_options.dry_run == true) else if (runtime_options.dry_run == true)
{ {
@@ -2271,7 +2271,7 @@ do_standby_follow_internal(PGconn *primary_conn, t_node_info *primary_node_recor
log_error(_("unable to retrieve record for node %i"), log_error(_("unable to retrieve record for node %i"),
config_file_options.node_id); config_file_options.node_id);
*error_code = ERR_BAD_CONFIG; *error_code = ERR_FOLLOW_FAIL;
return false; return false;
} }
@@ -2401,8 +2401,7 @@ do_standby_follow_internal(PGconn *primary_conn, t_node_info *primary_node_recor
if (!create_recovery_file(&local_node_record, &recovery_conninfo, config_file_options.data_directory, true)) if (!create_recovery_file(&local_node_record, &recovery_conninfo, config_file_options.data_directory, true))
{ {
/* XXX ERR_RECOVERY_FILE ??? */ *error_code = ERR_FOLLOW_FAIL;
*error_code = ERR_BAD_CONFIG;
return false; return false;
} }