File tree Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -1077,17 +1077,10 @@ static void MtmReceiver(Datum arg)
10771077 if (ts -> isTwoPhase ) {
10781078 MtmWakeUpBackend (ts );
10791079 } else if (MtmUseDtm ) {
1080- ts -> votedMask = 0 ;
10811080 MTM_TXTRACE (ts , "MtmTransReceiver send MSG_PRECOMMIT" );
10821081 Assert (replorigin_session_origin == InvalidRepOriginId );
1083- MTM_LOG2 ("SetPreparedTransactionState for %s" , ts -> gid );
1084- MtmUnlock ();
1085- MtmResetTransaction ();
1086- StartTransactionCommand ();
1087- SetPreparedTransactionState (ts -> gid , MULTIMASTER_PRECOMMITTED );
1088- CommitTransactionCommand ();
1089- Assert (!MtmTransIsActive ());
1090- MtmLock (LW_EXCLUSIVE );
1082+ ts -> isPrepared = false;
1083+ SetLatch (& ProcGlobal -> allProcs [ts -> procno ].procLatch );
10911084 } else {
10921085 ts -> status = TRANSACTION_STATUS_UNKNOWN ;
10931086 MtmWakeUpBackend (ts );
You can’t perform that action at this time.
0 commit comments