From a8aa818519ab27ae2f2c554d87bc9196e1d6884b Mon Sep 17 00:00:00 2001
From: chenxiaobin <1025221611@qq.com>
Date: Tue, 9 Mar 2021 19:57:13 +0800
Subject: [PATCH] modify infomation of view pg_stat_replication

---
 .../storage/replication/walsender.cpp           | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/src/gausskernel/storage/replication/walsender.cpp b/src/gausskernel/storage/replication/walsender.cpp
index ddd048819..23136c4f3 100644
--- a/src/gausskernel/storage/replication/walsender.cpp
+++ b/src/gausskernel/storage/replication/walsender.cpp
@@ -216,6 +216,9 @@ int WalSenderMain(void)
 {
     MemoryContext walsnd_context;
     int nRet = 0;
+    char* appName = NULL;
+    const char* appNameType = NULL;
+    size_t appNameSize;
 
     t_thrd.proc_cxt.MyProgName = "WalSender";
     if (RecoveryInProgress()) {
@@ -308,12 +311,20 @@ int WalSenderMain(void)
         SpinLockRelease(&walsnd->mutex);
 
         if (walsnd->sendRole == SNDROLE_PRIMARY_DUMMYSTANDBY) {
-            pgstat_report_appname("WalSender to Secondary");
+            appNameType = "WalSender to Secondary";
         } else if (walsnd->sendRole == SNDROLE_PRIMARY_BUILDSTANDBY) {
-            pgstat_report_appname("WalSender to Build");
+            appNameType = "WalSender to Build";
         } else if (walsnd->sendRole == SNDROLE_PRIMARY_STANDBY) {
-            pgstat_report_appname("WalSender to Standby");
+            appNameType = "WalSender to Standby";
         }
+
+        appNameSize = strlen(appNameType) + strlen(u_sess->attr.attr_common.application_name) + 3;
+        appName = (char*)palloc(appNameSize);
+        nRet = snprintf_s(appName, appNameSize, appNameSize - 1,
+                          "%s[%s]", appNameType, u_sess->attr.attr_common.application_name);
+        securec_check_ss(nRet, "\0", "\0");
+        pgstat_report_appname(appName);
+        pfree_ext(appName);
     }
 
     SyncRepInitConfig();