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 function get_timeline_history()

Browse Source 
This will be required for verifying whether one node is able to
follow another node.
This commit is contained in:
Ian Barwick
2018-11-22 14:49:02 +09:00
parent b223cb4cee
commit 80a280cbf4
2 changed files with 69 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
dbutils.c
View File

@@ -1602,6 +1602,71 @@ identify_system(PGconn *repl_conn, t_system_identification *identification)
return true; return true;
} }
TimeLineHistoryEntry *
get_timeline_history(PGconn *repl_conn, TimeLineID tli)
{
PQExpBufferData query;
PGresult *res = NULL;
int nfields;
TimeLineID file_tli;
uint32 switchpoint_hi;
uint32 switchpoint_lo;
TimeLineHistoryEntry *history;
initPQExpBuffer(&query);
appendPQExpBuffer(&query,
"TIMELINE_HISTORY %i",
(int)tli);
res = PQexec(repl_conn, query.data);
log_verbose(LOG_DEBUG, "get_timeline_history():\n%s", query.data);
if (PQresultStatus(res) != PGRES_TUPLES_OK)
{
log_db_error(repl_conn, query.data, _("get_timeline_history(): unable to execute query"));
termPQExpBuffer(&query);
PQclear(res);
return NULL;
}
termPQExpBuffer(&query);
if (PQnfields(res) != 2 || PQntuples(res) != 1)
{
log_error(_("unexpected response to TIMELINE_HISTORY command"));
log_detail(_("got %i rows and %i fields, expected %i rows and %i fields"),
PQntuples(res), PQnfields(res), 1, 2);
PQclear(res);
return NULL;
}
nfields = sscanf(PQgetvalue(res, 0, 1),
"%u\t%X/%X",
&file_tli, &switchpoint_hi, &switchpoint_lo);
if (nfields != 3)
{
log_error(_("unable to parse timeline history file content"));
log_detail(_("content is: \"%s\""), PQgetvalue(res, 0, 1));
PQclear(res);
return NULL;
}
history = (TimeLineHistoryEntry *) palloc(sizeof(TimeLineHistoryEntry));
history->tli = file_tli;
history->begin = InvalidXLogRecPtr; /* we don't care about this */
history->end = ((uint64) (switchpoint_hi)) << 32 | (uint64) switchpoint_lo;
PQclear(res);
return history;
}
/* =============================== */
/* repmgrd shared memory functions */
/* =============================== */
bool bool
repmgrd_set_local_node_id(PGconn *conn, int local_node_id) repmgrd_set_local_node_id(PGconn *conn, int local_node_id)

4
dbutils.h
View File

@@ -20,6 +20,7 @@
#ifndef _REPMGR_DBUTILS_H_ #ifndef _REPMGR_DBUTILS_H_
#define _REPMGR_DBUTILS_H_ #define _REPMGR_DBUTILS_H_
#include "access/timeline.h"
#include "access/xlogdefs.h" #include "access/xlogdefs.h"
#include "pqexpbuffer.h" #include "pqexpbuffer.h"
#include "portability/instr_time.h" #include "portability/instr_time.h"
@@ -424,6 +425,9 @@ RecoveryType get_recovery_type(PGconn *conn);
int get_primary_node_id(PGconn *conn); int get_primary_node_id(PGconn *conn);
int get_ready_archive_files(PGconn *conn, const char *data_directory); int get_ready_archive_files(PGconn *conn, const char *data_directory);
bool identify_system(PGconn *repl_conn, t_system_identification *identification); bool identify_system(PGconn *repl_conn, t_system_identification *identification);
TimeLineHistoryEntry *get_timeline_history(PGconn *repl_conn, TimeLineID tli);
/* repmgrd shared memory functions */
bool repmgrd_set_local_node_id(PGconn *conn, int local_node_id); bool repmgrd_set_local_node_id(PGconn *conn, int local_node_id);
int repmgrd_get_local_node_id(PGconn *conn); int repmgrd_get_local_node_id(PGconn *conn);
BackupState server_in_exclusive_backup_mode(PGconn *conn); BackupState server_in_exclusive_backup_mode(PGconn *conn);