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 @@ -2802,14 +2802,14 @@ void MtmRollbackPreparedTransaction(char const* gid)
2802
2802
2803
2803
void MtmFinishPreparedTransaction (MtmTransState * ts , bool commit )
2804
2804
{
2805
- if (Mtm -> nodes [MtmNodeId - 1 ].originId == InvalidRepOriginId ) {
2806
- /* This dummy origin is used for local commits/aborts which should not be replicated */
2807
- Mtm -> nodes [MtmNodeId - 1 ].originId = replorigin_create (psprintf (MULTIMASTER_SLOT_PATTERN , MtmNodeId ));
2808
- }
2809
2805
Assert (ts -> votingCompleted );
2810
2806
Assert (!IsTransactionState ());
2811
2807
MtmResetTransaction ();
2812
2808
StartTransactionCommand ();
2809
+ if (Mtm -> nodes [MtmNodeId - 1 ].originId == InvalidRepOriginId ) {
2810
+ /* This dummy origin is used for local commits/aborts which should not be replicated */
2811
+ Mtm -> nodes [MtmNodeId - 1 ].originId = replorigin_create (psprintf (MULTIMASTER_SLOT_PATTERN , MtmNodeId ));
2812
+ }
2813
2813
MtmBeginSession (MtmNodeId );
2814
2814
MtmSetCurrentTransactionCSN (ts -> csn );
2815
2815
MtmSetCurrentTransactionGID (ts -> gid );
You can’t perform that action at this time.
0 commit comments