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

repmgrd: minor refactoring of try_primary_reconnect()

Browse Source
This commit is contained in:
Ian Barwick
2020-05-12 14:51:00 +09:00
parent bb56387aaa
commit 8ee4fac5bb
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
repmgrd-physical.c
View File

@@ -5223,11 +5223,8 @@ parse_child_nodes_disconnect_command(char *parsed_command, char *template, int r
int int
try_primary_reconnect(PGconn **conn, PGconn *local_conn, t_node_info *node_info) try_primary_reconnect(PGconn **conn, PGconn *local_conn, t_node_info *node_info)
{ {
PGconn *our_conn;
t_conninfo_param_list conninfo_params = T_CONNINFO_PARAM_LIST_INITIALIZER; t_conninfo_param_list conninfo_params = T_CONNINFO_PARAM_LIST_INITIALIZER;
int i; int i;
int max_attempts = config_file_options.reconnect_attempts; int max_attempts = config_file_options.reconnect_attempts;
initialize_conninfo_params(&conninfo_params, false); initialize_conninfo_params(&conninfo_params, false);
@@ -5248,6 +5245,8 @@ try_primary_reconnect(PGconn **conn, PGconn *local_conn, t_node_info *node_info)
if (is_server_available_params(&conninfo_params) == true) if (is_server_available_params(&conninfo_params) == true)
{ {
PGconn *our_conn;
log_notice(_("node \"%s\" (ID: %i) has recovered, reconnecting"), log_notice(_("node \"%s\" (ID: %i) has recovered, reconnecting"),
node_info->node_name, node_info->node_name,
node_info->node_id); node_info->node_id);
@@ -5322,6 +5321,8 @@ try_primary_reconnect(PGconn **conn, PGconn *local_conn, t_node_info *node_info)
{ {
log_notice(_("received notification that new primary is node %i"), new_primary_node_id); log_notice(_("received notification that new primary is node %i"), new_primary_node_id);
} }
free_conninfo_params(&conninfo_params);
return new_primary_node_id; return new_primary_node_id;
} }
sleep(1); sleep(1);