Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit d98e258

Browse files
committed
allow replication session to be set in several backends
1 parent 392ddde commit d98e258

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

multimaster.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3813,7 +3813,7 @@ void MtmSetupReplicationHooks(struct PGLogicalHooks* hooks)
38133813
*/
38143814
void MtmBeginSession(int nodeId)
38153815
{
3816-
MtmLockNode(nodeId, LW_EXCLUSIVE);
3816+
// MtmLockNode(nodeId, LW_EXCLUSIVE);
38173817
Assert(replorigin_session_origin == InvalidRepOriginId);
38183818
replorigin_session_origin = Mtm->nodes[nodeId-1].originId;
38193819
Assert(replorigin_session_origin != InvalidRepOriginId);
@@ -3833,9 +3833,9 @@ void MtmEndSession(int nodeId, bool unlock)
38333833
replorigin_session_origin_lsn = INVALID_LSN;
38343834
replorigin_session_origin_timestamp = 0;
38353835
replorigin_session_reset();
3836-
if (unlock) {
3837-
MtmUnlockNode(nodeId);
3838-
}
3836+
// if (unlock) {
3837+
// MtmUnlockNode(nodeId);
3838+
// }
38393839
MTM_LOG3("%d: End reset replorigin session: %d", MyProcPid, replorigin_session_origin);
38403840
}
38413841
}

0 commit comments

Comments
 (0)