summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorRobby Zambito <contact@robbyzambito.me>2026-01-12 19:14:59 -0500
committerRobby Zambito <contact@robbyzambito.me>2026-01-12 19:15:11 -0500
commitc5ad98adc6ebea6627fc08c2c16324610a8a97e0 (patch)
tree06de8a535209d11df07a509b05893a7b2041bd29 /src
parent9f690fe27a25dc36047e65e83c8a2f4c8372734b (diff)
max buffer size way too small
Diffstat (limited to 'src')
-rw-r--r--src/Server.zig3
-rw-r--r--src/Server/parse.zig3
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;