Push responses to WAL sender

knizhnik · knizhnik · commit 725cda1c0fa5 · 2016-08-12T18:13:43.000+03:00
diff --git a/contrib/mmts/pglogical_receiver.c b/contrib/mmts/pglogical_receiver.c
@@ -453,7 +453,7 @@ pglogical_receiver_main(Datum main_arg)
 						int64 now = feGetCurrentTimestamp();
 
 						/* Leave is feedback is not sent properly */
-						MtmUpdateLsnMapping(nodeId, InvalidXLogRecPtr);
+						MtmUpdateLsnMapping(nodeId, walEnd);
 						if (!sendFeedback(conn, now, nodeId)) {
 							goto OnError;
 						}

Original file line number	Diff line number	Diff line change
`@@ -453,7 +453,7 @@ pglogical_receiver_main(Datum main_arg)`
`453`	`453`	`int64 now = feGetCurrentTimestamp();`
`454`	`454`
`455`	`455`	`/* Leave is feedback is not sent properly */`
`456`		`- MtmUpdateLsnMapping(nodeId, InvalidXLogRecPtr);`
	`456`	`+ MtmUpdateLsnMapping(nodeId, walEnd);`
`457`	`457`	`if (!sendFeedback(conn, now, nodeId)) {`
`458`	`458`	`goto OnError;`
`459`	`459`	`}`