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

Commit da75f3b

Browse files
knizhnikkelvich
authored andcommitted
Use DoNotReplicateId to avoid replication of local commits/aborts
1 parent 0329690 commit da75f3b

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

multimaster.c

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2080,6 +2080,7 @@ static void MtmInitialize()
20802080
Mtm->nodes[i].originId = InvalidRepOriginId;
20812081
Mtm->nodes[i].timeline = 0;
20822082
}
2083+
Mtm->nodes[MtmNodeId-1].originId = DoNotReplicateId;
20832084
PGSemaphoreCreate(&Mtm->sendSemaphore);
20842085
PGSemaphoreReset(&Mtm->sendSemaphore);
20852086
SpinLockInit(&Mtm->spinlock);
@@ -2806,10 +2807,12 @@ void MtmFinishPreparedTransaction(MtmTransState* ts, bool commit)
28062807
Assert(!IsTransactionState());
28072808
MtmResetTransaction();
28082809
StartTransactionCommand();
2810+
#if 0
28092811
if (Mtm->nodes[MtmNodeId-1].originId == InvalidRepOriginId) {
28102812
/* This dummy origin is used for local commits/aborts which should not be replicated */
28112813
Mtm->nodes[MtmNodeId-1].originId = replorigin_create(psprintf(MULTIMASTER_SLOT_PATTERN, MtmNodeId));
28122814
}
2815+
#endif
28132816
MtmBeginSession(MtmNodeId);
28142817
MtmSetCurrentTransactionCSN(ts->csn);
28152818
MtmSetCurrentTransactionGID(ts->gid);

0 commit comments

Comments
 (0)