Commitf90c8cd

committed

respect new changing_xact_state variable

1 parentb99dd9c commitf90c8cdCopy full SHA for f90c8cd

File tree

-2

lines changed

-2

lines changed

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -450,7 +450,7 @@ begin_remote_xact(ConnCacheEntry *entry)`
`450`	`450`	`elog(DEBUG3,"starting remote transaction on connection %p",`
`451`	`451`	`entry->conn);`
`452`	`452`
`453`		`-if (TransactionIdIsValid(gxid))`
	`453`	`+if (UseTsDtmTransactions&&TransactionIdIsValid(gxid))`
`454`	`454`	`{`
`455`	`455`	`charstmt[64];`
`456`	`456`	`snprintf(stmt,sizeof(stmt),"select public.dtm_join_transaction(%d)",gxid);`
`@@ -873,7 +873,9 @@ pgfdw_xact_callback(XactEvent event, void *arg)`
`873`	`873`	`pgfdw_reject_incomplete_xact_state_change(entry);`
`874`	`874`
`875`	`875`	`/* 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;`
`877`	`879`	`continue;`
`878`	`880`
`879`	`881`	`caseXACT_EVENT_PRE_PREPARE:`

Comments

(0)