Commit515af13

committed

Do not call SetPreparedTransactionState() from master

1 parentc5d6c7c commit515af13Copy full SHA for 515af13

File tree

-9

lines changed

-9

lines changed

Lines changed: 2 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -1077,17 +1077,10 @@ static void MtmReceiver(Datum arg)`
`1077`	`1077`	`if (ts->isTwoPhase) {`
`1078`	`1078`	`MtmWakeUpBackend(ts);`
`1079`	`1079`	`}elseif (MtmUseDtm) {`
`1080`		`-ts->votedMask=0;`
`1081`	`1080`	`MTM_TXTRACE(ts,"MtmTransReceiver send MSG_PRECOMMIT");`
`1082`	`1081`	`Assert(replorigin_session_origin==InvalidRepOriginId);`
`1083`		`-MTM_LOG2("SetPreparedTransactionState for %s",ts->gid);`
`1084`		`-MtmUnlock();`
`1085`		`-MtmResetTransaction();`
`1086`		`-StartTransactionCommand();`
`1087`		`-SetPreparedTransactionState(ts->gid,MULTIMASTER_PRECOMMITTED);`
`1088`		`-CommitTransactionCommand();`
`1089`		`-Assert(!MtmTransIsActive());`
`1090`		`-MtmLock(LW_EXCLUSIVE);`
	`1082`	`+ts->isPrepared= false;`
	`1083`	`+SetLatch(&ProcGlobal->allProcs[ts->procno].procLatch);`
`1091`	`1084`	`}else {`
`1092`	`1085`	`ts->status=TRANSACTION_STATUS_UNKNOWN;`
`1093`	`1086`	`MtmWakeUpBackend(ts);`

Comments

(0)