Currently,`ptrack` codebase is split between small PostgreSQL core patch and extension. All public SQL API methods and main engine are placed in the`ptrack` extension, while the core patch contains only certain hooks and modifies binary utilities to ignore`ptrack.map.*` files.

This extension is compatible with PostgreSQL[11](patches/REL_11_STABLE-ptrack-core.diff),[12](patches/REL_12_STABLE-ptrack-core.diff),[13](patches/REL_13_STABLE-ptrack-core.diff),[14](patches/REL_14_STABLE-ptrack-core.diff),[15](patches/REL_15_STABLE-ptrack-core.diff),[16](patches/REL_16_STABLE-ptrack-core.diff),[17](patches/REL_17_STABLE-ptrack-core.diff).

This extension is compatible with PostgreSQL[11](patches/REL_11_STABLE-ptrack-core.diff),[12](patches/REL_12_STABLE-ptrack-core.diff),[13](patches/REL_13_STABLE-ptrack-core.diff),[14](patches/REL_14_STABLE-ptrack-core.diff),[15](patches/REL_15_STABLE-ptrack-core.diff),[16](patches/REL_16_STABLE-ptrack-core.diff),[17](patches/REL_17_STABLE-ptrack-core.diff),[18](patches/REL_18_STABLE-ptrack-core.diff).

index 596d2ca5836..3a72b8d2bf4 100644

@@ -136,6 +136,7 @@ intwal_retrieve_retry_interval = 5000;

intmax_slot_wal_keep_size_mb = -1;

intwal_decode_buffer_size = 512 * 1024;

booltrack_wal_io_timing = false;

#ifdef WAL_DEBUG

boolXLOG_DEBUG = false;

@@ -8929,6 +8930,12 @@ do_pg_backup_start(const char *backupidstr, bool fast, List **tablespaces,

{

boolcheckpointfpw;

/*

* Force a CHECKPOINT. Aside from being necessary to prevent torn

* page problems, this guarantees that two successive backup runs

index f0f88838dc2..239d50be357 100644

@@ -219,6 +219,12 @@ static const struct exclude_list_item excludeFiles[] =

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

index aa8c64a2c9e..56ed1b4df0a 100644

#include "storage/copydir.h"

#include "storage/fd.h"

/* GUCs */

intfile_copy_method = FILE_COPY_METHOD_COPY;

@@ -91,6 +93,9 @@ copydir(const char *fromdir, const 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 2ccb0faceb5..ad08c0c6960 100644

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

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

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

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

@@ -530,6 +532,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

register_dirty_segment(reln, forknum, v);

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

}

/*

@@ -637,6 +642,12 @@ mdzeroextend(SMgrRelation reln, ForkNumber forknum,

remblocks -= numblocks;

curblocknum += numblocks;

}

}

@@ -1139,7 +1150,14 @@ mdwritev(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

nblocks -= nblocks_this_segment;

buffers += nblocks_this_segment;

}

}

index fc16db90133..08cd553ad55 100644

@@ -74,6 +74,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

@@ -470,6 +472,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 df182577a19..8e4d7526db1 100644

@@ -80,6 +80,11 @@ static Latch LocalLatchData;

boolIgnoreSystemIndexes = false;

/* ----------------------------------------------------------------

*common process startup code

@@ -1908,6 +1913,8 @@ process_shared_preload_libraries(void)

false);

process_shared_preload_libraries_in_progress = false;

process_shared_preload_libraries_done = true;

}

/*

@@ -1950,3 +1957,71 @@ pg_bindtextdomain(const char *domain)

}

#endif

}

index f20be82862a..84c1d82b9cd 100644

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

{"pg_filenode.map", false},

{"pg_internal.init", true},

{"PG_VERSION", false},

#ifdef EXEC_BACKEND

{"config_exec_params", true},

#endif

index e876f35f38e..1fa3bf4d222 100644

@@ -87,6 +87,7 @@ static void FindEndOfXLOG(void);

static void KillExistingXLOG(void);

static void KillExistingArchiveStatus(void);

static void KillExistingWALSummaries(void);

static void WriteEmptyXLOG(void);

static void usage(void);

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

KillExistingXLOG();

KillExistingArchiveStatus();

KillExistingWALSummaries();

WriteEmptyXLOG();

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

@@ -1022,6 +1024,40 @@ KillExistingXLOG(void)

pg_fatal("could not close directory \"%s\": %m", XLOGDIR);

}

/*

* Remove existing archive status files

index c933871ca9f..f34c0edf350 100644

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

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

index adddac6710e..d57d04a6fd5 100644

@@ -59,6 +59,9 @@ extern PGDLLIMPORT int wal_decode_buffer_size;

extern PGDLLIMPORT int CheckPointSegments;

/* Archive modes */

typedef enum ArchiveMode

{

index f1d7beeed1a..f162c4405dc 100644

@@ -22,6 +22,9 @@ typedef enum FileCopyMethod

/* GUC parameters */

extern PGDLLIMPORT int file_copy_method;

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

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

index b563c27abf0..29fbc1c80c3 100644

extern PGDLLIMPORT const PgAioHandleCallbacks aio_md_readv_cb;

/* md storage manager functionality */

extern void mdinit(void);

extern void mdopen(SMgrRelation reln);

index c2272d14175..4132cfd92c6 100644

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

uint64segno;

} FileTag;

extern void InitSync(void);

extern void SyncPreCheckpoint(void);

extern void SyncPostCheckpoint(void);