More correct rollback of hanged replicated transactions

Author: knizhnik

arbiter.c

@@ -347,7 +347,7 @@ static void MtmSendHeartbeat()
 		{ 
 			size_t rc = send(sockets[i], &msg, sizeof(msg), 0);
 			if ((size_t)rc != sizeof(msg)) { 
-				elog(LOG, "Failed to send heartbeat to node %d: %d", i, errno);
+				elog(LOG, "Failed to send heartbeat to node %d: %d", i+1, errno);
 			}
 		}
 	}

multimaster.c

@@ -1063,7 +1063,7 @@ void MtmWakeUpBackend(MtmTransState* ts)
 void MtmAbortTransaction(MtmTransState* ts)
 {	
 	if (ts->status != TRANSACTION_STATUS_ABORTED) { 
-		MTM_LOG1("Rollback active transaction %d:%d", ts->gtid.node, ts->gtid.xid);
+		MTM_LOG1("Rollback active transaction %d:%d (local xid %d)", ts->gtid.node, ts->gtid.xid, ts->xid);
 		ts->status = TRANSACTION_STATUS_ABORTED;
 		MtmAdjustSubtransactions(ts);
 		Mtm->nActiveTransactions -= 1;
@@ -1387,8 +1387,8 @@ bool MtmRefreshClusterStatus(bool nowait)
 					MtmAbortTransaction(ts);
 					MtmWakeUpBackend(ts);
 				}
-			} else if (BIT_CHECK(disabled, ts->gtid.node-1)) { // coordinator of transaction is on disabled node
-				if (ts->status != TRANSACTION_STATUS_ABORTED) {
+			} else if (TransactionIdIsValid(ts->gtid.xid) && BIT_CHECK(disabled, ts->gtid.node-1)) { // coordinator of transaction is on disabled node
+				if (ts->gid[0] && ts->status != TRANSACTION_STATUS_ABORTED) {
 					MtmAbortTransaction(ts);
 					FinishPreparedTransaction(ts->gid, false);
 				}
@@ -1457,8 +1457,8 @@ void MtmOnNodeDisconnect(int nodeId)
 						MtmAbortTransaction(ts);
 						MtmWakeUpBackend(ts);
 					}
-				} else if (ts->gtid.node == nodeId) { //coordinator of transaction is on disabled node
-					if (ts->status != TRANSACTION_STATUS_ABORTED) {
+				} else if (TransactionIdIsValid(ts->gtid.xid) && ts->gtid.node == nodeId) { //coordinator of transaction is on disabled node
+					if (ts->gid[0] && ts->status != TRANSACTION_STATUS_ABORTED) {
 						MtmAbortTransaction(ts);
 						FinishPreparedTransaction(ts->gid, false);
 					}