46 bool *nulls,
uint32 ncols);
52 bool stats_per_record);
54 uint64 rec_len, uint64 total_rec_len,
55 uint64 fpi_len, uint64 total_fpi_len,
56 uint64 tot_len, uint64 total_len,
61 bool stats_per_record);
101 if (lsn < XLOG_BLCKSZ)
103 (
errmsg(
"could not read WAL at LSN %X/%X",
117 (
errcode(ERRCODE_OUT_OF_MEMORY),
119 errdetail(
"Failed while allocating a WAL reading processor.")));
126 (
errmsg(
"could not find a valid record after %X/%X",
166 errmsg(
"could not read WAL at %X/%X: %s",
171 errmsg(
"could not read WAL at %X/%X",
183 bool *nulls,
uint32 ncols)
200 desc.
rm_desc(&rec_desc, record);
231 #define PG_GET_WAL_BLOCK_INFO_COLS 11
251 &rnode, &fork, &blkno, NULL);
264 (
errcode(ERRCODE_INTERNAL_ERROR),
301 (
errcode(ERRCODE_INTERNAL_ERROR),
309 memcpy(
VARDATA(raw_page), page, BLCKSZ);
338 memset(&nulls[
i],
true, 3 *
sizeof(
bool));
348 #undef PG_GET_WAL_FPI_BLOCK_COLS
374 "pg_get_block_fpi_info temporary cxt",
405 #define PG_GET_WAL_RECORD_INFO_COLS 11
420 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
421 errmsg(
"WAL input LSN must be less than current LSN"),
422 errdetail(
"Current WAL LSN on the database system is at %X/%X.",
427 elog(
ERROR,
"return type must be a row type");
433 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
434 errmsg(
"could not read WAL at %X/%X",
446 #undef PG_GET_WAL_RECORD_INFO_COLS
460 if (start_lsn > curr_lsn)
462 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
463 errmsg(
"WAL start LSN must be less than current LSN"),
464 errdetail(
"Current WAL LSN on the database system is at %X/%X.",
467 if (start_lsn > *end_lsn)
469 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
470 errmsg(
"WAL start LSN must be less than end LSN")));
472 if (*end_lsn > curr_lsn)
483 #define PG_GET_WAL_RECORDS_INFO_COLS 11
491 Assert(start_lsn <= end_lsn);
498 "GetWALRecordsInfo temporary cxt",
524 #undef PG_GET_WAL_RECORDS_INFO_COLS
547 uint64 n, uint64 total_count,
548 uint64 rec_len, uint64 total_rec_len,
549 uint64 fpi_len, uint64 total_fpi_len,
550 uint64 tot_len, uint64 total_len,
560 if (total_count != 0)
561 n_pct = 100 * (double) n / total_count;
564 if (total_rec_len != 0)
565 rec_len_pct = 100 * (double) rec_len / total_rec_len;
568 if (total_fpi_len != 0)
569 fpi_len_pct = 100 * (double) fpi_len / total_fpi_len;
573 tot_len_pct = 100 * (double) tot_len / total_len;
594 bool stats_per_record)
598 uint64 total_count = 0;
599 uint64 total_rec_len = 0;
600 uint64 total_fpi_len = 0;
601 uint64 total_len = 0;
617 total_len = total_rec_len + total_fpi_len;
620 "GetXLogSummaryStats temporary cxt",
639 if (stats_per_record)
650 tot_len = rec_len + fpi_len;
661 id =
psprintf(
"UNKNOWN (%x)", rj << 4);
664 total_count, rec_len, total_rec_len, fpi_len,
665 total_fpi_len, tot_len, total_len,
681 tot_len = rec_len + fpi_len;
686 total_rec_len, fpi_len, total_fpi_len, tot_len,
687 total_len,
values, nulls, ncols);
706 bool stats_per_record)
708 #define PG_GET_WAL_STATS_COLS 9
715 Assert(start_lsn <= end_lsn);
736 #undef PG_GET_WAL_STATS_COLS
750 GetWalStats(fcinfo, start_lsn, end_lsn, stats_per_record);
765 if (start_lsn > end_lsn)
767 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
768 errmsg(
"WAL start LSN must be less than current LSN"),
769 errdetail(
"Current WAL LSN on the database system is at %X/%X.",
784 if (start_lsn > end_lsn)
786 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
787 errmsg(
"WAL start LSN must be less than current LSN"),
788 errdetail(
"Current WAL LSN on the database system is at %X/%X.",
791 GetWalStats(fcinfo, start_lsn, end_lsn, stats_per_record);
ArrayType * construct_array_builtin(Datum *elems, int nelems, Oid elmtype)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
elog(ERROR, "%s: %s", p2, msg)
int errmsg_internal(const char *fmt,...)
int errcode_for_file_access(void)
int errdetail(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
Datum Int64GetDatum(int64 X)
Datum Float8GetDatum(float8 X)
#define PG_GETARG_BOOL(n)
#define PG_RETURN_DATUM(x)
void InitMaterializedSRF(FunctionCallInfo fcinfo, bits32 flags)
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)
if(TABLE==NULL||TABLE_index==NULL)
Assert(fmt[strlen(fmt) - 1] !='\n')
void MemoryContextReset(MemoryContext context)
void pfree(void *pointer)
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define CHECK_FOR_INTERRUPTS()
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
uint64 pg_popcount(const char *buf, int bytes)
static Datum LSNGetDatum(XLogRecPtr X)
static void GetWALRecordInfo(XLogReaderState *record, Datum *values, bool *nulls, uint32 ncols)
#define PG_GET_WAL_STATS_COLS
Datum pg_get_wal_records_info(PG_FUNCTION_ARGS)
Datum pg_get_wal_stats(PG_FUNCTION_ARGS)
static void GetWalStats(FunctionCallInfo fcinfo, XLogRecPtr start_lsn, XLogRecPtr end_lsn, bool stats_per_record)
#define PG_GET_WAL_RECORDS_INFO_COLS
static void GetWALBlockInfo(FunctionCallInfo fcinfo, XLogReaderState *record)
#define PG_GET_WAL_RECORD_INFO_COLS
Datum pg_get_wal_block_info(PG_FUNCTION_ARGS)
static void GetWALRecordsInfo(FunctionCallInfo fcinfo, XLogRecPtr start_lsn, XLogRecPtr end_lsn)
Datum pg_get_wal_records_info_till_end_of_wal(PG_FUNCTION_ARGS)
#define PG_GET_WAL_BLOCK_INFO_COLS
static XLogRecord * ReadNextXLogRecord(XLogReaderState *xlogreader)
static XLogReaderState * InitXLogReaderState(XLogRecPtr lsn)
Datum pg_get_wal_stats_till_end_of_wal(PG_FUNCTION_ARGS)
static void GetXLogSummaryStats(XLogStats *stats, ReturnSetInfo *rsinfo, Datum *values, bool *nulls, uint32 ncols, bool stats_per_record)
PG_FUNCTION_INFO_V1(pg_get_wal_block_info)
static void FillXLogStatsRow(const char *name, uint64 n, uint64 total_count, uint64 rec_len, uint64 total_rec_len, uint64 fpi_len, uint64 total_fpi_len, uint64 tot_len, uint64 total_len, Datum *values, bool *nulls, uint32 ncols)
static void ValidateInputLSNs(XLogRecPtr start_lsn, XLogRecPtr *end_lsn)
Datum pg_get_wal_record_info(PG_FUNCTION_ARGS)
static XLogRecPtr GetCurrentLSN(void)
static Datum PointerGetDatum(const void *X)
static Datum TransactionIdGetDatum(TransactionId X)
static Datum Int16GetDatum(int16 X)
static Datum ObjectIdGetDatum(Oid X)
static Datum UInt32GetDatum(uint32 X)
char * psprintf(const char *fmt,...)
const char *const forkNames[]
#define RmgrIdIsValid(rmid)
void initStringInfo(StringInfo str)
Tuplestorestate * setResult
const char *(* rm_identify)(uint8 info)
void(* rm_desc)(StringInfo buf, XLogReaderState *record)
XLogRecStats record_stats[RM_MAX_ID+1][MAX_XLINFO_TYPES]
XLogRecStats rmgr_stats[RM_MAX_ID+1]
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, Datum *values, bool *isnull)
#define SET_VARSIZE(PTR, len)
bool RecoveryInProgress(void)
XLogRecPtr GetFlushRecPtr(TimeLineID *insertTLI)
static RmgrData GetRmgr(RmgrId rmid)
static bool RmgrIdExists(RmgrId rmid)
#define LSN_FORMAT_ARGS(lsn)
#define XLogRecPtrIsInvalid(r)
void XLogRecGetBlockRefInfo(XLogReaderState *record, bool pretty, bool detailed_format, StringInfo buf, uint32 *fpi_len)
bool XLogRecGetBlockTagExtended(XLogReaderState *record, uint8 block_id, RelFileLocator *rlocator, ForkNumber *forknum, BlockNumber *blknum, Buffer *prefetch_buffer)
XLogRecord * XLogReadRecord(XLogReaderState *state, char **errormsg)
void XLogReaderFree(XLogReaderState *state)
XLogReaderState * XLogReaderAllocate(int wal_segment_size, const char *waldir, XLogReaderRoutine *routine, void *private_data)
XLogRecPtr XLogFindNextRecord(XLogReaderState *state, XLogRecPtr RecPtr)
bool RestoreBlockImage(XLogReaderState *record, uint8 block_id, char *page)
#define XLogRecGetDataLen(decoder)
#define XLogRecGetInfo(decoder)
#define XLogRecGetRmid(decoder)
#define XLogRecGetTotalLen(decoder)
#define XLogRecGetXid(decoder)
#define XLogRecGetBlock(decoder, i)
#define XLogRecMaxBlockId(decoder)
#define XLogRecHasBlockRef(decoder, block_id)
#define XLogRecGetPrev(decoder)
#define BKPIMAGE_COMPRESS_ZSTD
#define BKPIMAGE_HAS_HOLE
#define BKPIMAGE_COMPRESS_LZ4
#define BKPIMAGE_COMPRESS_PGLZ
XLogRecPtr GetXLogReplayRecPtr(TimeLineID *replayTLI)
static XLogReaderState * xlogreader
void XLogRecStoreStats(XLogStats *stats, XLogReaderState *record)
void wal_segment_close(XLogReaderState *state)
void wal_segment_open(XLogReaderState *state, XLogSegNo nextSegNo, TimeLineID *tli_p)
int read_local_xlog_page_no_wait(XLogReaderState *state, XLogRecPtr targetPagePtr, int reqLen, XLogRecPtr targetRecPtr, char *cur_page)