Commit883d363

committed

Reset latch

1 parent3a8bfdd commit883d363Copy full SHA for 883d363

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -776,9 +776,9 @@ static void MtmTransReceiver(Datum arg)`
`776`	`776`	`}`
`777`	`777`	`break;`
`778`	`778`	`caseMSG_PREPARED:`
	`779`	`+Assert(ts->nVotes<Mtm->nLiveNodes);`
`779`	`780`	`if (ts->status!=TRANSACTION_STATUS_ABORTED) {`
`780`	`781`	`Assert(ts->status==TRANSACTION_STATUS_IN_PROGRESS);`
`781`		`-Assert(ts->nVotes<Mtm->nLiveNodes);`
`782`	`782`	`if (msg->csn>ts->csn) {`
`783`	`783`	`ts->csn=msg->csn;`
`784`	`784`	`MtmSyncClock(ts->csn);`

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -804,13 +804,13 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`804`	`804`	`MtmUnlock();`
`805`	`805`	`MtmWatchdog();`
`806`	`806`	`result=WaitLatch(&MyProc->procLatch,WL_LATCH_SET\|WL_TIMEOUT,timeout);`
`807`		`-if (result&WL_TIMEOUT) {`
	`807`	`+if (result&WL_LATCH_SET) {`
	`808`	`+ResetLatch(&MyProc->procLatch);`
	`809`	`+}elseif (result&WL_TIMEOUT) {`
`808`	`810`	`if (MtmGetSystemTime()>deadline) {`
`809`	`811`	`MtmLock(LW_SHARED);`
`810`	`812`	`break;`
`811`	`813`	`}`
`812`		`-}else {`
`813`		`-ResetLatch(&MyProc->procLatch);`
`814`	`814`	`}`
`815`	`815`	`MtmLock(LW_SHARED);`
`816`	`816`	`}`

Comments

(0)