fix(conn): lock conn buf

2026-10-28 22:59:34 +08:00 · 2023-12-18 07:32:59 +00:00
parent 21ff7aea65
commit ed6233cf77
1 changed files with 2 additions and 0 deletions
@@ -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);
            }
        }
    }