let receiver work in synchronous_twophase mode

Author: kelvich

multimaster.c

@@ -1775,7 +1775,7 @@ static void	MtmLoadPreparedTransactions(void)
 			MtmActivateTransaction(ts);
 			ts->status = strcmp(pxacts[i].state_3pc, MULTIMASTER_PRECOMMITTED) == 0 ? TRANSACTION_STATUS_UNKNOWN : TRANSACTION_STATUS_IN_PROGRESS;
 			ts->isLocal = true;
-			ts->isPrepared = true;
+			ts->isPrepared = strcmp(pxacts[i].state_3pc, MULTIMASTER_PRECOMMITTED) == 0;
 			ts->isPinned = false;
 			ts->snapshot = INVALID_CSN;
 			ts->isTwoPhase = false;
@@ -2074,15 +2074,15 @@ MtmPollStatusOfPreparedTransactions(bool majorMode)
 	{
 		MtmTransState *ts = MtmGetActiveTransaction(cur);
 
-		// MTM_LOG1("X_MtmPollStatusOfPreparedTransactions %s, major=%d, status=%d, isPrepared=%d, valid=%d, completed=%d", ts->gid, majorMode, ts->status, ts->isPrepared, TransactionIdIsValid(ts->gtid.xid), ts->votingCompleted);
+		MTM_LOG1("X_MtmPollStatusOfPreparedTransactions %s, major=%d, status=%d, isPrepared=%d, valid=%d, completed=%d", ts->gid, majorMode, ts->status, ts->isPrepared, TransactionIdIsValid(ts->gtid.xid), ts->votingCompleted);
 
 		if (TransactionIdIsValid(ts->gtid.xid)
 			&& ts->votingCompleted /* If voting is not yet completed, then there is some backend coordinating this transaction */
 			&& (ts->status == TRANSACTION_STATUS_UNKNOWN || ts->status == TRANSACTION_STATUS_IN_PROGRESS))
 		{
 			Assert(ts->gid[0]);
 
-			// MTM_LOG1("MtmPollStatusOfPreparedTransactions %s, major=%d, status=%d, isPrepared=%d", ts->gid, majorMode, ts->status, ts->isPrepared);
+			MTM_LOG1("MtmPollStatusOfPreparedTransactions %s, major=%d, status=%d, isPrepared=%d", ts->gid, majorMode, ts->status, ts->isPrepared);
 
 			if (majorMode)
 			{

pglogical_receiver.c

@@ -303,7 +303,7 @@ pglogical_receiver_main(Datum main_arg)
 		// 	synchronous_twophase = false;
 		// else
 		// 	synchronous_twophase = true;
-		synchronous_twophase = false;
+		synchronous_twophase = true;
 
 		if (mode == REPLMODE_EXIT)
 		{

tests2/docker-entrypoint.sh

@@ -51,15 +51,15 @@ if [ "$1" = 'postgres' ]; then
 			listen_addresses='*' 
 			max_prepared_transactions = 100
 			synchronous_commit = on
-			fsync = on
+			fsync = off
 			wal_level = logical
 			max_worker_processes = 30
 			max_replication_slots = 10
 			max_wal_senders = 10
 			shared_preload_libraries = 'multimaster'
 			default_transaction_isolation = 'repeatable read'
 			log_line_prefix = '%m [%p]: '
-			wal_writer_delay = 1ms
+			wal_writer_delay = 500ms
 			# log_statement = all
 
 			multimaster.max_nodes = 3