73 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
74 errmsg(
"a backup is already in progress in this session")));
86 "on-line backup context",
130 #define PG_BACKUP_STOP_V2_COLS 3
140 elog(
ERROR,
"return type must be a row type");
144 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
145 errmsg(
"backup is not in progress"),
146 errhint(
"Did you call pg_backup_start()?")));
187 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
188 errmsg(
"recovery is in progress"),
189 errhint(
"WAL control functions cannot be executed during recovery.")));
209 char *restore_name_str;
214 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
215 errmsg(
"recovery is in progress"),
216 errhint(
"WAL control functions cannot be executed during recovery.")));
220 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
221 errmsg(
"WAL level not sufficient for creating a restore point"),
222 errhint(
"wal_level must be set to \"replica\" or \"logical\" at server start.")));
228 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
229 errmsg(
"value too long for restore point (maximum %d characters)",
MAXFNAMELEN - 1)));
253 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
254 errmsg(
"recovery is in progress"),
255 errhint(
"WAL control functions cannot be executed during recovery.")));
274 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
275 errmsg(
"recovery is in progress"),
276 errhint(
"WAL control functions cannot be executed during recovery.")));
295 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
296 errmsg(
"recovery is in progress"),
297 errhint(
"WAL control functions cannot be executed during recovery.")));
365 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
366 errmsg(
"recovery is in progress"),
367 errhint(
"%s cannot be executed during recovery.",
368 "pg_walfile_name_offset()")));
423 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
424 errmsg(
"recovery is in progress"),
425 errhint(
"%s cannot be executed during recovery.",
426 "pg_walfile_name()")));
442 #define PG_SPLIT_WALFILE_NAME_COLS 2
458 for (p = fname_upper; *p; p++)
463 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
464 errmsg(
"invalid WAL file name \"%s\"", fname)));
469 elog(
ERROR,
"return type must be a row type");
485 #undef PG_SPLIT_WALFILE_NAME_COLS
499 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
500 errmsg(
"recovery is not in progress"),
501 errhint(
"Recovery control functions can only be executed during recovery.")));
505 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
506 errmsg(
"standby promotion is ongoing"),
507 errhint(
"%s cannot be executed after promotion is triggered.",
508 "pg_wal_replay_pause()")));
529 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
530 errmsg(
"recovery is not in progress"),
531 errhint(
"Recovery control functions can only be executed during recovery.")));
535 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
536 errmsg(
"standby promotion is ongoing"),
537 errhint(
"%s cannot be executed after promotion is triggered.",
538 "pg_wal_replay_resume()")));
553 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
554 errmsg(
"recovery is not in progress"),
555 errhint(
"Recovery control functions can only be executed during recovery.")));
572 char *statestr = NULL;
576 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
577 errmsg(
"recovery is not in progress"),
578 errhint(
"Recovery control functions can only be executed during recovery.")));
584 statestr =
"not paused";
587 statestr =
"pause requested";
656 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
657 errmsg(
"recovery is not in progress"),
658 errhint(
"Recovery control functions can only be executed during recovery.")));
662 (
errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
663 errmsg(
"\"wait_seconds\" must not be negative or zero")));
670 errmsg(
"could not create file \"%s\": %m",
676 errmsg(
"could not write file \"%s\": %m",
683 (
errmsg(
"failed to send signal to postmaster: %m")));
693 #define WAITS_PER_SECOND 10
720 "server did not promote within %d seconds",
Datum numeric_in(PG_FUNCTION_ARGS)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
elog(ERROR, "%s: %s", p2, msg)
int errmsg_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errcode_for_file_access(void)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
TupleDesc BlessTupleDesc(TupleDesc tupdesc)
FILE * AllocateFile(const char *name, const char *mode)
Datum Int64GetDatum(int64 X)
#define PG_GETARG_TEXT_PP(n)
#define DirectFunctionCall2(func, arg1, arg2)
#define PG_GETARG_DATUM(n)
#define PG_RETURN_TEXT_P(x)
#define PG_GETARG_INT32(n)
#define PG_GETARG_BOOL(n)
#define PG_RETURN_DATUM(x)
#define DirectFunctionCall3(func, arg1, arg2, arg3)
#define PG_RETURN_BOOL(x)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, Datum *values, bool *isnull)
void ResetLatch(Latch *latch)
int WaitLatch(Latch *latch, int wakeEvents, long timeout, uint32 wait_event_info)
#define WL_POSTMASTER_DEATH
Assert(fmt[strlen(fmt) - 1] !='\n')
void MemoryContextReset(MemoryContext context)
char * pstrdup(const char *in)
void pfree(void *pointer)
MemoryContext TopMemoryContext
void * palloc0(Size size)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_START_SMALL_SIZES
#define CHECK_FOR_INTERRUPTS()
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
static char promote_file[MAXPGPATH]
Datum pg_lsn_mi(PG_FUNCTION_ARGS)
static Datum LSNGetDatum(XLogRecPtr X)
static void static void status(const char *fmt,...) pg_attribute_printf(1
unsigned char pg_toupper(unsigned char ch)
static Datum ObjectIdGetDatum(Oid X)
static Datum CStringGetDatum(const char *X)
static Datum Int32GetDatum(int32 X)
static Datum UInt32GetDatum(uint32 X)
StringInfo makeStringInfo(void)
TupleDesc CreateTemplateTupleDesc(int natts)
void TupleDescInitEntry(TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim)
#define PG_RETURN_TIMESTAMPTZ(x)
char * text_to_cstring(const text *t)
text * cstring_to_text(const char *s)
XLogRecPtr GetWalRcvFlushRecPtr(XLogRecPtr *latestChunkStart, TimeLineID *receiveTLI)
bool RecoveryInProgress(void)
TimeLineID GetWALInsertionTimeLine(void)
XLogRecPtr RequestXLogSwitch(bool mark_unimportant)
SessionBackupState get_backup_status(void)
XLogRecPtr GetXLogInsertRecPtr(void)
XLogRecPtr GetFlushRecPtr(TimeLineID *insertTLI)
void register_persistent_abort_backup_handler(void)
XLogRecPtr GetXLogWriteRecPtr(void)
void do_pg_backup_start(const char *backupidstr, bool fast, List **tablespaces, BackupState *state, StringInfo tblspcmapfile)
XLogRecPtr XLogRestorePoint(const char *rpName)
void do_pg_backup_stop(BackupState *state, bool waitforarchive)
#define PROMOTE_SIGNAL_FILE
#define XLogSegmentOffset(xlogptr, wal_segsz_bytes)
static bool IsXLogFileName(const char *fname)
static void XLogFromFileName(const char *fname, TimeLineID *tli, XLogSegNo *logSegNo, int wal_segsz_bytes)
#define XLByteToPrevSeg(xlrp, logSegNo, wal_segsz_bytes)
static void XLogFileName(char *fname, TimeLineID tli, XLogSegNo logSegNo, int wal_segsz_bytes)
char * build_backup_content(BackupState *state, bool ishistoryfile)
Datum pg_is_wal_replay_paused(PG_FUNCTION_ARGS)
Datum pg_wal_lsn_diff(PG_FUNCTION_ARGS)
Datum pg_backup_start(PG_FUNCTION_ARGS)
Datum pg_create_restore_point(PG_FUNCTION_ARGS)
Datum pg_current_wal_insert_lsn(PG_FUNCTION_ARGS)
Datum pg_switch_wal(PG_FUNCTION_ARGS)
Datum pg_is_in_recovery(PG_FUNCTION_ARGS)
#define PG_SPLIT_WALFILE_NAME_COLS
Datum pg_split_walfile_name(PG_FUNCTION_ARGS)
Datum pg_backup_stop(PG_FUNCTION_ARGS)
Datum pg_last_xact_replay_timestamp(PG_FUNCTION_ARGS)
static BackupState * backup_state
Datum pg_current_wal_lsn(PG_FUNCTION_ARGS)
Datum pg_last_wal_receive_lsn(PG_FUNCTION_ARGS)
#define PG_BACKUP_STOP_V2_COLS
Datum pg_walfile_name(PG_FUNCTION_ARGS)
Datum pg_current_wal_flush_lsn(PG_FUNCTION_ARGS)
Datum pg_walfile_name_offset(PG_FUNCTION_ARGS)
static MemoryContext backupcontext
static StringInfo tablespace_map
Datum pg_promote(PG_FUNCTION_ARGS)
Datum pg_get_wal_replay_pause_state(PG_FUNCTION_ARGS)
Datum pg_last_wal_replay_lsn(PG_FUNCTION_ARGS)
Datum pg_wal_replay_pause(PG_FUNCTION_ARGS)
Datum pg_wal_replay_resume(PG_FUNCTION_ARGS)
void SetRecoveryPause(bool recoveryPause)
void WakeupRecovery(void)
bool PromoteIsTriggered(void)
XLogRecPtr GetXLogReplayRecPtr(TimeLineID *replayTLI)
RecoveryPauseState GetRecoveryPauseState(void)
TimestampTz GetLatestXTime(void)
@ RECOVERY_PAUSE_REQUESTED