Commit9b1ae2b

authored and

committed

Reset latch

1 parent02789a0 commit9b1ae2bCopy full SHA for 9b1ae2b

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
`@@ -803,13 +803,13 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)`
`803`	`803`	`MtmUnlock();`
`804`	`804`	`MtmWatchdog();`
`805`	`805`	`result=WaitLatch(&MyProc->procLatch,WL_LATCH_SET\|WL_TIMEOUT,timeout);`
`806`		`-if (result&WL_TIMEOUT) {`
	`806`	`+if (result&WL_LATCH_SET) {`
	`807`	`+ResetLatch(&MyProc->procLatch);`
	`808`	`+}elseif (result&WL_TIMEOUT) {`
`807`	`809`	`if (MtmGetSystemTime()>deadline) {`
`808`	`810`	`MtmLock(LW_SHARED);`
`809`	`811`	`break;`
`810`	`812`	`}`
`811`		`-}else {`
`812`		`-ResetLatch(&MyProc->procLatch);`
`813`	`813`	`}`
`814`	`814`	`MtmLock(LW_SHARED);`
`815`	`815`	`}`

Comments

(0)