Commit81035a7

authored and

committed

Restore rule for getting global snapshot

1 parent6e97853 commit81035a7Copy full SHA for 81035a7

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -123,6 +123,7 @@ static TransactionId DtmNextXid;`
`123`	`123`	`staticSnapshotDataDtmSnapshot= {HeapTupleSatisfiesMVCC };`
`124`	`124`	`staticboolDtmHasGlobalSnapshot;`
`125`	`125`	`staticintDtmLocalXidReserve;`
	`126`	`+staticCommandIdDtmCurcid;`
`126`	`127`	`staticSnapshotDtmLastSnapshot;`
`127`	`128`	`staticTransactionManagerDtmTM= {`
`128`	`129`	`DtmGetTransactionStatus,`
`@@ -630,11 +631,12 @@ static Snapshot DtmGetSnapshot(Snapshot snapshot)`
`630`	`631`	`{`
`631`	`632`	`if (TransactionIdIsValid(DtmNextXid)&&snapshot!=&CatalogSnapshotData)`
`632`	`633`	`{`
`633`		`-if (!DtmHasGlobalSnapshot) {`
	`634`	`+if (!DtmHasGlobalSnapshot&& (snapshot!=DtmLastSnapshot\|\|DtmCurcid!=GetCurrentCommandId(false))) {`
`634`	`635`	`DtmGlobalGetSnapshot(DtmNextXid,&DtmSnapshot,&dtm->minXid);`
`635`	`636`	`}`
`636`	`637`	`DtmLastSnapshot=snapshot;`
`637`	`638`	`DtmMergeWithGlobalSnapshot(snapshot);`
	`639`	`+DtmCurcid=snapshot->curcid;`
`638`	`640`	`if (!IsolationUsesXactSnapshot())`
`639`	`641`	`{`
`640`	`642`	`/* Use single global snapshot during all transaction for repeatable read isolation level,`

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -107,6 +107,7 @@ static SnapshotData DtmSnapshot = { HeapTupleSatisfiesMVCC };`
`107`	`107`	`staticboolDtmHasGlobalSnapshot;`
`108`	`108`	`staticboolDtmGlobalXidAssigned;`
`109`	`109`	`staticintDtmLocalXidReserve;`
	`110`	`+staticCommandIdDtmCurcid;`
`110`	`111`	`staticSnapshotDtmLastSnapshot;`
`111`	`112`	`staticTransactionManagerDtmTM= {`
`112`	`113`	`DtmGetTransactionStatus,`
`@@ -600,7 +601,6 @@ DtmGetNewTransactionId(bool isSubXact)`
`600`	`601`	`returnxid;`
`601`	`602`	`}`
`602`	`603`
`603`		`-`
`604`	`604`	`staticSnapshotDtmGetSnapshot(Snapshotsnapshot)`
`605`	`605`	`{`
`606`	`606`	`if (DtmGlobalXidAssigned)`
`@@ -613,11 +613,13 @@ static Snapshot DtmGetSnapshot(Snapshot snapshot)`
`613`	`613`	`}`
`614`	`614`	`if (TransactionIdIsValid(DtmNextXid)&&snapshot!=&CatalogSnapshotData)`
`615`	`615`	`{`
	`616`	`+// if (!DtmHasGlobalSnapshot && (snapshot != DtmLastSnapshot \|\| DtmCurcid != GetCurrentCommandId(false))) {`
`616`	`617`	`if (!DtmHasGlobalSnapshot) {`
`617`	`618`	`ArbiterGetSnapshot(DtmNextXid,&DtmSnapshot,&dtm->minXid);`
`618`	`619`	`}`
`619`	`620`	`DtmLastSnapshot=snapshot;`
`620`	`621`	`DtmMergeWithGlobalSnapshot(snapshot);`
	`622`	`+DtmCurcid=snapshot->curcid;`
`621`	`623`	`if (!IsolationUsesXactSnapshot())`
`622`	`624`	`{`
`623`	`625`	`/* Use single global snapshot during all transaction for repeatable read isolation level,`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ struct config`
`70`	`70`	`nWriters =10;`
`71`	`71`	`nIterations =1000;`
`72`	`72`	`nAccounts =1000;`
`73`		`- isolationLevel ="read committed";`
	`73`	`+ isolationLevel ="repeatable read";//"read committed";`
`74`	`74`	`}`
`75`	`75`	`};`
`76`	`76`

Comments

(0)