diff options
| -rw-r--r-- | src/server/Client.zig | 2 | ||||
| -rw-r--r-- | src/server/Server.zig | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/server/Client.zig b/src/server/Client.zig index 2ce3c38..53a66b9 100644 --- a/src/server/Client.zig +++ b/src/server/Client.zig @@ -33,7 +33,7 @@ pub fn deinit(self: *Client, alloc: std.mem.Allocator) void { } pub fn start(self: *Client, io: std.Io, alloc: std.mem.Allocator) !void { - var msgs: [8]Message = undefined; + var msgs: [256]Message = undefined; while (true) { const len = try self.recv_queue.get(io, &msgs, 1); diff --git a/src/server/Server.zig b/src/server/Server.zig index 82d2cbd..eaecdf2 100644 --- a/src/server/Server.zig +++ b/src/server/Server.zig @@ -123,7 +123,7 @@ fn handleConnection(server: *Server, server_allocator: Allocator, io: Io, id: us const in = &reader.interface; // Set up buffer queue - var qbuf: [8]Message = undefined; + var qbuf: [r_buffer.len / @sizeOf(Message)]Message = undefined; var queue: Queue(Message) = .init(&qbuf); defer { queue.close(io); |