Commit5ee48f4

committed

Check for transaction status before waiting latch

1 parent9e7d476 commit5ee48f4Copy full SHA for 5ee48f4

File tree

-1

lines changed

-1

lines changed

Lines changed: 6 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -801,8 +801,13 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`801`	`801`	`intnConfigChanges=Mtm->nConfigChanges;`
`802`	`802`	`/* wait votes from all nodes */`
`803`	`803`	`while (!ts->votingCompleted) {`
`804`		`-MtmWatchdog();`
`805`	`804`	`MtmUnlock();`
	`805`	`+MtmWatchdog();`
	`806`	`+if (ts->status==TRANSACTION_STATUS_ABORTED) {`
	`807`	`+elog(WARNING,"Transaction %d(%s) is aborted by watchdog",x->xid,x->gid);`
	`808`	`+x->status=TRANSACTION_STATUS_ABORTED;`
	`809`	`+return;`
	`810`	`+}`
`806`	`811`	`result=WaitLatch(&MyProc->procLatch,WL_LATCH_SET\|WL_TIMEOUT,timeout);`
`807`	`812`	`if (result&WL_LATCH_SET) {`
`808`	`813`	`ResetLatch(&MyProc->procLatch);`

Comments

(0)