@@ -1111,38 +1111,31 @@ MtmPostPrepareTransaction(MtmCurrentTrans* x)
11111111MtmLock (LW_EXCLUSIVE );
11121112ts = (MtmTransState * )hash_search (MtmXid2State ,& x -> xid ,HASH_FIND ,NULL );
11131113Assert (ts != NULL );
1114- //if (x->gid[0]) MTM_LOG1("Preparing transaction %d (%s) at %ld", x->xid, x->gid, MtmGetCurrentTime());
11151114if (!MtmIsCoordinator (ts )|| Mtm -> status == MTM_RECOVERY ) {
1116- MTM_TXTRACE (x ,"recovery?" );
11171115MTM_LOG3 ("Preparing transaction %d (%s) at %ld" ,x -> xid ,x -> gid ,MtmGetCurrentTime ());
11181116Assert (x -> gid [0 ]);
11191117ts -> votingCompleted = true;
1120- MTM_TXTRACE (x ,"recovery? 1" );
11211118if (Mtm -> status != MTM_RECOVERY /* || Mtm->recoverySlot != MtmReplicationNodeId*/ ) {
1122- MTM_TXTRACE (x ,"recovery? 2" );
11231119MtmSend2PCMessage (ts ,MSG_PREPARED );/* send notification to coordinator */
11241120if (!MtmUseDtm ) {
11251121ts -> status = TRANSACTION_STATUS_UNKNOWN ;
11261122}
11271123}else {
1128- MTM_TXTRACE (x ,"recovery? 3" );
11291124ts -> status = TRANSACTION_STATUS_UNKNOWN ;
11301125}
1131- MTM_TXTRACE (x ,"recovery? 4" );
11321126MtmUnlock ();
1133- MTM_TXTRACE (x ,"recovery? 5" );
11341127MtmResetTransaction ();
1135- MTM_TXTRACE (x ,"recovery? 6" );
1136- }else if (!ts -> isLocal ) {
1137- MTM_TXTRACE (x ,"not recovery?" );
1138- Mtm2PCVoting (x ,ts );
1128+ }else {
1129+ if (!ts -> isLocal ) {
1130+ Mtm2PCVoting (x ,ts );
1131+ }else {
1132+ ts -> votingCompleted = true;
1133+ }
11391134MtmUnlock ();
11401135if (x -> isTwoPhase ) {
11411136MtmResetTransaction ();
11421137}
11431138}
1144- MTM_TXTRACE (x ,"recovery? 7" );
1145- //if (x->gid[0]) MTM_LOG1("Prepared transaction %d (%s) csn=%ld at %ld: %d", x->xid, x->gid, ts->csn, MtmGetCurrentTime(), ts->status);
11461139if (Mtm -> inject2PCError == 3 ) {
11471140Mtm -> inject2PCError = 0 ;
11481141elog (ERROR ,"ERROR INJECTION for transaction %s (%lu)" ,x -> gid , (long )x -> xid );
@@ -1182,6 +1175,8 @@ MtmPreCommitPreparedTransaction(MtmCurrentTrans* x)
11821175MtmLock (LW_EXCLUSIVE );
11831176
11841177Mtm2PCVoting (x ,ts );
1178+ }else {
1179+ ts -> status = TRANSACTION_STATUS_UNKNOWN ;
11851180}
11861181
11871182x -> xid = ts -> xid ;