diff options
Diffstat (limited to 'src/reactor-epoll.c')
| -rw-r--r-- | src/reactor-epoll.c | 76 |
1 files changed, 0 insertions, 76 deletions
diff --git a/src/reactor-epoll.c b/src/reactor-epoll.c deleted file mode 100644 index e488fef..0000000 --- a/src/reactor-epoll.c +++ /dev/null @@ -1,76 +0,0 @@ -#include "reactor.h" - -#include <stdio.h> -#include <stdlib.h> -#include <sys/epoll.h> - -struct reactor { - int epoll_fd; - void *events; -}; - -struct events { - struct epoll_event events[10]; - uint32_t nevents; -}; - -struct reactor *reactor_create() { - int epollfd = epoll_create1(0); - if (epollfd == -1) { - perror("epoll_create1"); - } - - struct reactor *r = (struct reactor *)calloc(1, sizeof(struct reactor)); - r->epoll_fd = epollfd; - r->events = calloc(1, sizeof(struct events)); - - return r; -} - -void reactor_destroy(struct reactor *reactor) { - free(reactor->events); - free(reactor); -} - -uint32_t reactor_register_interest(struct reactor *reactor, int fd, - enum interest interest) { - struct epoll_event ev; - ev.events = 0; - ev.events |= (interest & ReadInterest) != 0 ? EPOLLIN : 0; - ev.events |= (interest & WriteInterest) != 0 ? EPOLLOUT : 0; - ev.data.fd = fd; - if (epoll_ctl(reactor->epoll_fd, EPOLL_CTL_ADD, fd, &ev) < 0) { - perror("epoll_ctl"); - return -1; - } - - return fd; -} - -void reactor_unregister_interest(struct reactor *reactor, uint32_t ev_id) { - epoll_ctl(reactor->epoll_fd, EPOLL_CTL_DEL, ev_id, NULL); -} - -bool reactor_poll_event(struct reactor *reactor, uint32_t ev_id) { - struct events *events = (struct events *)reactor->events; - for (uint32_t ei = 0; ei < events->nevents; ++ei) { - struct epoll_event *ev = &events->events[ei]; - - if (ev->data.fd == ev_id) { - return true; - } - } - - return false; -} - -void reactor_update(struct reactor *reactor) { - struct events *events = (struct events *)reactor->events; - int nfds = epoll_wait(reactor->epoll_fd, events->events, 10, -1); - - if (nfds == -1) { - // TODO: log failure - } - - events->nevents = nfds; -} |
