Move away from oneshot (epoll) / dispatch (kqueue)

Result in way less system calls, significant performance boost, but more
complicated thread-safety code.

src/httpz.zig

@@ -512,6 +512,8 @@ pub fn Server(comptime H: type) type {
             var req = Request.init(allocator, conn);
             var res = Response.init(allocator, conn);
 
+            defer std.debug.assert(res.written == true);
+
             if (comptime std.meta.hasFn(Handler, "handle")) {
                 if (comptime @typeInfo(@TypeOf(Handler.handle)).@"fn".return_type != void) {
                     @compileError(@typeName(Handler) ++ ".handle must return 'void'");
@@ -668,13 +670,6 @@ pub fn upgradeWebsocket(comptime H: type, req: *Request, res: *Response, ctx: an
     return true;
 }
 
-// fn websocketHandler(comptime H: type, server: *websocket.Server, stream: std.net.Stream, context: anytype) void {
-//     errdefer stream.close();
-//     var conn = server.newConn(stream);
-//     var handler = H.init(&conn, context) catch return;
-//     server.handle(H, &handler, &conn);
-// }
-
 // std.heap.StackFallbackAllocator is very specific. It's really _stack_ as it
 // requires a comptime size. Also, it uses non-public calls from the FixedBufferAllocator.
 // There should be a more generic FallbackAllocator that just takes 2 allocators...

src/request.zig

@@ -1522,7 +1522,7 @@ test "request: fuzz" {
         const number_of_requests = random.uintAtMost(u8, 10) + 1;
 
         for (0..number_of_requests) |_| {
-            defer ctx.conn.keepalive(4096);
+            defer ctx.conn.requestDone(4096);
             const method = randomMethod(random);
             const url = t.randomString(random, aa, 20);
 

src/response.zig

@@ -181,7 +181,6 @@ pub const Response = struct {
             .{ .len = header_buf.len, .base = header_buf.ptr },
             .{ .len = body.len, .base = body.ptr },
         };
-
         try writeAllIOVec(stream.handle, &vec);
     }
 

src/t.zig

@@ -98,7 +98,7 @@ pub const Context = struct {
 
         const conn = aa.create(Conn) catch unreachable;
         conn.* = .{
-            .state = .request,
+            ._state = .request,
             .handover = .close,
             .stream = server,
             .address = std.net.Address.initIp4([_]u8{ 127, 0, 0, 200 }, 0),