Commitfce52d2

committed

Always request global snalshot to correctly implement read-committed

1 parent0cb3dee commitfce52d2Copy full SHA for fce52d2

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,6 @@ static TransactionId DtmNextXid;`
`115`	`115`	`staticSnapshotDataDtmSnapshot= {HeapTupleSatisfiesMVCC };`
`116`	`116`	`staticboolDtmHasGlobalSnapshot;`
`117`	`117`	`staticintDtmLocalXidReserve;`
`118`		`-staticintDtmCurcid;`
`119`	`118`	`staticSnapshotDtmLastSnapshot;`
`120`	`119`	`staticTransactionManagerDtmTM= {`
`121`	`120`	`DtmGetTransactionStatus,`
`@@ -617,11 +616,9 @@ static Snapshot DtmGetSnapshot(Snapshot snapshot)`
`617`	`616`	`{`
`618`	`617`	`if (TransactionIdIsValid(DtmNextXid)&&snapshot!=&CatalogSnapshotData)`
`619`	`618`	`{`
`620`		`-intcid=GetCurrentCommandId(false);`
`621`		`-if (!DtmHasGlobalSnapshot&& (snapshot!=DtmLastSnapshot\|\|DtmCurcid!=cid) {`
	`619`	`+if (!DtmHasGlobalSnapshot) {`
`622`	`620`	`DtmGlobalGetSnapshot(DtmNextXid,&DtmSnapshot,&dtm->minXid);`
`623`	`621`	`}`
`624`		`-DtmCurcid=cid;`
`625`	`622`	`DtmLastSnapshot=snapshot;`
`626`	`623`	`DtmMergeWithGlobalSnapshot(snapshot);`
`627`	`624`	`if (!IsolationUsesXactSnapshot())`

Comments

(0)