Commitd98e258

committed

allow replication session to be set in several backends

1 parent392ddde commitd98e258Copy full SHA for d98e258

File tree

-4

lines changed

-4

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -3813,7 +3813,7 @@ void MtmSetupReplicationHooks(struct PGLogicalHooks* hooks)`
`3813`	`3813`	`*/`
`3814`	`3814`	`voidMtmBeginSession(intnodeId)`
`3815`	`3815`	`{`
`3816`		`-MtmLockNode(nodeId,LW_EXCLUSIVE);`
	`3816`	`+//MtmLockNode(nodeId, LW_EXCLUSIVE);`
`3817`	`3817`	`Assert(replorigin_session_origin==InvalidRepOriginId);`
`3818`	`3818`	`replorigin_session_origin=Mtm->nodes[nodeId-1].originId;`
`3819`	`3819`	`Assert(replorigin_session_origin!=InvalidRepOriginId);`
`@@ -3833,9 +3833,9 @@ void MtmEndSession(int nodeId, bool unlock)`
`3833`	`3833`	`replorigin_session_origin_lsn=INVALID_LSN;`
`3834`	`3834`	`replorigin_session_origin_timestamp=0;`
`3835`	`3835`	`replorigin_session_reset();`
`3836`		`-if (unlock) {`
`3837`		`-MtmUnlockNode(nodeId);`
`3838`		`-}`
	`3836`	`+//if (unlock) {`
	`3837`	`+//MtmUnlockNode(nodeId);`
	`3838`	`+//}`
`3839`	`3839`	`MTM_LOG3("%d: End reset replorigin session: %d",MyProcPid,replorigin_session_origin);`
`3840`	`3840`	`}`
`3841`	`3841`	`}`

Comments

(0)