Commitf209c5b

Andrei Krichinin

committed

connect backend before start receiver loop

1 parent946a0e3 commitf209c5bCopy full SHA for f209c5b

File tree

-0

lines changed

-0

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1498,6 +1498,8 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)`
`1498`	`1498`	`#else`
`1499`	`1499`	`pg_atomic_write_u64(&MyProc->xmin,InvalidTransactionId);`
`1500`	`1500`	`#endif`
	`1501`	`+dmq_receiver_recreate_mqs(&dmq_state->receivers[receiver_id],`
	`1502`	`+segs,mq_handles);`
`1501`	`1503`
`1502`	`1504`	`for (;;)`
`1503`	`1505`	`{`

Comments

(0)