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;