-PG_VERSION=12 PG_BRANCH=REL_12_STABLE TEST_CASE=all MODE=paranoia

-PG_VERSION=12 PG_BRANCH=REL_12_STABLE TEST_CASE=test_ptrack_multiple_segments TEST_REPEATS=5 MODE=paranoia

-PG_VERSION=12 PG_BRANCH=REL_12_STABLE TEST_CASE=test_ptrack_eat_my_data TEST_REPEATS=4

-PG_VERSION=11 PG_BRANCH=REL_11_STABLE TEST_CASE=tap

-PG_VERSION=11 PG_BRANCH=REL_11_STABLE TEST_CASE=tap MODE=legacy

codecov:

notify:

after_n_builds:5# keep in sync with .travis.yml number of builds

after_n_builds:8# keep in sync with .travis.yml number of builds

index 3e53b3df6fb..f76bfc2a646 100644

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

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

@@ -224,6 +231,10 @@ static const struct exclude_list_item noChecksumFiles[] = {

{"pg_filenode.map", false},

{"pg_internal.init", true},

{"PG_VERSION", false},

#ifdef EXEC_BACKEND

{"config_exec_params", true},

#endif

index 4a0d23b11e3..d59009a4c8c 100644

#include "miscadmin.h"

#include "pgstat.h"

/*

* copydir: copy a directory

*

@@ -78,6 +80,9 @@ copydir(char *fromdir, char *todir, bool recurse)

}

FreeDir(xldir);

/*

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

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

index 200cc7f657a..d0dcb5c0287 100644

#include "utils/memutils.h"

#include "pg_trace.h"

/* intervals for calling AbsorbFsyncRequests in mdsync and mdpostckpt */

#define FSYNCS_PER_ABSORB10

@@ -114,6 +115,8 @@ typedef struct _MdfdVec

static MemoryContext MdCxt;/* context for all MdfdVec objects */

/*

* In some contexts (currently, standalone backends and the checkpointer)

@@ -558,6 +561,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

register_dirty_segment(reln, forknum, v);

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

}

/*

@@ -851,6 +857,9 @@ mdwrite(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

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

register_dirty_segment(reln, forknum, v);

}

/*

@@ -1329,6 +1338,9 @@ mdsync(void)

CheckpointStats.ckpt_longest_sync = longest;

CheckpointStats.ckpt_agg_sync_time = total_elapsed;

/* Flag successful completion of mdsync */

mdsync_in_progress = false;

}

index 6fb403a5a8a..6e31ccb3e0f 100644

@@ -84,6 +84,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);

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

RewriteControlFile();

KillExistingXLOG();

KillExistingArchiveStatus();

WriteEmptyXLOG();

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

@@ -1201,6 +1203,57 @@ KillExistingArchiveStatus(void)

}

}

/*

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

index 197163d5544..fc846e78175 100644

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

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

index 80241455357..50dca7bf6f4 100644

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

NormalProcessing/* normal processing */

} ProcessingMode;

#define IsBootstrapProcessingMode() (Mode == BootstrapProcessing)

#define IsInitProcessingMode()(Mode == InitProcessing)

index 9a26295c8e8..dc72b27a10d 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)

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

#ifdef USE_SSE42_CRC32C_WITH_RUNTIME_CHECK

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

#endif

index 4fef3e21072..e55430879c3 100644

#ifndef COPYDIR_H

#define COPYDIR_H

extern void copydir(char *fromdir, char *todir, bool recurse);

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

index 0298ed1a2bc..24c684771d0 100644

@@ -116,6 +116,17 @@ extern void AtEOXact_SMgr(void);

/* internals: move me elsewhere -- ay 7/94 */

/* in md.c */

extern void mdinit(void);

extern void mdclose(SMgrRelation reln, ForkNumber forknum);

extern void mdcreate(SMgrRelation reln, ForkNumber forknum, bool isRedo);

#ifPG_VERSION_NUM >=120000

staticcopydir_hook_typeprev_copydir_hook=NULL;

staticmdwrite_hook_typeprev_mdwrite_hook=NULL;

staticmdextend_hook_typeprev_mdextend_hook=NULL;

#ifPG_VERSION_NUM >=120000

staticProcessSyncRequests_hook_typeprev_ProcessSyncRequests_hook=NULL;

void_PG_init(void);

void_PG_fini(void);

ForkNumberforkno,BlockNumberblkno);

staticvoidptrack_mdextend_hook(RelFileNodeBackendsmgr_rnode,

ForkNumberforkno,BlockNumberblkno);

#ifPG_VERSION_NUM >=120000

staticvoidptrack_ProcessSyncRequests_hook(void);

staticvoidptrack_gather_filelist(List**filelist,char*path,OidspcOid,OiddbOid);

staticintptrack_filelist_getnext(PtScanCtx*ctx);

mdwrite_hook=ptrack_mdwrite_hook;

prev_mdextend_hook=mdextend_hook;

mdextend_hook=ptrack_mdextend_hook;

#ifPG_VERSION_NUM >=120000

prev_ProcessSyncRequests_hook=ProcessSyncRequests_hook;

ProcessSyncRequests_hook=ptrack_ProcessSyncRequests_hook;

}

copydir_hook=prev_copydir_hook;

mdwrite_hook=prev_mdwrite_hook;

mdextend_hook=prev_mdextend_hook;

#ifPG_VERSION_NUM >=120000

ProcessSyncRequests_hook=prev_ProcessSyncRequests_hook;

}

prev_mdextend_hook(smgr_rnode,forknum,blocknum);

}

#ifPG_VERSION_NUM >=120000

ptrack_ProcessSyncRequests_hook()

{

if (prev_ProcessSyncRequests_hook)

prev_ProcessSyncRequests_hook();

}