Commitea73b2b

committed

Use MtmIsBroadcast to prevent recursion in MtmProcessDDLCommand

1 parentf4ff5be commitea73b2bCopy full SHA for ea73b2b

File tree

-2

lines changed

-2

lines changed

Lines changed: 4 additions & 2 deletions

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

Comments

(0)