Use DoNotReplicateId to avoid replication of local commits/aborts

knizhnik · kelvich · commit da75f3b276fb · 2017-11-13T02:17:33.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -2080,6 +2080,7 @@ static void MtmInitialize()
 			Mtm->nodes[i].originId = InvalidRepOriginId;
 			Mtm->nodes[i].timeline = 0;
 		}
+		Mtm->nodes[MtmNodeId-1].originId = DoNotReplicateId;
 		PGSemaphoreCreate(&Mtm->sendSemaphore);
 		PGSemaphoreReset(&Mtm->sendSemaphore);
 		SpinLockInit(&Mtm->spinlock);
@@ -2806,10 +2807,12 @@ void MtmFinishPreparedTransaction(MtmTransState* ts, bool commit)
 	Assert(!IsTransactionState());
 	MtmResetTransaction();
 	StartTransactionCommand();
+#if 0
 	if (Mtm->nodes[MtmNodeId-1].originId == InvalidRepOriginId) { 
 		/* This dummy origin is used for local commits/aborts which should not be replicated */
 		Mtm->nodes[MtmNodeId-1].originId = replorigin_create(psprintf(MULTIMASTER_SLOT_PATTERN, MtmNodeId));
 	}
+#endif
 	MtmBeginSession(MtmNodeId);
 	MtmSetCurrentTransactionCSN(ts->csn);
 	MtmSetCurrentTransactionGID(ts->gid);
