From ed6233cf772746285ed22a66d2b8e32fbb03e02f Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Mon, 18 Dec 2023 07:30:21 +0000
Subject: [PATCH] fix(conn): lock conn buf

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

diff --git a/src/connection/connection.c b/src/connection/connection.c
index 4a2b87fb..9084f927 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -1289,10 +1289,12 @@ int neu_conn_stream_consume(neu_conn_t *conn, void *context,
                 neu_conn_disconnect(conn);
                 break;
             } else {
+                pthread_mutex_lock(&conn->mtx);
                 conn->offset -= used;
                 memmove(conn->buf, conn->buf + used, conn->offset);
                 neu_protocol_unpack_buf_init(&protocol_buf, conn->buf,
                                              conn->offset);
+                pthread_mutex_unlock(&conn->mtx);
             }
         }
     }