Merge pull request #1572 from fengzeroz/main

fix(connection): server consume
2026-10-22 01:05:56 +08:00 · 2023-09-28 16:06:27 +08:00
parent 84887e1d26 937fd4bb86
commit 0d2992257b
1 changed files with 5 additions and 7 deletions
@@ -1295,15 +1295,13 @@ int neu_conn_stream_tcp_server_consume(neu_conn_t *conn, int fd, void *context,
            } else if (used == -1) {
                neu_conn_tcp_server_close_client(conn, fd);
                break;
+            } else {
+                conn->offset -= used;
+                memmove(conn->buf, conn->buf + used, conn->offset);
+                neu_protocol_unpack_buf_init(&protocol_buf, conn->buf,
+                                             conn->offset);
            }
        }
-        if (conn->offset != 0) {
-            conn->offset -= neu_protocol_unpack_buf_used_size(&protocol_buf);
-            memmove(conn->buf,
-                    conn->buf +
-                        neu_protocol_unpack_buf_used_size(&protocol_buf),
-                    conn->offset);
-        }
    }
    return ret;
 }