Commitabb6801

authored and

committed

Enable interrupts in Mtm2PCVoting

1 parent681372d commitabb6801Copy full SHA for abb6801

File tree

-0

lines changed

-0

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1181,9 +1181,12 @@ Mtm2PCVoting(MtmCurrentTrans* x, MtmTransState* ts)`
`1181`	`1181`	`timestamp_tstart=MtmGetSystemTime();`
`1182`	`1182`	`timestamp_tdeadline=start+timeout;`
`1183`	`1183`	`timestamp_tnow;`
	`1184`	`+uint32SaveCancelHoldoffCount=QueryCancelHoldoffCount;`
`1184`	`1185`
`1185`	`1186`	`Assert(ts->csn>ts->snapshot);`
`1186`	`1187`
	`1188`	`+QueryCancelHoldoffCount=0;`
	`1189`	`+`
`1187`	`1190`	`/* Wait votes from all nodes until: */`
`1188`	`1191`	`while (!MtmVotingCompleted(ts))`
`1189`	`1192`	`{`
`@@ -1212,6 +1215,8 @@ Mtm2PCVoting(MtmCurrentTrans* x, MtmTransState* ts)`
`1212`	`1215`	`}`
`1213`	`1216`	`}`
`1214`	`1217`	`}`
	`1218`	`+QueryCancelHoldoffCount=SaveCancelHoldoffCount;`
	`1219`	`+`
`1215`	`1220`	`if (ts->status!=TRANSACTION_STATUS_ABORTED&& !ts->votingCompleted) {`
`1216`	`1221`	`if (ts->isPrepared) {`
`1217`	`1222`	`MTM_ELOG(WARNING,"Commit of distributed transaction %s is suspended because node is switched to %s mode",ts->gid,MtmNodeStatusMnem[Mtm->status]);`

Comments

(0)