From 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 05 一月 2022 14:11:39 +0800
Subject: [PATCH] pb.go MsgQueryProcReply add subLocalTopics and subNetTopics

---
 src/socket/bus_server_socket.cpp |    3 +++
 1 files changed, 3 insertions(+), 0 deletions(-)

diff --git a/src/socket/bus_server_socket.cpp b/src/socket/bus_server_socket.cpp
index 2cd1ca8..fc53b0b 100644
--- a/src/socket/bus_server_socket.cpp
+++ b/src/socket/bus_server_socket.cpp
@@ -567,7 +567,10 @@
         procQuePart->erase(buf_temp);
       }
 
+      pthread_mutex_lock(&gMutex);
       BusServerSocket::buf_data_remove(key);
+      pthread_mutex_unlock(&gMutex);
+
       find_mm_data(key);
     }
 

--
Gitblit v1.8.0