index45be21131c5..134e677f9d1 100644

index5fbbe5ffd20..3c9b99f851d 100644

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

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

{"postmaster.pid", false},

{"postmaster.opts", false},

/* end of list */

{NULL, false}

};

@@ -214,6 +221,11 @@ 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

indexe04bc3941ae..996b5de6169 100644

indexd4fbe542077..b108416c708 100644

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

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

indexfdecbad1709..f849d00161e 100644

indexbf0f3ca76d1..7d9833a3604 100644

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

@@ -85,6 +85,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) \

@@ -515,6 +517,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

@@ -513,6 +515,9 @@ mdextend(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

register_dirty_segment(reln, forknum, v);

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

}

/*

@@ -622,6 +627,12 @@ mdzeroextend(SMgrRelation reln, ForkNumber forknum,

@@ -620,6 +625,12 @@ mdzeroextend(SMgrRelation reln, ForkNumber forknum,

remblocks -= numblocks;

curblocknum += numblocks;

}

}

@@ -867,6 +878,9 @@mdwrite(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

@@ -1015,7 +1026,14 @@mdwritev(SMgrRelation reln, ForkNumber forknum, BlockNumber blocknum,

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

register_dirty_segment(reln, forknum, v);

nblocks -= nblocks_this_segment;

buffers += nblocks_this_segment;

}

}

/*

index04fcb06056d..22bf179f560 100644

indexab7137d0fff..bc40a763c05 100644

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

@@ -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

@@ -475,6 +477,9 @@ ProcessSyncRequests(void)

@@ -470,6 +472,9 @@ ProcessSyncRequests(void)

CheckpointStats.ckpt_longest_sync = longest;

CheckpointStats.ckpt_agg_sync_time = total_elapsed;

sync_in_progress = false;

}

index19eb67e4854..008a7acc9f0 100644

index9e6fd435f60..f2180b9f6de 100644

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

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

{"pg_filenode.map", false},

{"pg_internal.init", true},

{"PG_VERSION", false},

{"config_exec_params", true},

#endif

indexe7ef2b8bd0c..ca7f8cdbc2f 100644

indexe9dcb5a6d89..844b04d5e12 100644

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

static void FindEndOfXLOG(void);

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

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

RewriteControlFile();

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

KillExistingXLOG();

KillExistingArchiveStatus();

KillExistingWALSummaries();

WriteEmptyXLOG();

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

@@ -1029,6 +1031,41 @@KillExistingArchiveStatus(void)

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

@@ -998,6 +1000,41 @@KillExistingXLOG(void)

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

}

/*

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

*Remove existing archive status files

indexbd5c598e200..a568156c5fb 100644

index255ddf2ffaf..1142c244926 100644

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

{NULL, false}

};

indexa8be5b21e0b..020874f96cd 100644

indexa25e258f479..b20b9c76e8d 100644

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

index941879ee6a8..24738aeecd0 100644

index620f10abdeb..b36936871bd 100644

extern void mdinit(void);

extern void mdopen(SMgrRelation reln);

indexcfbcfa6797d..2a432440db9 100644

index9dee8fa6e5b..348ed53e4e2 100644

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

uint32segno;

uint64segno;

} FileTag;