another take on MtmFilterTransaction behaviour

Author: kelvich

multimaster.c

@@ -3789,10 +3789,10 @@ bool MtmFilterTransaction(char* record, int size)
 	restart_lsn = origin_node == MtmReplicationNodeId ? end_lsn : origin_lsn;
 	if (Mtm->nodes[origin_node-1].restartLSN < restart_lsn) {
 		MTM_LOG2("[restartlsn] node %d: %llx -> %llx (MtmFilterTransaction)", MtmReplicationNodeId, Mtm->nodes[MtmReplicationNodeId-1].restartLSN, restart_lsn);
-		if (event != PGLOGICAL_PREPARE) {
-			/* Transactions can be prepared in different order, so to avoid loosing transactions we should not update restartLsn for them */
-			Mtm->nodes[origin_node-1].restartLSN = restart_lsn;
-		}
+		// if (event != PGLOGICAL_PREPARE) {
+		// 	/* Transactions can be prepared in different order, so to avoid loosing transactions we should not update restartLsn for them */
+		// 	Mtm->nodes[origin_node-1].restartLSN = restart_lsn;
+		// }
 	} else {
 		duplicate = true;
 	}

pglogical_apply.c

@@ -468,8 +468,8 @@ process_remote_message(StringInfo s)
 			}
 			if (Mtm->nodes[origin_node-1].restartLSN < msg->origin_lsn) { 
 				MTM_LOG1("Receive logical abort message for transaction %s from node %d: %llx < %llx", msg->gid, origin_node, Mtm->nodes[origin_node-1].restartLSN, msg->origin_lsn);
-				Mtm->nodes[origin_node-1].restartLSN = msg->origin_lsn;
-				replorigin_session_origin_lsn = msg->origin_lsn; 				
+				// Mtm->nodes[origin_node-1].restartLSN = msg->origin_lsn;
+				// replorigin_session_origin_lsn = msg->origin_lsn;
 				MtmRollbackPreparedTransaction(origin_node, msg->gid);
 			} else { 
 				if (msg->origin_lsn != INVALID_LSN) {