diff options
| author | Guangxiong Lin <[email protected]> | 2022-12-16 13:53:35 +0800 |
|---|---|---|
| committer | Guangxiong Lin <[email protected]> | 2022-12-16 13:53:35 +0800 |
| commit | 7369505397cdfddf0883e2c24e1652df8bd488fe (patch) | |
| tree | e961bd1bba0276e2c5f523bf12663b34983c9e51 /src/acceptor.c | |
| parent | 49839c88a98d3798f7b18c58f54f26f36cacff38 (diff) | |
| download | tinyserver-7369505397cdfddf0883e2c24e1652df8bd488fe.tar.gz tinyserver-7369505397cdfddf0883e2c24e1652df8bd488fe.tar.bz2 tinyserver-7369505397cdfddf0883e2c24e1652df8bd488fe.zip | |
Refactor file structure
Diffstat (limited to 'src/acceptor.c')
| -rw-r--r-- | src/acceptor.c | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/src/acceptor.c b/src/acceptor.c new file mode 100644 index 0000000..1f28fcc --- /dev/null +++ b/src/acceptor.c @@ -0,0 +1,58 @@ +#include <stdbool.h> +#include <stdlib.h> +#include <stdio.h> +#include <sys/epoll.h> + +#include "acceptor.h" +#include "util.h" +#include "connection.h" +#include "evloop.h" + +struct conn_acceptor { + struct tsocket *sock; + evloop_t *el; +}; +typedef struct conn_acceptor conn_acceptor_t; + +static void conn_acceptor_accept(conn_acceptor_t *ca) +{ + struct tsocket *conn_sock = tsocket_accept(ca->sock); + if (conn_sock == NULL) { + perror("socket accept"); + return; + } + + if (setblocking(conn_sock->fd, false) == -1) { + perror("setblocking"); + tsocket_destroy(conn_sock); + return; + } + + event_t *conn_ev = connection_create_event(conn_sock); + + if (evloop_add(ca->el, conn_ev, EPOLLIN | EPOLLET) == -1) { + perror("eventloop add fd: conn_sock"); + return; + } + + printf("New client fd %d, ip: %s, port: %d\n", + conn_sock->fd, conn_sock->addr, conn_sock->port); +} + +static void conn_acceptor_destroy(conn_acceptor_t *ca) +{ + tsocket_destroy(ca->sock); + free(ca); +} + +event_t *conn_acceptor_create_event(struct tsocket *sock, evloop_t *el) +{ + conn_acceptor_t *ca = malloc(sizeof(*ca)); + ca->sock = sock; + ca->el = el; + + struct event *ev = event_create(ca, sock->fd, + (evloop_process_func_t) conn_acceptor_accept, + (evloop_destroy_func_t) conn_acceptor_destroy); + return ev; +} |