You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
29 lines
787 B
C
29 lines
787 B
C
#include "io_internal.h"
|
|
#ifdef HAVE_EPOLL
|
|
#include <sys/epoll.h>
|
|
#endif
|
|
#ifdef HAVE_KQUEUE
|
|
#include <sys/types.h>
|
|
#include <sys/event.h>
|
|
#include <sys/time.h>
|
|
#endif
|
|
|
|
int iom_add(iomux_t* c,int64 s,unsigned int events) {
|
|
#ifdef HAVE_EPOLL
|
|
struct epoll_event e = { .events=EPOLLONESHOT, .data.fd=s };
|
|
if (events & IOM_READ) e.events|=EPOLLIN;
|
|
if (events & IOM_WRITE) e.events|=EPOLLOUT;
|
|
return epoll_ctl(c->ctx, EPOLL_CTL_ADD, s, &e);
|
|
#elif defined(HAVE_KQUEUE)
|
|
struct kevent kev;
|
|
struct timespec ts = { 0 };
|
|
EV_SET(&kev, s,
|
|
(events & IOM_READ ? EVFILT_READ : 0) +
|
|
(events & IOM_WRITE ? EVFILT_WRITE : 0),
|
|
EV_ADD | EV_ENABLE | EV_ONESHOT, 0, 0, (void*)s);
|
|
return kevent(c->ctx, &kev, 1, 0, 0, &ts);
|
|
#else
|
|
#warning "only epoll and kqueue supported for now"
|
|
#endif
|
|
}
|