diff options
| author | Robby Zambito <contact@robbyzambito.me> | 2026-01-12 19:14:59 -0500 |
|---|---|---|
| committer | Robby Zambito <contact@robbyzambito.me> | 2026-01-12 19:15:11 -0500 |
| commit | c5ad98adc6ebea6627fc08c2c16324610a8a97e0 (patch) | |
| tree | 06de8a535209d11df07a509b05893a7b2041bd29 /src | |
| parent | 9f690fe27a25dc36047e65e83c8a2f4c8372734b (diff) | |
max buffer size way too small
Diffstat (limited to 'src')
| -rw-r--r-- | src/Server.zig | 3 | ||||
| -rw-r--r-- | src/Server/parse.zig | 3 |
2 files changed, 5 insertions, 1 deletions
diff --git a/src/Server.zig b/src/Server.zig index 25c938b..e0aca28 100644 --- a/src/Server.zig +++ b/src/Server.zig @@ -171,7 +171,8 @@ fn handleConnection( const out = &writer.interface; // Set up client reader - const r_buffer: []u8 = try alloc.alignedAlloc(u8, .fromByteUnits(std.atomic.cache_line), r_buf_size); + _ = r_buf_size; + const r_buffer: []u8 = try alloc.alignedAlloc(u8, .fromByteUnits(std.atomic.cache_line), 64 * 1024 * 1024); defer alloc.free(r_buffer); var reader = stream.reader(io, r_buffer); const in = &reader.interface; diff --git a/src/Server/parse.zig b/src/Server/parse.zig index cda5985..6f8281b 100644 --- a/src/Server/parse.zig +++ b/src/Server/parse.zig @@ -141,6 +141,9 @@ pub fn @"pub"(in: *Reader) Error!Message.Pub { } if (in.buffered()[iter.index] == '\r') { const bytes = parseUnsigned(usize, second, 10) catch return error.InvalidStream; + log.debug("received len: {d}", .{in.buffered().len}); + log.debug("headers len: {d}\tbytes: {d}", .{ iter.index, bytes }); + log.debug("buffer len: {d}", .{in.buffer.len}); if (in.buffered().len < iter.index + bytes + "\r\n".len + "\r\n".len) { try in.fill(iter.index + bytes + "\r\n".len + "\r\n".len); continue; |
