Commit436af24

committed

Ensure backwards compatibility for GetStableLatestTransactionId()

1 parent2c1382d commit436af24Copy full SHA for 436af24

File tree

-6

lines changed

-6

lines changed

Lines changed: 8 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -392,11 +392,10 @@ GetCurrentTransactionIdIfAny(void)`
`392`	`392`	`returnCurrentTransactionState->transactionId;`
`393`	`393`	`}`
`394`	`394`
`395`		`-`
`396`	`395`	`/*`
`397`		`- *GetStableLatestTransactionIdIfAny`
	`396`	`+ *GetStableLatestTransactionId`
`398`	`397`	`*`
`399`		`- * Get thelatestXID once and then return same value for rest of transaction.`
	`398`	`+ * Get the XID once and then return same value for rest of transaction.`
`400`	`399`	`* Acts as a useful reference point for maintenance tasks.`
`401`	`400`	`*/`
`402`	`401`	`TransactionId`
`@@ -405,13 +404,16 @@ GetStableLatestTransactionId(void)`
`405`	`404`	`staticLocalTransactionIdlxid=InvalidLocalTransactionId;`
`406`	`405`	`staticTransactionIdstablexid=InvalidTransactionId;`
`407`	`406`
`408`		`-if (lxid!=MyProc->lxid\|\|`
`409`		`-!TransactionIdIsValid(stablexid))`
	`407`	`+if (lxid!=MyProc->lxid)`
`410`	`408`	`{`
`411`	`409`	`lxid=MyProc->lxid;`
`412`		`-stablexid=ReadNewTransactionId();`
	`410`	`+stablexid=GetTopTransactionIdIfAny();`
	`411`	`+if (!TransactionIdIsValid(stablexid))`
	`412`	`+stablexid=ReadNewTransactionId();`
`413`	`413`	`}`
`414`	`414`
	`415`	`+Assert(TransactionIdIsValid(stablexid));`
	`416`	`+`
`415`	`417`	`returnstablexid;`
`416`	`418`	`}`
`417`	`419`

Comments

(0)