Push responses to WAL sender

Author: knizhnik

pglogical_receiver.c

@@ -453,6 +453,7 @@ pglogical_receiver_main(Datum main_arg)
 						int64 now = feGetCurrentTimestamp();
 
 						/* Leave is feedback is not sent properly */
+						MtmUpdateLsnMapping(nodeId, InvalidXLogRecPtr);
 						if (!sendFeedback(conn, now, nodeId)) {
 							goto OnError;
 						}
@@ -568,14 +569,7 @@ pglogical_receiver_main(Datum main_arg)
 				timeoutptr = &timeout;
 
 				r = select(PQsocket(conn) + 1, &input_mask, NULL, NULL, timeoutptr);
-				if (r == 0)
-				{
-					int64 now = feGetCurrentTimestamp();
-					MtmUpdateLsnMapping(nodeId, InvalidXLogRecPtr);
-					sendFeedback(conn, now, nodeId);					
-					continue;
-				}
-				else if (r < 0 && errno == EINTR)
+				if (r <= 0 && errno == EINTR)
 				{
 					/*
 					 * Got a timeout or signal. Continue the loop and either