From d7db88e63cd535de3fa517b6d4c8808fe2f2acaa Mon Sep 17 00:00:00 2001
From: luozihao <1165977584@qq.com>
Date: Tue, 22 Jun 2021 20:54:13 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BC=80=E5=90=AF=E5=A4=87?=
 =?UTF-8?q?=E6=9C=BA=E5=BD=92=E6=A1=A3=E6=97=B6=E5=86=85=E5=AD=98=E6=B3=84?=
 =?UTF-8?q?=E6=BC=8F=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/storage/replication/walreceiver.cpp | 2 ++
 src/gausskernel/storage/replication/walsender.cpp   | 4 +++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/gausskernel/storage/replication/walreceiver.cpp b/src/gausskernel/storage/replication/walreceiver.cpp
index 4e814828..91756473 100644
--- a/src/gausskernel/storage/replication/walreceiver.cpp
+++ b/src/gausskernel/storage/replication/walreceiver.cpp
@@ -3031,6 +3031,8 @@ static void InitArchiveStartPoint()
         pfree(xlog_array);
         xlog_array = NULL;
     }
+    FreeDir(xldir);
+    xldir = NULL;
 }
 
 static bool CheckXlogNameValid(char* xlog)
diff --git a/src/gausskernel/storage/replication/walsender.cpp b/src/gausskernel/storage/replication/walsender.cpp
index f184ed51..be2b7a0e 100644
--- a/src/gausskernel/storage/replication/walsender.cpp
+++ b/src/gausskernel/storage/replication/walsender.cpp
@@ -3203,7 +3203,9 @@ static int WalSndLoop(WalSndSendDataCallback send_data)
             XLogRecPtr replayPtr;
             bool amSync = false;
             bool got_recptr = false;
-            int standby_nums = list_length(SyncRepGetSyncStandbys(&amSync));
+            List* sync_standbys = SyncRepGetSyncStandbys(&amSync);
+            int standby_nums = list_length(sync_standbys);
+            list_free(sync_standbys);
             got_recptr = SyncRepGetSyncRecPtr(&receivePtr, &writePtr, &flushPtr, &replayPtr, &amSync, false);
             if (got_recptr) {
                 ArchiveXlogOnStandby(flushPtr);