Push responses to WAL sender

Author: knizhnik

contrib/mmts/pglogical_receiver.c

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