do not log forwarded syncpoints

kelvich · kelvich · commit 8cd33a3242fa · 2019-03-29T17:22:39.000+03:00
diff --git a/src/pglogical_apply.c b/src/pglogical_apply.c
@@ -597,7 +597,7 @@ process_syncpoint(MtmReceiverContext *rctx, const char *msg, XLogRecPtr received
 		if (origin_node == Mtm->my_node_id)
 			return;
 
-		local_lsn = LogLogicalMessage("S", msg, strlen(msg) + 1, false);
+		local_lsn = GetXLogInsertRecPtr();
 	}
 	else
 	{

Original file line number	Diff line number	Diff line change
`@@ -597,7 +597,7 @@ process_syncpoint(MtmReceiverContext rctx, const char msg, XLogRecPtr received`
`597`	`597`	`if (origin_node == Mtm->my_node_id)`
`598`	`598`	`return;`
`599`	`599`
`600`		`- local_lsn = LogLogicalMessage("S", msg, strlen(msg) + 1, false);`
	`600`	`+ local_lsn = GetXLogInsertRecPtr();`
`601`	`601`	`}`
`602`	`602`	`else`
`603`	`603`	`{`