bugfix:修复packet io内存泄漏v4.8.13-20230522

1 files changed, 12 insertions, 2 deletions

diff --git a/common/src/tfe_ctrl_packet.cpp b/common/src/tfe_ctrl_packet.cpp
index c535857..206eb96 100644
--- a/common/src/tfe_ctrl_packet.cpp
+++ b/common/src/tfe_ctrl_packet.cpp
@@ -297,6 +297,8 @@ int ctrl_packet_parser_parse(void *ctx, const char* data, size_t length, void *l
         goto error;
     }
 
+    handler->cmsg = tfe_cmsg_init();
+    tfe_cmsg_dup(handler->cmsg);
     proxy_map = mpack_node_map_cstr(params, "proxy");
     ret = proxy_parse_messagepack(proxy_map, handler, logger);
     if (ret != 0)
@@ -307,6 +309,8 @@ succ:
     return 0;
 error:
     mpack_tree_destroy(&tree);
+    tfe_cmsg_destroy(handler->cmsg);
+    tfe_cmsg_destroy(handler->cmsg);
     return -1;
 }
 
@@ -330,8 +334,14 @@ const char *session_state_to_string(enum session_state state)
 void ctrl_packet_parser_init(struct ctrl_pkt_parser *handler)
 {
     memset(handler, 0, sizeof(struct ctrl_pkt_parser));
-    handler->cmsg = tfe_cmsg_init();
-    tfe_cmsg_dup(handler->cmsg);
+}
+
+void ctrl_packet_cmsg_destroy(struct ctrl_pkt_parser *handler)
+{
+    if (handler) {
+        tfe_cmsg_destroy(handler->cmsg);
+        tfe_cmsg_destroy(handler->cmsg);
+    }
 }
 
 void ctrl_packet_parser_dump(struct ctrl_pkt_parser *handler, void *logger)