File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -450,7 +450,7 @@ begin_remote_xact(ConnCacheEntry *entry)
450450 elog (DEBUG3 , "starting remote transaction on connection %p" ,
451451 entry -> conn );
452452
453- if (TransactionIdIsValid (gxid ))
453+ if (UseTsDtmTransactions && TransactionIdIsValid (gxid ))
454454 {
455455 char stmt [64 ];
456456 snprintf (stmt , sizeof (stmt ), "select public.dtm_join_transaction(%d)" , gxid );
@@ -873,7 +873,9 @@ pgfdw_xact_callback(XactEvent event, void *arg)
873873 pgfdw_reject_incomplete_xact_state_change (entry );
874874
875875 /* Commit all remote transactions during pre-commit */
876- do_sql_send_command (entry -> conn , "COMMIT TRANSACTION" );
876+ entry -> changing_xact_state = true;
877+ do_sql_command (entry -> conn , "COMMIT TRANSACTION" );
878+ entry -> changing_xact_state = false;
877879 continue ;
878880
879881 case XACT_EVENT_PRE_PREPARE :
You can’t perform that action at this time.
0 commit comments