Commite1647b9

authored and

committed

Restore apply memory context after SPI call

1 parentf644229 commite1647b9Copy full SHA for e1647b9

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -403,6 +403,7 @@ process_remote_message(StringInfo s)`
`403`	`403`	`if (rc<0) {`
`404`	`404`	`MTM_ELOG(ERROR,"Failed to execute utility statement %s",messageBody);`
`405`	`405`	`}else {`
	`406`	`+MemoryContextSwitchTo(MtmApplyContext);`
`406`	`407`	`PushActiveSnapshot(GetTransactionSnapshot());`
`407`	`408`
`408`	`409`	`if (MtmVacuumStmt!=NULL) {`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -550,7 +550,8 @@ pglogical_receiver_main(Datum main_arg)`
`550`	`550`	`if (stmt[0]=='Z'\|\| (stmt[0]=='M'&& (stmt[1]=='L'\|\|stmt[1]=='A'\|\|stmt[1]=='C'))) {`
`551`	`551`	`MTM_LOG3("Process '%c' message from %d",stmt[1],nodeId);`
`552`	`552`	`if (stmt[0]=='M'&&stmt[1]=='C') {/* concurrent DDL should be executed by parallel workers */`
`553`		`-MtmExecute(stmt,msg_len);`
	`553`	`+//MtmExecute(stmt, msg_len);`
	`554`	`+MtmExecutor(stmt,msg_len);`
`554`	`555`	`}else {`
`555`	`556`	`MtmExecutor(stmt,msg_len);/* all other messages can be processed by receiver itself */`
`556`	`557`	`}`

Comments

(0)