25 #define SYNC_METHOD_FSYNC 0 26 #define SYNC_METHOD_FDATASYNC 1 27 #define SYNC_METHOD_OPEN 2 28 #define SYNC_METHOD_FSYNC_WRITETHROUGH 3 29 #define SYNC_METHOD_OPEN_DSYNC 4 74 #define InHotStandby (standbyState >= STANDBY_SNAPSHOT_PENDING) 180 #define XLogArchivingActive() \ 181 (AssertMacro(XLogArchiveMode == ARCHIVE_MODE_OFF || wal_level >= WAL_LEVEL_REPLICA), XLogArchiveMode > ARCHIVE_MODE_OFF) 183 #define XLogArchivingAlways() \ 184 (AssertMacro(XLogArchiveMode == ARCHIVE_MODE_OFF || wal_level >= WAL_LEVEL_REPLICA), XLogArchiveMode == ARCHIVE_MODE_ALWAYS) 185 #define XLogArchiveCommandSet() (XLogArchiveCommand[0] != '\0') 191 #define XLogIsNeeded() (wal_level >= WAL_LEVEL_REPLICA) 202 #define XLogHintBitIsNeeded() (DataChecksumsEnabled() || wal_log_hints) 205 #define XLogStandbyInfoActive() (wal_level >= WAL_LEVEL_REPLICA) 208 #define XLogLogicalInfoActive() (wal_level >= WAL_LEVEL_LOGICAL) 211 extern bool XLOG_DEBUG;
221 #define CHECKPOINT_IS_SHUTDOWN 0x0001 222 #define CHECKPOINT_END_OF_RECOVERY 0x0002 224 #define CHECKPOINT_IMMEDIATE 0x0004 225 #define CHECKPOINT_FORCE 0x0008 226 #define CHECKPOINT_FLUSH_ALL 0x0010 229 #define CHECKPOINT_WAIT 0x0020 230 #define CHECKPOINT_REQUESTED 0x0040 232 #define CHECKPOINT_CAUSE_XLOG 0x0080 233 #define CHECKPOINT_CAUSE_TIME 0x0100 238 #define XLOG_INCLUDE_ORIGIN 0x01 239 #define XLOG_MARK_UNIMPORTANT 0x02 240 #define XLOG_INCLUDE_XID 0x04 379 bool needtblspcmapfile);
387 #define RECOVERY_SIGNAL_FILE "recovery.signal" 388 #define STANDBY_SIGNAL_FILE "standby.signal" 389 #define BACKUP_LABEL_FILE "backup_label" 390 #define BACKUP_LABEL_OLD "backup_label.old" 392 #define TABLESPACE_MAP "tablespace_map" 393 #define TABLESPACE_MAP_OLD "tablespace_map.old" 396 #define PROMOTE_SIGNAL_FILE "promote"
void CreateCheckPoint(int flags)
struct CheckpointStatsData CheckpointStatsData
XLogRecPtr GetXLogWriteRecPtr(void)
uint64 ckpt_agg_sync_time
TimeLineID recoveryTargetTLI
const char * recoveryTargetName
TimestampTz ckpt_sync_end_t
bool CreateRestartPoint(int flags)
bool XLogInsertAllowed(void)
bool recoveryTargetInclusive
char * recovery_target_time_string
bool XLogNeedsFlush(XLogRecPtr RecPtr)
XLogRecPtr GetRedoRecPtr(void)
bool DataChecksumsEnabled(void)
bool wal_receiver_create_temp_slot
void WakeupRecovery(void)
void XLogFlush(XLogRecPtr RecPtr)
void xlog_desc(StringInfo buf, XLogReaderState *record)
bool HotStandbyActive(void)
int XLogFileOpen(XLogSegNo segno)
WALAvailability GetWALAvailability(XLogRecPtr targetLSN)
XLogRecPtr XactLastRecEnd
RecoveryTargetTimeLineGoal
void LocalProcessControlFile(bool reset)
char * GetMockAuthenticationNonce(void)
XLogSegNo XLogGetLastRemovedSegno(void)
RecoveryState GetRecoveryState(void)
char * wal_consistency_checking_string
void SetRecoveryPause(bool recoveryPause)
bool CheckPromoteSignal(void)
XLogRecPtr GetXLogReplayRecPtr(TimeLineID *replayTLI)
static int fd(const char *x, int i)
void UpdateFullPageWrites(void)
char * recoveryRestoreCommand
RecoveryTargetTimeLineGoal recoveryTargetTimeLineGoal
bool XLogBackgroundFlush(void)
void xlog_redo(XLogReaderState *record)
void XLogSetReplicationSlotMinimumLSN(XLogRecPtr lsn)
void XLogSetAsyncXactLSN(XLogRecPtr record)
void CheckXLogRemoved(XLogSegNo segno, TimeLineID tli)
XLogRecPtr GetInsertRecPtr(void)
void assign_checkpoint_completion_target(double newval, void *extra)
bool * wal_consistency_checking
bool PromoteIsTriggered(void)
void UpdateControlFile(void)
const char * xlog_identify(uint8 info)
char * recoveryEndCommand
void InitXLOGAccess(void)
HotStandbyState standbyState
PGDLLIMPORT int wal_level
XLogRecPtr GetXLogInsertRecPtr(void)
RecoveryTargetType recoveryTarget
char * PromoteTriggerFile
void RemovePromoteSignalFiles(void)
XLogRecPtr GetFlushRecPtr(void)
int max_slot_wal_keep_size_mb
int recovery_min_apply_delay
void register_persistent_abort_backup_handler(void)
bool HotStandbyActiveInReplay(void)
bool StandbyModeRequested
SessionBackupState get_backup_status(void)
void issue_xlog_fsync(int fd, XLogSegNo segno)
XLogRecPtr ProcLastRecPtr
TimestampTz GetCurrentChunkReplayStartTime(void)
XLogRecPtr GetLastImportantRecPtr(void)
int XLogFileInit(XLogSegNo segno, bool *use_existent, bool use_lock)
XLogRecPtr do_pg_stop_backup(char *labelfile, bool waitforarchive, TimeLineID *stoptli_p)
PGDLLIMPORT XLogRecPtr XactLastCommitEnd
void SetWalWriterSleeping(bool sleeping)
void ShutdownXLOG(int code, Datum arg)
XLogRecPtr GetFakeLSNForUnloggedRel(void)
void assign_max_wal_size(int newval, void *extra)
TimestampTz GetLatestXTime(void)
void XLogRequestWalReceiverReply(void)
XLogRecPtr XLogRestorePoint(const char *rpName)
bool RecoveryInProgress(void)
TransactionId recoveryTargetXid
void do_pg_abort_backup(int code, Datum arg)
XLogRecPtr recoveryTargetLSN
XLogRecPtr do_pg_start_backup(const char *backupidstr, bool fast, TimeLineID *starttli_p, StringInfo labelfile, List **tablespaces, StringInfo tblspcmapfile, bool needtblspcmapfile)
bool RecoveryIsPaused(void)
char * archiveCleanupCommand
CheckpointStatsData CheckpointStats
PGDLLIMPORT TimeLineID ThisTimeLineID
XLogRecPtr XLogInsertRecord(struct XLogRecData *rdata, XLogRecPtr fpw_lsn, uint8 flags, int num_fpi)
void GetFullPageWriteInfo(XLogRecPtr *RedoRecPtr_p, bool *doPageWrites_p)
int wal_retrieve_retry_interval
void StartupRequestWalReceiverRestart(void)
void XLogPutNextOid(Oid nextOid)
void GetXLogReceiptTime(TimestampTz *rtime, bool *fromStream)
uint64 GetSystemIdentifier(void)
XLogRecPtr CalculateMaxmumSafeLSN(void)
TimeLineID recoveryTargetTLIRequested
char * XLogArchiveCommand