Commit0b8983c

committed

Handle new events in postgres_fdw

1 parent4381f69 commit0b8983cCopy full SHA for 0b8983c

File tree

+18

-1

lines changed

+18

-1

lines changed

Lines changed: 18 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -740,6 +740,20 @@ pgfdw_xact_callback(XactEvent event, void *arg)`
`740`	`740`	`HASH_SEQ_STATUSscan;`
`741`	`741`	`ConnCacheEntry*entry;`
`742`	`742`
	`743`	`+/* Do nothing for this events */`
	`744`	`+switch (event)`
	`745`	`+{`
	`746`	`+caseXACT_EVENT_START:`
	`747`	`+caseXACT_EVENT_POST_PREPARE:`
	`748`	`+caseXACT_EVENT_COMMIT_PREPARED:`
	`749`	`+caseXACT_EVENT_PRE_COMMIT_PREPARED:`
	`750`	`+caseXACT_EVENT_ABORT_PREPARED:`
	`751`	`+caseXACT_EVENT_COMMIT_COMMAND:`
	`752`	`+return;`
	`753`	`+default:`
	`754`	`+break;`
	`755`	`+}`
	`756`	`+`
`743`	`757`	`/* Quick exit if no connections were touched in this transaction. */`
`744`	`758`	`if (!xact_got_connection)`
`745`	`759`	`return;`
`@@ -902,8 +916,11 @@ pgfdw_xact_callback(XactEvent event, void *arg)`
`902`	`916`	`break;`
`903`	`917`
`904`	`918`	`caseXACT_EVENT_START:`
`905`		`-caseXACT_EVENT_ABORT_PREPARED:`
	`919`	`+caseXACT_EVENT_POST_PREPARE:`
`906`	`920`	`caseXACT_EVENT_COMMIT_PREPARED:`
	`921`	`+caseXACT_EVENT_PRE_COMMIT_PREPARED:`
	`922`	`+caseXACT_EVENT_ABORT_PREPARED:`
	`923`	`+caseXACT_EVENT_COMMIT_COMMAND:`
`907`	`924`	`break;`
`908`	`925`	`}`
`909`	`926`	`}`

Comments

(0)