diff options
author | Guangxiong Lin <[email protected]> | 2022-12-09 16:46:49 +0800 |
---|---|---|
committer | Guangxiong Lin <[email protected]> | 2022-12-09 19:39:08 +0800 |
commit | 49839c88a98d3798f7b18c58f54f26f36cacff38 (patch) | |
tree | 5cb4ee13f9bdb0ef25e39a07a628f6f16da18e87 /server.c | |
parent | 0457119acb36b89b6f2f4534fe8ad94b19540bbd (diff) | |
download | tinyserver-49839c88a98d3798f7b18c58f54f26f36cacff38.tar.gz tinyserver-49839c88a98d3798f7b18c58f54f26f36cacff38.tar.bz2 tinyserver-49839c88a98d3798f7b18c58f54f26f36cacff38.zip |
Implement a simple thread pool and refactor
Refactor
Diffstat (limited to 'server.c')
-rw-r--r-- | server.c | 22 |
1 files changed, 13 insertions, 9 deletions
@@ -10,27 +10,31 @@ #include <sys/epoll.h> #include <errno.h> -#include "eventloop.h" +#include "evloop.h" #include "tsocket.h" #include "util.h" -#include "connection.h" #include "acceptor.h" +#include "tpool.h" int main() { - struct eventLoop *el = eventLoopNew(); + evloop_t *el = evloop_create(); if (el == NULL) panic("eventloop creation"); - struct tsocket *sock = tsocketNew(); + struct tsocket *sock = tsocket_create(); if (sock == NULL - || tsocketBind(sock, "127.0.0.1", 8888) == -1 - || tsocketListen(sock) == -1) + || tsocket_bind(sock, "127.0.0.1", 8888) == -1 + || tsocket_listen(sock) == -1) panic("socket creation"); - struct event *acceptEvent = connAcceptorNewEvent(sock, el); - if (eventLoopAdd(el, acceptEvent, EPOLLIN) == -1) + tpool = tpool_create(0); + if (!tpool) + panic("tpool_create"); + + event_t *acceptEvent = conn_acceptor_create_event(sock, el); + if (evloop_add(el, acceptEvent, EPOLLIN) == -1) panic("eventloop add fd"); - eventLoopLoop(el); + evloop_loop(el); } |