summaryrefslogtreecommitdiff
path: root/ev_epoll.c
diff options
context:
space:
mode:
authorroot <root>2007-11-03 21:58:51 +0000
committerroot <root>2007-11-03 21:58:51 +0000
commit228b0b302ab0857b23efad5a8b2429de2c0ccc00 (patch)
treefc54cf6a81f9c0267619258e80c471c1872c7070 /ev_epoll.c
parentb5304cc456ee27383d787591037f5d15ca3b274f (diff)
prepare for multiple bases
Diffstat (limited to 'ev_epoll.c')
-rw-r--r--ev_epoll.c23
1 files changed, 10 insertions, 13 deletions
diff --git a/ev_epoll.c b/ev_epoll.c
index a7918af..30d1b25 100644
--- a/ev_epoll.c
+++ b/ev_epoll.c
@@ -31,10 +31,8 @@
#include <sys/epoll.h>
-static int epoll_fd = -1;
-
static void
-epoll_modify (int fd, int oev, int nev)
+epoll_modify (EV_P_ int fd, int oev, int nev)
{
int mode = nev ? oev ? EPOLL_CTL_MOD : EPOLL_CTL_ADD : EPOLL_CTL_DEL;
@@ -48,7 +46,7 @@ epoll_modify (int fd, int oev, int nev)
}
static void
-epoll_postfork_child (void)
+epoll_postfork_child (EV_P)
{
int fd;
@@ -58,14 +56,11 @@ epoll_postfork_child (void)
/* re-register interest in fds */
for (fd = 0; fd < anfdmax; ++fd)
if (anfds [fd].events)//D
- epoll_modify (fd, EV_NONE, anfds [fd].events);
+ epoll_modify (EV_A_ fd, EV_NONE, anfds [fd].events);
}
-static struct epoll_event *events;
-static int eventmax;
-
static void
-epoll_poll (ev_tstamp timeout)
+epoll_poll (EV_P_ ev_tstamp timeout)
{
int eventcnt = epoll_wait (epoll_fd, events, eventmax, ceil (timeout * 1000.));
int i;
@@ -75,6 +70,7 @@ epoll_poll (ev_tstamp timeout)
for (i = 0; i < eventcnt; ++i)
fd_event (
+ EV_A_
events [i].data.u64,
(events [i].events & (EPOLLOUT | EPOLLERR | EPOLLHUP) ? EV_WRITE : 0)
| (events [i].events & (EPOLLIN | EPOLLERR | EPOLLHUP) ? EV_READ : 0)
@@ -89,22 +85,23 @@ epoll_poll (ev_tstamp timeout)
}
}
-static void
-epoll_init (int flags)
+static int
+epoll_init (EV_P_ int flags)
{
epoll_fd = epoll_create (256);
if (epoll_fd < 0)
- return;
+ return 0;
fcntl (epoll_fd, F_SETFD, FD_CLOEXEC);
- ev_method = EVMETHOD_EPOLL;
method_fudge = 1e-3; /* needed to compensate for epoll returning early */
method_modify = epoll_modify;
method_poll = epoll_poll;
eventmax = 64; /* intiial number of events receivable per poll */
events = malloc (sizeof (struct epoll_event) * eventmax);
+
+ return EVMETHOD_EPOLL;
}