#ifPG_VERSION_NUM >=150000

#ifPG_VERSION_NUM >=120000

ptrack_write_chunk(intfd,pg_crc32c*crc,char*chunk,size_tsize)

{

COMP_CRC32_COMMON(*crc, (char*)chunk,size);

#ifPG_VERSION_NUM >=150000

COMP_CRC32C_COMMON(*crc, (char*)chunk,size);

COMP_CRC32C(*crc, (char*)chunk,size);

if (write(fd,chunk,size)!=size)

{

pg_crc32c*file_crc;

INIT_CRC32C(crc);

COMP_CRC32_COMMON(crc, (char*)ptrack_map,PtrackCrcOffset);

#ifPG_VERSION_NUM >=150000

COMP_CRC32C_COMMON(crc, (char*)ptrack_map,PtrackCrcOffset);

COMP_CRC32C(crc, (char*)ptrack_map,PtrackCrcOffset);

FIN_CRC32C(crc);

file_crc= (pg_crc32c*) ((char*)ptrack_map+PtrackCrcOffset);

commita14ac459d71528c64df00c693e9c71ac70d3ba29

Author:anastasia<a.lubennikova@postgrespro.ru>

Date:Mon Oct 19 14:53:06 2020 +0300

commit98d98792c0dbe589e8baee4c4100e0dc174ccacb

Author:Anton A. Melnikov<a.melnikov@postgrespro.ru>

Date:Wed Apr 13 09:49:33 2022 +0300

index50ae1f16d0..721b926ad2 100644

index67489192a2..5e22017bd1 100644

@@ -233,6 +233,13 @@ static const struct exclude_list_item excludeFiles[] =

@@ -197,6 +197,13 @@ static const struct exclude_list_item excludeFiles[] =

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

@@ -248,6 +255,11 @@ static const struct exclude_list_item noChecksumFiles[] = {

@@ -212,6 +219,11 @@ static const struct exclude_list_item noChecksumFiles[] = {

{"pg_filenode.map", false},

{"pg_internal.init", true},

{"PG_VERSION", false},

{"config_exec_params", true},

#endif

index0cf598dd0c..c9c44a4ae7 100644

index658fd95ba9..eee38eba17 100644

* Be paranoid here and fsync all files to ensure the copy is really done.

* But if fsync is disabled, we're done.

index0eacd461cd..c2ef404a1a 100644

index286dd3f755..2c496b3a6d 100644

@@ -87,6 +87,8 @@ typedef struct _MdfdVec

/* Populate a file tag describing an md.c segment file. */

#define INIT_MD_FILETAG(a,xx_rnode,xx_forknum,xx_segno) \

@@ -435,6 +437,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

@@ -465,6 +467,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

register_dirty_segment(reln, forknum, v);

Assert(_mdnblocks(reln, forknum, v) <= ((BlockNumber) RELSEG_SIZE));

}

/*

@@ -721,6 +726,9 @@ mdwrite(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

@@ -757,6 +762,9 @@ mdwrite(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

if (!skipFsync && !SmgrIsTemp(reln))

register_dirty_segment(reln, forknum, v);

/*

index3ded2cdd71..3a596a59f7 100644

indexc695d816fc..77e2ab1996 100644

@@ -75,6 +75,8 @@ static MemoryContext pendingOpsCxt; /* context for the above */

@@ -81,6 +81,8 @@ static MemoryContext pendingOpsCxt; /* context for the above */

static CycleCtr sync_cycle_ctr = 0;

static CycleCtr checkpoint_cycle_ctr = 0;

/* Intervals for calling AbsorbSyncRequests */

#define FSYNCS_PER_ABSORB10

#define UNLINKS_PER_ABSORB10

@@ -420,6 +422,9 @@ ProcessSyncRequests(void)

@@ -478,6 +480,9 @@ ProcessSyncRequests(void)

CheckpointStats.ckpt_longest_sync = longest;

CheckpointStats.ckpt_agg_sync_time = total_elapsed;

/* Flag successful completion of ProcessSyncRequests */

sync_in_progress = false;

}

index 1683629ee3..d2fc154576 100644

@@ -620,7 +620,6 @@ static char *recovery_target_xid_string;

static char *recovery_target_name_string;

static char *recovery_target_lsn_string;

/* should be static, but commands/variable.c needs to get at this */

char *role_string;

indexffdc23945c..7ae95866ce 100644

index21dfe1b6ee..266ac1ef40 100644

@@ -114,6 +114,11 @@ static const struct exclude_list_item skip[] = {

@@ -118,6 +118,11 @@ static const struct exclude_list_item skip[] = {

{"pg_filenode.map", false},

{"pg_internal.init", true},

{"PG_VERSION", false},

{"config_exec_params", true},

#endif

index233441837f..cf7bd073bf 100644

indexd4772a2965..66456f7e44 100644

@@ -84,6 +84,7 @@ static void RewriteControlFile(void);

@@ -85,6 +85,7 @@ static void RewriteControlFile(void);

static void FindEndOfXLOG(void);

static void KillExistingXLOG(void);

static void KillExistingArchiveStatus(void);

static void WriteEmptyXLOG(void);

static void usage(void);

@@ -513,6 +514,7 @@ main(int argc, char *argv[])

@@ -488,6 +489,7 @@ main(int argc, char *argv[])

RewriteControlFile();

KillExistingXLOG();

KillExistingArchiveStatus();

WriteEmptyXLOG();

printf(_("Write-ahead log reset\n"));

@@ -1102,6 +1104,53 @@ KillExistingArchiveStatus(void)

@@ -1036,6 +1038,53 @@ KillExistingArchiveStatus(void)

}

/*

* Write an empty XLOG file, containing only the checkpoint record

indexfbb97b5cf1..6cd7f2ae3e 100644

indexd61067f6b2..27ec23137d 100644

@@ -124,6 +124,10 @@ static const struct exclude_list_item excludeFiles[] =

@@ -157,6 +157,10 @@ static const struct exclude_list_item excludeFiles[] =

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

index 72e3352398..5c2e016501 100644

@@ -388,7 +388,7 @@ typedef enum ProcessingMode

NormalProcessing/* normal processing */

} ProcessingMode;

index 1904fabd5a..f9306a6d01 100644

#define CHECKSUM_H

#define IsBootstrapProcessingMode() (Mode == BootstrapProcessing)

#define IsInitProcessingMode()(Mode == InitProcessing)

index 3c6f906683..a7355f7ad1 100644

@@ -69,8 +69,11 @@ extern pg_crc32c pg_comp_crc32c_armv8(pg_crc32c crc, const void *data, size_t le

#define FIN_CRC32C(crc) ((crc) ^= 0xFFFFFFFF)

/*

* Compute the checksum for a Postgres page. The page must be aligned on a

*/

extern uint16 pg_checksum_page(char *page, BlockNumber blkno);

extern pg_crc32c pg_comp_crc32c_sb8(pg_crc32c crc, const void *data, size_t len);

#endif/* CHECKSUM_H */

index 015f0f1f83..1c5a0ba351 100644

@@ -213,3 +213,11 @@ pg_checksum_page(char *page, BlockNumber blkno)

*/

return (uint16) ((checksum % 65535) + 1);

}

#ifdef USE_SSE42_CRC32C_WITH_RUNTIME_CHECK

extern pg_crc32c pg_comp_crc32c_sse42(pg_crc32c crc, const void *data, size_t len);

#endif

index5d28f59c1d..0d3f04d8af 100644

index50a26edeb0..af1602f515 100644

extern void copy_file(char *fromfile, char *tofile);

index07fd1bb7d0..5294811bc8 100644

index6e46d8d96a..f0967ef484 100644

extern void mdinit(void);

extern void mdopen(SMgrRelation reln);

indexe16ab8e711..88da9686eb 100644

index9737e1eb67..914ad86328 100644

@@ -50,6 +50,9 @@ typedef struct FileTag

@@ -55,6 +55,9 @@ typedef struct FileTag

uint32segno;

} FileTag;