reset arena after each send

mookums · Sep 18, 2024 · 266e844 · 266e844
1 parent 3570e1e
commit 266e844
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/core/server.zig b/src/core/server.zig
@@ -510,6 +510,9 @@ pub fn Server(
                                         if (inner.count >= inner.slice.len) {
                                             // All done sending.
                                             log.debug("{d} - queueing a new recv", .{p.index});
+                                            _ = p.arena.reset(.{
+                                                .retain_with_limit = z_config.size_connection_arena_retain,
+                                            });
                                             p.recv_buffer.clearRetainingCapacity();
                                             p.job = .{ .recv = .{ .count = 0 } };
                                             try backend.queue_recv(p, p.socket, p.buffer);
@@ -560,6 +563,9 @@ pub fn Server(
 
                                     if (inner.count >= inner.slice.len) {
                                         log.debug("{d} - queueing a new recv", .{p.index});
+                                        _ = p.arena.reset(.{
+                                            .retain_with_limit = z_config.size_connection_arena_retain,
+                                        });
                                         p.recv_buffer.clearRetainingCapacity();
                                         p.job = .{ .recv = .{ .count = 0 } };
                                         try backend.queue_recv(p, p.socket, p.buffer);