X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=acceptor.cpp;h=7620b7991104d98d19364559b46d6778d4c7919e;hp=0b8de507af4d0b5576cb2f9aa309ba6e68519a62;hb=e1722a5c0341fd541ce57f1eed4dc76cbd3efe07;hpb=3f82e5f8ede16a712aa0bcd0913d2d8e3689742c diff --git a/acceptor.cpp b/acceptor.cpp index 0b8de50..7620b79 100644 --- a/acceptor.cpp +++ b/acceptor.cpp @@ -1,6 +1,7 @@ #include #include #include +#include #include #include #include @@ -59,10 +60,14 @@ int create_server_socket(int port) return server_sock; } + +AcceptorThread::AcceptorThread(int server_sock) + : server_sock(server_sock) +{ +} -void *acceptor_thread_run(void *arg) +void AcceptorThread::do_work() { - int server_sock = int(intptr_t(arg)); while (!hupped) { // Since we are non-blocking, we need to wait for the right state first. // Wait up to 50 ms, then check hupped. @@ -104,5 +109,4 @@ void *acceptor_thread_run(void *arg) // Pick a server, round-robin, and hand over the socket to it. servers->add_client(sock); } - return NULL; }