github/repmgr
1
0
Fork 0
mirror of https://github.com/EnterpriseDB/repmgr.git synced 2026-03-26 08:36:30 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

master register: add event details if relevant

Browse Source
This commit is contained in:
Ian Barwick
2017-04-26 22:09:49 +09:00
parent cd0509194d
commit 16a47f5693
1 changed files with 30 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
repmgr-client.c
View File

@@ -755,6 +755,8 @@ do_master_register(void)
int record_found; int record_found;
bool record_created; bool record_created;
PQExpBufferData event_description;
log_info(_("connecting to master database...")); log_info(_("connecting to master database..."));
conn = establish_db_connection(config_file_options.conninfo, true); conn = establish_db_connection(config_file_options.conninfo, true);
@@ -857,14 +859,40 @@ do_master_register(void)
// XXX if upstream_node_id set, warn that it will be ignored // XXX if upstream_node_id set, warn that it will be ignored
initPQExpBuffer(&event_description);
if (record_found) if (record_found)
{
record_created = update_node_record(conn, record_created = update_node_record(conn,
"master register", "master register",
&node_info); &node_info);
if (record_created == true)
{
appendPQExpBuffer(&event_description,
"existing master record updated");
}
else
{
appendPQExpBuffer(&event_description,
"error encountered while updating master record:\n%s",
PQerrorMessage(conn));
}
}
else else
{
record_created = create_node_record(conn, record_created = create_node_record(conn,
"master register", "master register",
&node_info); &node_info);
if (record_created == false)
{
appendPQExpBuffer(&event_description,
"error encountered while creating master record:\n%s",
PQerrorMessage(conn));
}
}
/* Log the event */ /* Log the event */
create_event_record(conn, create_event_record(conn,
@@ -872,7 +900,7 @@ do_master_register(void)
config_file_options.node_id, config_file_options.node_id,
"master_register", "master_register",
record_created, record_created,
NULL); event_description.data);
if (record_created == false) if (record_created == false)
{ {
@@ -971,7 +999,7 @@ do_cluster_event(void)
if (PQresultStatus(res) != PGRES_TUPLES_OK) if (PQresultStatus(res) != PGRES_TUPLES_OK)
{ {
log_error(_("unable to execute event query:\n %s"), log_error(_("unable to execute event query:\n %s"),
PQerrorMessage(conn)); PQerrorMessage(conn));
PQclear(res); PQclear(res);
PQfinish(conn); PQfinish(conn);
exit(ERR_DB_QUERY); exit(ERR_DB_QUERY);