File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -2801,14 +2801,14 @@ void MtmRollbackPreparedTransaction(char const* gid)
2801
2801
2802
2802
void MtmFinishPreparedTransaction (MtmTransState * ts , bool commit )
2803
2803
{
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
- }
2808
2804
Assert (ts -> votingCompleted );
2809
2805
Assert (!IsTransactionState ());
2810
2806
MtmResetTransaction ();
2811
2807
StartTransactionCommand ();
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
+ }
2812
2812
MtmBeginSession (MtmNodeId );
2813
2813
MtmSetCurrentTransactionCSN (ts -> csn );
2814
2814
MtmSetCurrentTransactionGID (ts -> gid );
You can’t perform that action at this time.
0 commit comments