File tree 1 file changed +9
-3
lines changed 1 file changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -1000,10 +1000,16 @@ static void MtmReceiver(Datum arg)
1000
1000
if ((ts -> participantsMask & ~Mtm -> disabledNodeMask & ~ts -> votedMask ) == 0 ) {
1001
1001
MTM_ELOG (LOG , "Commit transaction %s because it is prepared at all live nodes" , msg -> gid );
1002
1002
1003
- replorigin_session_origin = DoNotReplicateId ;
1003
+ ts -> status = msg -> status ;
1004
+ MtmWakeUpBackend (ts );
1005
+ // replorigin_session_origin = DoNotReplicateId;
1004
1006
TXFINISH ("%s COMMIT, MSG_POLL_STATUS" , msg -> gid );
1005
- MtmFinishPreparedTransaction (ts , true);
1006
- replorigin_session_origin = InvalidRepOriginId ;
1007
+ // MtmUnlock();
1008
+ // LWLockAcquire(TwoPhaseStateLock, LW_EXCLUSIVE);
1009
+ // MtmFinishPreparedTransaction(ts, true);
1010
+ // LWLockRelease(TwoPhaseStateLock);
1011
+ // MtmLock(LW_EXCLUSIVE);
1012
+ // replorigin_session_origin = InvalidRepOriginId;
1007
1013
} else {
1008
1014
MTM_LOG1 ("Receive response for transaction %s -> %s, participants=%llx, voted=%llx" ,
1009
1015
msg -> gid , MtmTxnStatusMnem [msg -> status ], ts -> participantsMask , ts -> votedMask );
You can’t perform that action at this time.
0 commit comments