[PATCH]: ./register_notice_process.patch

Commitfest Bot · Commitfest Bot · commit 6ba1378619f5 · 2025-05-31T03:47:20.000Z
diff --git a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
@@ -127,6 +127,12 @@ _PG_init(void)
 	WalReceiverFunctions = &PQWalReceiverFunctions;
 }
 
+static void
+notice_processor(void *arg, const char *message)
+{
+	elog(LOG, "%s", message);
+}
+
 /*
  * Establish the connection to the primary server.
  *
@@ -253,6 +259,8 @@ libpqrcv_connect(const char *conninfo, bool replication, bool logical,
 		PQclear(res);
 	}
 
+	PQsetNoticeProcessor(conn->streamConn, notice_processor, NULL);
+
 	conn->logical = logical;
 
 	return conn;

Original file line number	Diff line number	Diff line change
`@@ -127,6 +127,12 @@ _PG_init(void)`
`127`	`127`	`WalReceiverFunctions = &PQWalReceiverFunctions;`
`128`	`128`	`}`
`129`	`129`
	`130`	`+static void`
	`131`	`+notice_processor(void arg, const char message)`
	`132`	`+{`
	`133`	`+ elog(LOG, "%s", message);`
	`134`	`+}`
	`135`	`+`
`130`	`136`	`/*`
`131`	`137`	`* Establish the connection to the primary server.`
`132`	`138`	`*`
`@@ -253,6 +259,8 @@ libpqrcv_connect(const char *conninfo, bool replication, bool logical,`
`253`	`259`	`PQclear(res);`
`254`	`260`	`}`
`255`	`261`
	`262`	`+ PQsetNoticeProcessor(conn->streamConn, notice_processor, NULL);`
	`263`	`+`
`256`	`264`	`conn->logical = logical;`
`257`	`265`
`258`	`266`	`return conn;`