69 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
70 errmsg(
"a backup is already in progress in this session")));
82 "on-line backup context",
126 #define PG_BACKUP_STOP_V2_COLS 3
136 elog(
ERROR,
"return type must be a row type");
140 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
141 errmsg(
"backup is not in progress"),
142 errhint(
"Did you call pg_backup_start()?")));
183 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
184 errmsg(
"recovery is in progress"),
185 errhint(
"WAL control functions cannot be executed during recovery.")));
208 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
209 errmsg(
"recovery is in progress"),
210 errhint(
"%s cannot be executed during recovery.",
211 "pg_log_standby_snapshot()")));
215 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
216 errmsg(
"pg_log_standby_snapshot() can only be used if \"wal_level\" >= \"replica\"")));
236 char *restore_name_str;
241 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
242 errmsg(
"recovery is in progress"),
243 errhint(
"WAL control functions cannot be executed during recovery.")));
247 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
248 errmsg(
"WAL level not sufficient for creating a restore point"),
249 errhint(
"\"wal_level\" must be set to \"replica\" or \"logical\" at server start.")));
255 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
256 errmsg(
"value too long for restore point (maximum %d characters)",
MAXFNAMELEN - 1)));
280 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
281 errmsg(
"recovery is in progress"),
282 errhint(
"WAL control functions cannot be executed during recovery.")));
301 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
302 errmsg(
"recovery is in progress"),
303 errhint(
"WAL control functions cannot be executed during recovery.")));
322 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
323 errmsg(
"recovery is in progress"),
324 errhint(
"WAL control functions cannot be executed during recovery.")));
388 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
389 errmsg(
"recovery is in progress"),
390 errhint(
"%s cannot be executed during recovery.",
391 "pg_walfile_name_offset()")));
446 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
447 errmsg(
"recovery is in progress"),
448 errhint(
"%s cannot be executed during recovery.",
449 "pg_walfile_name()")));
465 #define PG_SPLIT_WALFILE_NAME_COLS 2
481 for (p = fname_upper; *p; p++)
486 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
487 errmsg(
"invalid WAL file name \"%s\"", fname)));
492 elog(
ERROR,
"return type must be a row type");
508 #undef PG_SPLIT_WALFILE_NAME_COLS
522 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
523 errmsg(
"recovery is not in progress"),
524 errhint(
"Recovery control functions can only be executed during recovery.")));
528 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
529 errmsg(
"standby promotion is ongoing"),
530 errhint(
"%s cannot be executed after promotion is triggered.",
531 "pg_wal_replay_pause()")));
552 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
553 errmsg(
"recovery is not in progress"),
554 errhint(
"Recovery control functions can only be executed during recovery.")));
558 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
559 errmsg(
"standby promotion is ongoing"),
560 errhint(
"%s cannot be executed after promotion is triggered.",
561 "pg_wal_replay_resume()")));
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.")));
595 char *statestr = NULL;
599 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
600 errmsg(
"recovery is not in progress"),
601 errhint(
"Recovery control functions can only be executed during recovery.")));
607 statestr =
"not paused";
610 statestr =
"pause requested";
679 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
680 errmsg(
"recovery is not in progress"),
681 errhint(
"Recovery control functions can only be executed during recovery.")));
685 (
errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
686 errmsg(
"\"wait_seconds\" must not be negative or zero")));
693 errmsg(
"could not create file \"%s\": %m",
699 errmsg(
"could not write file \"%s\": %m",
707 (
errcode(ERRCODE_SYSTEM_ERROR),
708 errmsg(
"failed to send signal to postmaster: %m")));
716 #define WAITS_PER_SECOND 10
739 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
740 errmsg(
"terminating connection due to unexpected postmaster exit"),
746 "server did not promote within %d seconds",
Datum numeric_in(PG_FUNCTION_ARGS)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define Assert(condition)
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, const Datum *values, const bool *isnull)
void ResetLatch(Latch *latch)
int WaitLatch(Latch *latch, int wakeEvents, long timeout, uint32 wait_event_info)
#define WL_POSTMASTER_DEATH
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 char promote_file[MAXPGPATH]
Datum pg_lsn_mi(PG_FUNCTION_ARGS)
static Datum LSNGetDatum(XLogRecPtr X)
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)
MemoryContextSwitchTo(old_ctx)
XLogRecPtr LogStandbySnapshot(void)
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 XLogStandbyInfoActive()
#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 XLByteToSeg(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)
Datum pg_log_standby_snapshot(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