Restpore assert in arbiter on receiving PREPARE in aborted state

Author: knizhnik

arbiter.c

@@ -915,15 +915,17 @@ static void MtmTransReceiver(Datum arg)
 					} else { 
 						switch (msg->code) { 
 						  case MSG_PREPARE:
-							if (ts->status == TRANSACTION_STATUS_IN_PROGRESS) { 
-								ts->status = TRANSACTION_STATUS_UNKNOWN;
-								ts->csn = MtmAssignCSN();
-								MtmAdjustSubtransactions(ts);
-								MtmSendNotificationMessage(ts, MSG_PREPARED);
+							Assert(ts->status == TRANSACTION_STATUS_IN_PROGRESS);
+							ts->status = TRANSACTION_STATUS_UNKNOWN;
+							ts->csn = MtmAssignCSN();
+							MtmAdjustSubtransactions(ts);
+							MtmSendNotificationMessage(ts, MSG_PREPARED);
+#if 0							
 							} else {
 								Assert(ts->status == TRANSACTION_STATUS_ABORTED);
 								MtmSendNotificationMessage(ts, MSG_ABORTED);
 							}
+#endif
 							break;
 						  default:
 							Assert(false);

multimaster.c

@@ -797,7 +797,7 @@ void MtmWatchdog(void)
 			if (Mtm->nodes[i].lastHeartbeat != 0
 				&& now > Mtm->nodes[i].lastHeartbeat + MSEC_TO_USEC(MtmHeartbeatRecvTimeout)) 
 			{ 
-				elog(WARNING, "Heartbeat was received from node %d during %d msec", 
+				elog(WARNING, "Heartbeat is not received from node %d during %d msec", 
 					 i+1, (int)USEC_TO_MSEC(now - Mtm->nodes[i].lastHeartbeat));
 				MtmOnNodeDisconnect(i+1);				
 			}