summaryrefslogtreecommitdiff
path: root/src/reactor-linux.c
diff options
context:
space:
mode:
authorAlbert Cervin <albert@acervin.com>2023-01-31 15:25:59 +0100
committerAlbert Cervin <albert@acervin.com>2023-01-31 15:25:59 +0100
commit1cd66cac903151396a7513f8e009f6f654561daf (patch)
tree9acd39542c42c59c517cf9321a7faa25929ecb12 /src/reactor-linux.c
parent689ceeca3d25cb2f738a6c52776c53912abb797f (diff)
downloaddged-1cd66cac903151396a7513f8e009f6f654561daf.tar.gz
dged-1cd66cac903151396a7513f8e009f6f654561daf.tar.xz
dged-1cd66cac903151396a7513f8e009f6f654561daf.zip
Fixes to copy-paste
It would crash on multi-line copy.
Diffstat (limited to 'src/reactor-linux.c')
-rw-r--r--src/reactor-linux.c76
1 files changed, 0 insertions, 76 deletions
diff --git a/src/reactor-linux.c b/src/reactor-linux.c
deleted file mode 100644
index e488fef..0000000
--- a/src/reactor-linux.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;
-}