From d062205e8c3b2956b6aaa03403417b3e6963b28f Mon Sep 17 00:00:00 2001
From: liyifeng_seu <307419146@qq.com>
Date: Thu, 5 Aug 2021 06:11:25 +0000
Subject: [PATCH 1/2] =?UTF-8?q?update=20src/bin/pg=5Fprobackup/pg=5Fprobac?=
 =?UTF-8?q?kup.cpp.=20=E4=BF=AE=E5=A4=8Dprobackup=E5=86=85=E5=AD=98?=
 =?UTF-8?q?=E6=B3=84=E9=9C=B2=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/bin/pg_probackup/pg_probackup.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/bin/pg_probackup/pg_probackup.cpp b/src/bin/pg_probackup/pg_probackup.cpp
index 58445b25c..37d28c2e7 100644
--- a/src/bin/pg_probackup/pg_probackup.cpp
+++ b/src/bin/pg_probackup/pg_probackup.cpp
@@ -804,6 +804,8 @@ int main(int argc, char *argv[])
      */
     parse_backup_option_to_params(command, command_name);
 
+    pfree(command_name);
+
     compress_init();
 
     /* do actual operation */

From 4d100b93878b797ea8c3f4ece4510c796c84b22d Mon Sep 17 00:00:00 2001
From: liyifeng_seu <307419146@qq.com>
Date: Thu, 5 Aug 2021 06:14:31 +0000
Subject: [PATCH 2/2] =?UTF-8?q?update=20src/bin/pg=5Fprobackup/pgut.cpp.?=
 =?UTF-8?q?=20=E4=BF=AE=E5=A4=8Dprobackup=E5=86=85=E5=AD=98=E6=B3=84?=
 =?UTF-8?q?=E9=9C=B2=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/bin/pg_probackup/pgut.cpp | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/bin/pg_probackup/pgut.cpp b/src/bin/pg_probackup/pgut.cpp
index 502c0f8ab..b513c97cf 100644
--- a/src/bin/pg_probackup/pgut.cpp
+++ b/src/bin/pg_probackup/pgut.cpp
@@ -613,6 +613,7 @@ PGconn* pgut_connect_replication(const char *host, const char *port,
     const char **values;
     errno_t rc = EOK;
     char rwtimeoutStr[12] = {0};
+    const char *malloc_port = NULL;
 
     if (interrupted && !in_cleanup)
         elog(ERROR, "interrupted");
@@ -659,6 +660,7 @@ PGconn* pgut_connect_replication(const char *host, const char *port,
     {
         keywords[i] = "port";
         values[i] = inc_dbport(port);
+        malloc_port = values[i];
         i++;
     }
 
@@ -683,6 +685,10 @@ PGconn* pgut_connect_replication(const char *host, const char *port,
         {
             free(values);
             free(keywords);
+            if (malloc_port)
+            {
+                free((void *)malloc_port);
+            }
             return tmpconn;
         }
 
@@ -700,6 +706,10 @@ PGconn* pgut_connect_replication(const char *host, const char *port,
         PQfinish(tmpconn);
         free(values);
         free(keywords);
+        if (malloc_port)
+        {
+            free((void *)malloc_port);
+        }
         return NULL;
     }
 }