properly set non-blocking mode in dmq-sender

kelvich · kelvich · commit fab1df469c27 · 2019-03-27T12:38:04.000+03:00
diff --git a/src/dmq.c b/src/dmq.c
@@ -676,6 +676,7 @@ dmq_sender_main(Datum main_arg)
 					{
 						conns[conn_id].state = Active;
 						DeleteWaitEvent(set, event.pos);
+						PQsetnonblocking(conns[conn_id].pgconn, 1);
 
 						mtm_log(DmqStateFinal,
 								"[DMQ] Connected to %s",

Original file line number	Diff line number	Diff line change
`@@ -676,6 +676,7 @@ dmq_sender_main(Datum main_arg)`
`676`	`676`	`{`
`677`	`677`	`conns[conn_id].state = Active;`
`678`	`678`	`DeleteWaitEvent(set, event.pos);`
	`679`	`+ PQsetnonblocking(conns[conn_id].pgconn, 1);`
`679`	`680`
`680`	`681`	`mtm_log(DmqStateFinal,`
`681`	`682`	`"[DMQ] Connected to %s",`