修复libpqwalreceiver内存泄漏问题

2022-09-28 09:06:39 +00:00
parent cfa1dacbf9
commit 5488a8d7f4
1 changed files with 3 additions and 1 deletions
--- a/src/gausskernel/storage/replication/libpqwalreceiver.cpp
+++ b/src/gausskernel/storage/replication/libpqwalreceiver.cpp
@ -1355,10 +1355,12 @@ bool libpqrcv_receive(int timeout, unsigned char *type, char **buffer, int *len)

            /* Verify that there are no more results */
            res = PQgetResult(t_thrd.libwalreceiver_cxt.streamConn);
-            if (res != NULL)
+            if (res != NULL) {
+                PQclear(res);
                ereport(ERROR,
                        (errmsg("unexpected result after CommandComplete: %s",
                                PQerrorMessage(t_thrd.libwalreceiver_cxt.streamConn))));
+            }
            *len = -1;
            return false;
        }