Commitd176c85

committed

Update top memory context

1 parent2edd41b commitd176c85Copy full SHA for d176c85

File tree

-3

lines changed

-3

lines changed

Lines changed: 2 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,6 @@ static void process_remote_insert(StringInfo s, Relation rel);`
`79`	`79`	`staticvoidprocess_remote_update(StringInfos,Relationrel);`
`80`	`80`	`staticvoidprocess_remote_delete(StringInfos,Relationrel);`
`81`	`81`
`82`		`-staticMemoryContextTopContext;`
`83`	`82`	`staticboolGucAltered;/* transaction is setting some GUC variables */`
`84`	`83`
`85`	`84`	`/*`
`@@ -662,7 +661,7 @@ process_remote_commit(StringInfo in)`
`662`	`661`	`casePGLOGICAL_PREPARE:`
`663`	`662`	`{`
`664`	`663`	`Assert(IsTransactionState()&&TransactionIdIsValid(MtmGetCurrentTransactionId()));`
`665`		`-gid=pstrdup(pq_getmsgstring(in));/* in case of spilling large transaction to the file, message body will be deallocated, so copy it */`
	`664`	`+gid=pq_getmsgstring(in);`
`666`	`665`	`if (MtmExchangeGlobalTransactionStatus(gid,TRANSACTION_STATUS_IN_PROGRESS)==TRANSACTION_STATUS_ABORTED) {`
`667`	`666`	`MTM_LOG1("Avoid prepare of previously aborted global transaction %s",gid);`
`668`	`667`	`AbortCurrentTransaction();`
`@@ -1047,7 +1046,7 @@ void MtmExecutor(void* work, size_t size)`
`1047`	`1046`	`ALLOCSET_DEFAULT_INITSIZE,`
`1048`	`1047`	`ALLOCSET_DEFAULT_MAXSIZE);`
`1049`	`1048`	`}`
`1050`		`-TopContext=MemoryContextSwitchTo(MtmApplyContext);`
	`1049`	`+TopMemoryContext=MemoryContextSwitchTo(MtmApplyContext);`
`1051`	`1050`	`replorigin_session_origin=InvalidRepOriginId;`
`1052`	`1051`	`PG_TRY();`
`1053`	`1052`	`{`

Comments

(0)