19#ifndef XLOG_INTERNAL_H
20#define XLOG_INTERNAL_H
34#define XLOG_PAGE_MAGIC 0xD118
52#define SizeOfXLogShortPHD MAXALIGN(sizeof(XLogPageHeaderData))
69#define SizeOfXLogLongPHD MAXALIGN(sizeof(XLogLongPageHeaderData))
74#define XLP_FIRST_IS_CONTRECORD 0x0001
76#define XLP_LONG_HEADER 0x0002
78#define XLP_BKP_REMOVABLE 0x0004
80#define XLP_FIRST_IS_OVERWRITE_CONTRECORD 0x0008
82#define XLP_ALL_FLAGS 0x000F
84#define XLogPageHeaderSize(hdr) \
85 (((hdr)->xlp_info & XLP_LONG_HEADER) ? SizeOfXLogLongPHD : SizeOfXLogShortPHD)
88#define WalSegMinSize 1024 * 1024
89#define WalSegMaxSize 1024 * 1024 * 1024
91#define DEFAULT_MIN_WAL_SEGS 5
92#define DEFAULT_MAX_WAL_SEGS 64
95#define IsPowerOf2(x) (x > 0 && ((x) & ((x)-1)) == 0)
96#define IsValidWalSegSize(size) \
97 (IsPowerOf2(size) && \
98 ((size) >= WalSegMinSize && (size) <= WalSegMaxSize))
100#define XLogSegmentsPerXLogId(wal_segsz_bytes) \
101 (UINT64CONST(0x100000000) / (wal_segsz_bytes))
103#define XLogSegNoOffsetToRecPtr(segno, offset, wal_segsz_bytes, dest) \
104 (dest) = (segno) * (wal_segsz_bytes) + (offset)
106#define XLogSegmentOffset(xlogptr, wal_segsz_bytes) \
107 ((xlogptr) & ((wal_segsz_bytes) - 1))
117#define XLByteToSeg(xlrp, logSegNo, wal_segsz_bytes) \
118 logSegNo = (xlrp) / (wal_segsz_bytes)
120#define XLByteToPrevSeg(xlrp, logSegNo, wal_segsz_bytes) \
121 logSegNo = ((xlrp) - 1) / (wal_segsz_bytes)
127#define XLogMBVarToSegs(mbvar, wal_segsz_bytes) \
128 ((mbvar) / ((wal_segsz_bytes) / (1024 * 1024)))
136#define XLByteInSeg(xlrp, logSegNo, wal_segsz_bytes) \
137 (((xlrp) / (wal_segsz_bytes)) == (logSegNo))
139#define XLByteInPrevSeg(xlrp, logSegNo, wal_segsz_bytes) \
140 ((((xlrp) - 1) / (wal_segsz_bytes)) == (logSegNo))
143#define XRecOffIsValid(xlrp) \
144 ((xlrp) % XLOG_BLCKSZ >= SizeOfXLogShortPHD)
149#define XLOGDIR "pg_wal"
150#define XLOG_CONTROL_FILE "global/pg_control"
156#define MAXFNAMELEN 64
159#define XLOG_FNAME_LEN 24
205 sscanf(fname,
"%08X%08X%08X", tli, &log, &seg);
226 return (strlen(fname) == 8 + strlen(
".history") &&
227 strspn(fname,
"0123456789ABCDEF") == 8 &&
228 strcmp(fname + 8,
".history") == 0);
257 strcmp(fname + strlen(fname) - strlen(
".backup"),
".backup") == 0);
354 const char *(*rm_identify) (
uint8 info);
void(* rm_mask)(char *pagedata, BlockNumber blkno)
void(* rm_redo)(XLogReaderState *record)
void(* rm_decode)(struct LogicalDecodingContext *ctx, struct XLogRecordBuffer *buf)
void(* rm_desc)(StringInfo buf, XLogReaderState *record)
struct XLogRecData * next
TimeLineID PrevTimeLineID
TimeLineID ThisTimeLineID
TimestampTz overwrite_time
XLogRecPtr overwritten_lsn
bool track_commit_timestamp
char rp_name[MAXFNAMELEN]
struct xl_overwrite_contrecord xl_overwrite_contrecord
struct XLogLongPageHeaderData XLogLongPageHeaderData
static RmgrData GetRmgr(RmgrId rmid)
XLogRecPtr RequestXLogSwitch(bool mark_unimportant)
struct xl_restore_point xl_restore_point
XLogLongPageHeaderData * XLogLongPageHeader
struct XLogRecData XLogRecData
@ RECOVERY_TARGET_ACTION_PAUSE
@ RECOVERY_TARGET_ACTION_PROMOTE
@ RECOVERY_TARGET_ACTION_SHUTDOWN
PGDLLIMPORT bool ArchiveRecoveryRequested
#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)
void XLogRecGetBlockRefInfo(XLogReaderState *record, bool pretty, bool detailed_format, StringInfo buf, uint32 *fpi_len)
static bool IsTLHistoryFileName(const char *fname)
pg_time_t GetLastSegSwitchData(XLogRecPtr *lastSwitchLSN)
XLogPageHeaderData * XLogPageHeader
static bool IsBackupHistoryFileName(const char *fname)
static void StatusFilePath(char *path, const char *xlog, const char *suffix)
struct xl_parameter_change xl_parameter_change
static void BackupHistoryFileName(char *fname, TimeLineID tli, XLogSegNo logSegNo, XLogRecPtr startpoint, int wal_segsz_bytes)
void RmgrNotFound(RmgrId rmid)
static void XLogFilePath(char *path, TimeLineID tli, XLogSegNo logSegNo, int wal_segsz_bytes)
PGDLLIMPORT bool StandbyMode
PGDLLIMPORT bool InArchiveRecovery
static void XLogFileNameById(char *fname, TimeLineID tli, uint32 log, uint32 seg)
static void XLogFileName(char *fname, TimeLineID tli, XLogSegNo logSegNo, int wal_segsz_bytes)
void GetOldestRestartPoint(XLogRecPtr *oldrecptr, TimeLineID *oldtli)
static void TLHistoryFilePath(char *path, TimeLineID tli)
static void BackupHistoryFilePath(char *path, TimeLineID tli, XLogSegNo logSegNo, XLogRecPtr startpoint, int wal_segsz_bytes)
PGDLLIMPORT RmgrData RmgrTable[]
struct XLogPageHeaderData XLogPageHeaderData
struct xl_end_of_recovery xl_end_of_recovery
static bool RmgrIdExists(RmgrId rmid)
static void TLHistoryFileName(char *fname, TimeLineID tli)
#define XLogSegmentsPerXLogId(wal_segsz_bytes)
void RegisterCustomRmgr(RmgrId rmid, const RmgrData *rmgr)
PGDLLIMPORT char * recoveryRestoreCommand
static bool IsPartialXLogFileName(const char *fname)