Fix memory leak.

Per Coverity.

diff --git a/src/protocol/pool_process_query.c b/src/protocol/pool_process_query.c
index 6c7cc23dd865f9d0f0ff23b837a056826cbbbfac..2760ef16a592cd3ed31c6df6c0f9bc7d0c2c2c64 100644 (file)
--- a/src/protocol/pool_process_query.c
+++ b/src/protocol/pool_process_query.c
@@ -3280,7 +3280,8 @@ read_kind_from_backend(POOL_CONNECTION * frontend, POOL_CONNECTION_POOL * backen
                                        (errmsg("reading backend data packet kind"),
                                         errdetail("received notification message for master node %d",
                                                           MASTER_NODE_ID)));
-
+                       if (msg)
+                               pool_pending_message_free_pending_message(msg);
                        return;
                }
                pool_unread(CONNECTION(backend, MASTER_NODE_ID), &kind, sizeof(kind));