@@ -2801,14 +2801,14 @@ void MtmRollbackPreparedTransaction(char const* gid)
28012801
28022802void MtmFinishPreparedTransaction (MtmTransState * ts ,bool commit )
28032803{
2804- if (Mtm -> nodes [MtmNodeId - 1 ].originId == InvalidRepOriginId ) {
2805- /* This dummy origin is used for local commits/aborts which should not be replicated */
2806- Mtm -> nodes [MtmNodeId - 1 ].originId = replorigin_create (psprintf (MULTIMASTER_SLOT_PATTERN ,MtmNodeId ));
2807- }
28082804Assert (ts -> votingCompleted );
28092805Assert (!IsTransactionState ());
28102806MtmResetTransaction ();
28112807StartTransactionCommand ();
2808+ if (Mtm -> nodes [MtmNodeId - 1 ].originId == InvalidRepOriginId ) {
2809+ /* This dummy origin is used for local commits/aborts which should not be replicated */
2810+ Mtm -> nodes [MtmNodeId - 1 ].originId = replorigin_create (psprintf (MULTIMASTER_SLOT_PATTERN ,MtmNodeId ));
2811+ }
28122812MtmBeginSession (MtmNodeId );
28132813MtmSetCurrentTransactionCSN (ts -> csn );
28142814MtmSetCurrentTransactionGID (ts -> gid );