Push responses to WAL sender

knizhnik · kelvich · commit 6766596184f1 · 2017-11-13T02:17:30.000+03:00
diff --git a/pglogical_receiver.c b/pglogical_receiver.c
@@ -569,7 +569,7 @@ pglogical_receiver_main(Datum main_arg)
 				timeoutptr = &timeout;
 
 				r = select(PQsocket(conn) + 1, &input_mask, NULL, NULL, timeoutptr);
-				if (r <= 0 && errno == EINTR)
+				if (r == 0 || (r < 0 && errno == EINTR))
 				{
 					/*
 					 * Got a timeout or signal. Continue the loop and either

Original file line number	Diff line number	Diff line change
`@@ -569,7 +569,7 @@ pglogical_receiver_main(Datum main_arg)`
`569`	`569`	`timeoutptr = &timeout;`
`570`	`570`
`571`	`571`	`r = select(PQsocket(conn) + 1, &input_mask, NULL, NULL, timeoutptr);`
`572`		`- if (r <= 0 && errno == EINTR)`
	`572`	`+ if (r == 0 \|\| (r < 0 && errno == EINTR))`
`573`	`573`	`{`
`574`	`574`	`/*`
`575`	`575`	`* Got a timeout or signal. Continue the loop and either`