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

No need for log_event() function

Browse Source
This commit is contained in:
Ian Barwick
2015-03-19 22:49:50 +09:00
parent ebabc68f8a
commit 46a3082055
1 changed files with 6 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
repmgr.c
View File

@@ -79,7 +79,6 @@ static int check_server_version(PGconn *conn, char *server_type, bool exit_on_er
static bool check_upstream_config(PGconn *conn, int server_version_num, bool exit_on_error); static bool check_upstream_config(PGconn *conn, int server_version_num, bool exit_on_error);
static char *make_pg_path(char *file); static char *make_pg_path(char *file);
static bool log_event(PGconn *standby_conn, bool success, char *details);
static void do_master_register(void); static void do_master_register(void);
static void do_standby_register(void); static void do_standby_register(void);
@@ -949,7 +948,6 @@ do_standby_clone(void)
char *first_wal_segment = NULL; char *first_wal_segment = NULL;
char *last_wal_segment = NULL; char *last_wal_segment = NULL;
bool record_created = FALSE;
PQExpBufferData event_details; PQExpBufferData event_details;
/* /*
@@ -1514,43 +1512,18 @@ stop_backup:
_("; --force: %s"), _("; --force: %s"),
runtime_options.force ? "Y" : "N"); runtime_options.force ? "Y" : "N");
record_created = log_event(upstream_conn, create_event_record(upstream_conn,
true, &options,
event_details.data); options.node,
"standby_clone",
if(record_created == false) true,
{ event_details.data);
PQfinish(upstream_conn);
exit(ERR_DB_QUERY);
}
PQfinish(upstream_conn); PQfinish(upstream_conn);
exit(retval); exit(retval);
} }
static bool
log_event(PGconn *standby_conn, bool success, char *details)
{
PGconn *primary_conn;
bool retval;
primary_conn = get_primary_connection(standby_conn,
options.cluster_name,
NULL, NULL);
retval = create_event_record(primary_conn,
&options,
options.node,
"standby_clone",
success,
details);
PQfinish(primary_conn);
return retval;
}
static void static void
do_standby_promote(void) do_standby_promote(void)
{ {