You've already forked pgbackrest
mirror of
https://github.com/pgbackrest/pgbackrest.git
synced 2025-07-05 00:28:52 +02:00
e634fd85ce
If backup_label is removed from a restored backup then PostgreSQL will instead use checkpoint information from pg_control to attempt (what is thinks is) crash recovery. This will nearly always result in a corrupt cluster because the checkpoint will not be from the beginning of the backup, and even if it is, the end point will not be specified, which could lead to recovery stopping too early. To prevent this, invalidate the checkpoint LSN in pg_control on restore. If backup_label is removed then recovery will still fail because PostgreSQL will not be able to find the invalid checkpoint. The LSN of the checkpoint is not logged but it will be visible in pg_controldata output as 0/DEAD. This value is invalid because PostgreSQL always skips the first WAL segment when initializing a cluster.
166 lines
13 KiB
C
166 lines
13 KiB
C
/***********************************************************************************************************************************
|
|
PostgreSQL Version Interface
|
|
|
|
Macros for building version-specific functions that interface with the types in version.vendor.h. Due to the way PostgreSQL types
|
|
evolve over time, this seems to be the easiest way to extract information from them.
|
|
|
|
These macros should be kept as simple as possible, with most of the logic contained in postgres/interface.c.
|
|
***********************************************************************************************************************************/
|
|
#include "postgres/interface/version.vendor.h"
|
|
#include "postgres/version.h"
|
|
|
|
/***********************************************************************************************************************************
|
|
Determine if the supplied pg_control is for this version of PostgreSQL. When CATALOG_VERSION_NO_MAX is defined then the catalog will
|
|
be accepted as a range that lasts until the end of the encoded year. This allows pgBackRest to work with PostgreSQL during the
|
|
alpha/beta/rc period without needing to be updated, unless of course the actual interface changes.
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#ifdef CATALOG_VERSION_NO_MAX
|
|
|
|
#define PG_INTERFACE_CONTROL_IS(version) \
|
|
static bool \
|
|
pgInterfaceControlIs##version(const unsigned char *controlFile) \
|
|
{ \
|
|
ASSERT(controlFile != NULL); \
|
|
\
|
|
return \
|
|
((ControlFileData *)controlFile)->pg_control_version == PG_CONTROL_VERSION && \
|
|
((ControlFileData *)controlFile)->catalog_version_no >= CATALOG_VERSION_NO && \
|
|
((ControlFileData *)controlFile)->catalog_version_no < (CATALOG_VERSION_NO / 100000 + 1) * 100000; \
|
|
}
|
|
|
|
#else
|
|
|
|
#define PG_INTERFACE_CONTROL_IS(version) \
|
|
static bool \
|
|
pgInterfaceControlIs##version(const unsigned char *controlFile) \
|
|
{ \
|
|
ASSERT(controlFile != NULL); \
|
|
\
|
|
return \
|
|
((ControlFileData *)controlFile)->pg_control_version == PG_CONTROL_VERSION && \
|
|
((ControlFileData *)controlFile)->catalog_version_no == CATALOG_VERSION_NO; \
|
|
}
|
|
|
|
#endif
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Read the version specific pg_control into a general data structure
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#define PG_INTERFACE_CONTROL(version) \
|
|
static PgControl \
|
|
pgInterfaceControl##version(const unsigned char *controlFile) \
|
|
{ \
|
|
ASSERT(controlFile != NULL); \
|
|
\
|
|
return (PgControl) \
|
|
{ \
|
|
.systemId = ((ControlFileData *)controlFile)->system_identifier, \
|
|
.catalogVersion = ((ControlFileData *)controlFile)->catalog_version_no, \
|
|
.checkpoint = ((ControlFileData *)controlFile)->checkPoint, \
|
|
.timeline = ((ControlFileData *)controlFile)->checkPointCopy.ThisTimeLineID, \
|
|
.pageSize = ((ControlFileData *)controlFile)->blcksz, \
|
|
.walSegmentSize = ((ControlFileData *)controlFile)->xlog_seg_size, \
|
|
.pageChecksumVersion = ((ControlFileData *)controlFile)->data_checksum_version, \
|
|
}; \
|
|
}
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Get control crc offset
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#define PG_INTERFACE_CONTROL_CRC_OFFSET(version) \
|
|
static size_t \
|
|
pgInterfaceControlCrcOffset##version(void) \
|
|
{ \
|
|
return offsetof(ControlFileData, crc); \
|
|
}
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Invalidate control checkpoint. PostgreSQL skips the first segment so any LSN in that segment is invalid.
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_93
|
|
|
|
#define PG_INTERFACE_CONTROL_CHECKPOINT_INVALIDATE(version) \
|
|
static void \
|
|
pgInterfaceControlCheckpointInvalidate##version(unsigned char *const controlFile) \
|
|
{ \
|
|
((ControlFileData *)controlFile)->checkPoint = PG_CONTROL_CHECKPOINT_INVALID; \
|
|
}
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Get the control version
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#define PG_INTERFACE_CONTROL_VERSION(version) \
|
|
static uint32_t \
|
|
pgInterfaceControlVersion##version(void) \
|
|
{ \
|
|
return PG_CONTROL_VERSION; \
|
|
}
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Determine if the supplied WAL is for this version of PostgreSQL
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#define PG_INTERFACE_WAL_IS(version) \
|
|
static bool \
|
|
pgInterfaceWalIs##version(const unsigned char *walFile) \
|
|
{ \
|
|
ASSERT(walFile != NULL); \
|
|
\
|
|
return ((XLogPageHeaderData *)walFile)->xlp_magic == XLOG_PAGE_MAGIC; \
|
|
}
|
|
|
|
#endif
|
|
|
|
/***********************************************************************************************************************************
|
|
Read the version specific WAL header into a general data structure
|
|
***********************************************************************************************************************************/
|
|
#if PG_VERSION > PG_VERSION_MAX
|
|
|
|
#elif PG_VERSION >= PG_VERSION_94
|
|
|
|
#define PG_INTERFACE_WAL(version) \
|
|
static PgWal \
|
|
pgInterfaceWal##version(const unsigned char *walFile) \
|
|
{ \
|
|
ASSERT(walFile != NULL); \
|
|
\
|
|
return (PgWal) \
|
|
{ \
|
|
.systemId = ((XLogLongPageHeaderData *)walFile)->xlp_sysid, \
|
|
.size = ((XLogLongPageHeaderData *)walFile)->xlp_seg_size, \
|
|
}; \
|
|
}
|
|
|
|
#endif
|