Commitce2e104

committed

fixup for previous commit

1 parentb9e89b5 commitce2e104Copy full SHA for ce2e104

File tree

-4

lines changed

-4

lines changed

Lines changed: 6 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -367,14 +367,16 @@ DtmAdjustOldestXid()`
`367`	`367`	`}`
`368`	`368`
`369`	`369`	`staticvoid`
`370`		`-DtmInitGlobalXmin(TransactionIdxid)`
	`370`	`+DtmInitGlobalXmin(TransactionIdxmin)`
`371`	`371`	`{`
`372`	`372`	`TransactionIdcurrent_xmin;`
`373`	`373`
	`374`	`+Assert(TransactionIdIsValid(xmin));`
	`375`	`+`
`374`	`376`	`/* Better change to CAS */`
`375`	`377`	`current_xmin=ProcArrayGetGlobalSnapshotXmin();`
`376`	`378`	`if (!TransactionIdIsValid(current_xmin))`
`377`		`-ProcArraySetGlobalSnapshotXmin(xid);`
	`379`	`+ProcArraySetGlobalSnapshotXmin(xmin);`
`378`	`380`	`}`
`379`	`381`
`380`	`382`
`@@ -515,7 +517,7 @@ DtmLocalExtend(GlobalTransactionId gtid)`
`515`	`517`	`SpinLockRelease(&local->lock);`
`516`	`518`	`}`
`517`	`519`	`x->is_global= true;`
`518`		`-DtmInitGlobalXmin(x->xid);`
	`520`	`+DtmInitGlobalXmin(TransactionXmin);`
`519`	`521`	`returnx->snapshot;`
`520`	`522`	`}`
`521`	`523`
`@@ -549,7 +551,7 @@ DtmLocalAccess(DtmCurrentTrans * x, GlobalTransactionId gtid, cid_t global_cid)`
`549`	`551`	`{`
`550`	`552`	`elog(ERROR,"Too old snapshot: requested %ld, current %ld",global_cid,local_cid);`
`551`	`553`	`}`
`552`		`-DtmInitGlobalXmin(x->xid);`
	`554`	`+DtmInitGlobalXmin(TransactionXmin);`
`553`	`555`	`returnglobal_cid;`
`554`	`556`	`}`
`555`	`557`

Comments

(0)