From ae1194e159907e08e1471cba299bf4d84212e7cc Mon Sep 17 00:00:00 2001 From: andrewlalis Date: Sun, 29 Jun 2025 16:42:25 -0400 Subject: [PATCH] Updated readme, updated epoll. --- README.md | 2 +- source/handy_http_transport/http1/epoll.d | 17 +++++++---------- 2 files changed, 8 insertions(+), 11 deletions(-) diff --git a/README.md b/README.md index 4a99198..5d7cc86 100644 --- a/README.md +++ b/README.md @@ -26,7 +26,7 @@ class MyHandler : HttpRequestHandler { } void main() { - HttpTransport tp = new Http1Transport(new MyHandler(), 8080); + HttpTransport tp = new TaskPoolHttp1Transport(new MyHandler(), 8080); tp.start(); } ``` \ No newline at end of file diff --git a/source/handy_http_transport/http1/epoll.d b/source/handy_http_transport/http1/epoll.d index 8d8d547..8f87be1 100644 --- a/source/handy_http_transport/http1/epoll.d +++ b/source/handy_http_transport/http1/epoll.d @@ -13,17 +13,18 @@ extern(C) { } import handy_http_transport.interfaces; +import handy_http_transport.http1; +import handy_http_primitives; import slf4d; -class Http1EpollTransport : HttpTransport { - private immutable ushort port; +class Http1EpollTransport : Http1Transport { - this(ushort port) { - this.port = port; + this(HttpRequestHandler requestHandler, ushort port) { + super(requestHandler, port); } - void start() { - + override void start() { + super.start(); // Create the server socket. enum SOCK_NONBLOCK = 0x4000; int listenFd = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, 0); @@ -118,8 +119,4 @@ class Http1EpollTransport : HttpTransport { } } } - - void stop() { - - } } \ No newline at end of file