Push responses to WAL sender

Author: knizhnik

multimaster.c

@@ -2484,13 +2484,14 @@ void  MtmUpdateLsnMapping(int node_id, XLogRecPtr end_lsn)
 	XLogRecPtr local_flush = GetFlushRecPtr();
 	MemoryContext old_context = MemoryContextSwitchTo(TopMemoryContext);
 
-	/* Track commit lsn */
-	flushpos = (MtmFlushPosition *) palloc(sizeof(MtmFlushPosition));
-	flushpos->node_id = node_id;
-	flushpos->local_end = XactLastCommitEnd;
-	flushpos->remote_end = end_lsn;
-	dlist_push_tail(&MtmLsnMapping, &flushpos->node);
-
+	if (end_lsn != InvalidXLogRecPtr) {
+		/* Track commit lsn */
+		flushpos = (MtmFlushPosition *) palloc(sizeof(MtmFlushPosition));
+		flushpos->node_id = node_id;
+		flushpos->local_end = XactLastCommitEnd;
+		flushpos->remote_end = end_lsn;
+		dlist_push_tail(&MtmLsnMapping, &flushpos->node);
+	}
 	MtmLock(LW_EXCLUSIVE);
 	dlist_foreach_modify(iter, &MtmLsnMapping)
 	{

pglogical_receiver.c

@@ -571,6 +571,7 @@ pglogical_receiver_main(Datum main_arg)
 				if (r == 0)
 				{
 					int64 now = feGetCurrentTimestamp();
+					MtmUpdateLsnMapping(nodeId, InvalidXLogRecPtr);
 					sendFeedback(conn, now, nodeId);					
 					continue;
 				}