diff --git a/dbutils.c b/dbutils.c index 09b91b2b..bd72c3b0 100644 --- a/dbutils.c +++ b/dbutils.c @@ -1721,7 +1721,7 @@ create_event_record(PGconn *conn, t_configuration_options *options, int node_id, return success; } -bool +void create_checkpoint(PGconn *conn) { char sqlquery[MAXLEN]; @@ -1738,9 +1738,11 @@ create_checkpoint(PGconn *conn) PQfinish(conn); exit(ERR_DB_QUERY); } + log_notice(_("CHECKPOINT created\n")); } + bool update_node_record(PGconn *conn, char *action, int node, char *type, int upstream_node, char *cluster_name, char *node_name, char *conninfo, int priority, char *slot_name, bool active) { diff --git a/dbutils.h b/dbutils.h index b18f8795..bc3cb6bc 100644 --- a/dbutils.h +++ b/dbutils.h @@ -135,7 +135,7 @@ bool update_node_record(PGconn *conn, char *action, int node, char *type, bool update_node_record_status(PGconn *conn, char *cluster_name, int this_node_id, char *type, int upstream_node_id, bool active); bool update_node_record_set_upstream(PGconn *conn, char *cluster_name, int this_node_id, int new_upstream_node_id); bool create_event_record(PGconn *conn, t_configuration_options *options, int node_id, char *event, bool successful, char *details); -bool create_checkpoint(PGconn *conn); +void create_checkpoint(PGconn *conn); int get_node_replication_state(PGconn *conn, char *node_name, char *output); t_server_type parse_node_type(const char *type);