Commita0acd7b

authored and

committed

Use MtmIsBroadcast to prevent recursion in MtmProcessDDLCommand

1 parent535eae1 commita0acd7bCopy full SHA for a0acd7b

File tree

-2

lines changed

-2

lines changed

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -877,7 +877,9 @@ void MtmJoinTransaction(GlobalTransactionId* gtid, csn_t globalSnapshot)`
`877`	`877`	`}`
`878`	`878`	`if (!TransactionIdIsValid(gtid->xid)) {`
`879`	`879`	`/* In case of recovery InvalidTransactionId is passed */`
`880`		`-Assert(Mtm->status==MTM_RECOVERY);`
	`880`	`+if (Mtm->status!=MTM_RECOVERY) {`
	`881`	`+elog(PANIC,"Node %d tries to recover node %d which is in %s mode",MtmReplicationNode,MtmNodeId,MtmNodeStatusMnem[Mtm->status]);`
	`882`	`+}`
`881`	`883`	`}elseif (Mtm->status==MTM_RECOVERY) {`
`882`	`884`	`/* When recovery is completed we get normal transaction ID and switch to normal mode */`
`883`	`885`	`MtmRecoveryCompleted();`
`@@ -2340,7 +2342,7 @@ static bool MtmProcessDDLCommand(char const* queryString)`
`2340`	`2342`	`rel=heap_openrv_extended(rv,RowExclusiveLock, true);`
`2341`	`2343`
`2342`	`2344`	`if (rel==NULL) {`
`2343`		`-if (!IsTransactionBlock()) {`
	`2345`	`+if (!MtmIsBroadcast()) {`
`2344`	`2346`	`MtmBroadcastUtilityStmt(queryString, false);`
`2345`	`2347`	`return true;`
`2346`	`2348`	`}`

Comments

(0)