Commitadbbd19

committed

Update RecentXmin

1 parent51e68f0 commitadbbd19Copy full SHA for adbbd19

File tree

+11

-7

lines changed

+11

-7

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`CC=gcc`
`2`		`-CFLAGS=-g -Wall -Iinclude -D_LARGEFILE64_SOURCE -DDEBUG`
	`2`	`+CFLAGS=-g -Wall -Iinclude -D_LARGEFILE64_SOURCE#-DDEBUG`
`3`	`3`	`LIBUV_PREFIX=$(HOME)/libuv-build`
`4`	`4`	`LIBUV_CFLAGS=-I"$(LIBUV_PREFIX)/include" -L"$(LIBUV_PREFIX)/lib"`
`5`	`5`	`LIBUV_LDFLAGS=-luv -pthread`

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -183,9 +183,6 @@ static void DtmMergeSnapshots(Snapshot dst, Snapshot src)`
`183`	`183`	`}`
`184`	`184`	`}`
`185`	`185`	`dst->xcnt=j;`
`186`		`-if (RecentXmin>dst->xmin) {`
`187`		`-RecentXmin=dst->xmin;`
`188`		`- }`
`189`	`186`	`DumpSnapshot(dst,"merged");`
`190`	`187`	`}`
`191`	`188`
`@@ -207,6 +204,9 @@ static void DtmUpdateRecentXmin(void)`
`207`	`204`	`if (TransactionIdFollows(RecentGlobalXmin,xmin)) {`
`208`	`205`	`RecentGlobalXmin=xmin;`
`209`	`206`	`}`
	`207`	`+if (TransactionIdFollows(RecentXmin,xmin)) {`
	`208`	`+RecentXmin=xmin;`
	`209`	`+}`
`210`	`210`	`}`
`211`	`211`	`}`
`212`	`212`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -7611,10 +7611,10 @@ heap_xlog_visible(XLogReaderState *record)`
`7611`	`7611`	`* we did for the heap page. If this results in a dropped bit, no`
`7612`	`7612`	`* real harm is done; and the next VACUUM will fix it.`
`7613`	`7613`	`*/`
`7614`		`-if (lsn>PageGetLSN(vmpage))`
	`7614`	`+if (lsn>PageGetLSN(vmpage)) {`
`7615`	`7615`	`visibilitymap_set(reln,blkno,InvalidBuffer,lsn,vmbuffer,`
`7616`	`7616`	`xlrec->cutoff_xid);`
`7617`		`-`
	`7617`	`+ }`
`7618`	`7618`	`ReleaseBuffer(vmbuffer);`
`7619`	`7619`	`FreeFakeRelcacheEntry(reln);`
`7620`	`7620`	`}`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,7 @@ heap_page_prune_opt(Relation relation, Buffer buffer)`
`98`	`98`	`OldestXmin=RecentGlobalXmin;`
`99`	`99`	`else`
`100`	`100`	`OldestXmin=RecentGlobalDataXmin;`
`101`		`-`
	`101`	`+fprintf(stderr,"PRUNEHEAP: xmin=%d\n",OldestXmin);`
`102`	`102`	`Assert(TransactionIdIsValid(OldestXmin));`
`103`	`103`
`104`	`104`	`/*`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,7 @@`
`85`	`85`	`#include"access/heapam_xlog.h"`
`86`	`86`	`#include"access/visibilitymap.h"`
`87`	`87`	`#include"access/xlog.h"`
	`88`	`+#include"utils/snapmgr.h"`
`88`	`89`	`#include"miscadmin.h"`
`89`	`90`	`#include"storage/bufmgr.h"`
`90`	`91`	`#include"storage/lmgr.h"`
`@@ -253,6 +254,9 @@ visibilitymap_set(Relation rel, BlockNumber heapBlk, Buffer heapBuf,`
`253`	`254`	`Pagepage;`
`254`	`255`	`char*map;`
`255`	`256`
	`257`	`+fprintf(stderr,"Visibilitymap cutoff %d, RecentLocalDataXmin=%d\n",cutoff_xid,RecentGlobalDataXmin);`
	`258`	`+return;`
	`259`	`+`
`256`	`260`	`#ifdefTRACE_VISIBILITYMAP`
`257`	`261`	`elog(DEBUG1,"vm_set %s %d",RelationGetRelationName(rel),heapBlk);`
`258`	`262`	`#endif`

Comments

(0)