From a9f40899792c3a2708f0b0e957550094bd19314f Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Fri, 9 Sep 2022 03:20:25 +0000
Subject: [PATCH] fix(connection): multithreaded connection status exception

---
 src/connection/connection.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/connection/connection.c b/src/connection/connection.c
index be96047b..b87d3238 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -366,7 +366,9 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
 
 void neu_conn_disconnect(neu_conn_t *conn)
 {
+    pthread_mutex_lock(&conn->mtx);
     conn_disconnect(conn);
+    pthread_mutex_unlock(&conn->mtx);
 }
 
 static void conn_free_param(neu_conn_t *conn)