diff options
Diffstat (limited to 'libs/libevent/docs/devpoll.c')
-rw-r--r-- | libs/libevent/docs/devpoll.c | 311 |
1 files changed, 0 insertions, 311 deletions
diff --git a/libs/libevent/docs/devpoll.c b/libs/libevent/docs/devpoll.c deleted file mode 100644 index 3a2f86d6f1..0000000000 --- a/libs/libevent/docs/devpoll.c +++ /dev/null @@ -1,311 +0,0 @@ -/* - * Copyright 2000-2009 Niels Provos <provos@citi.umich.edu> - * Copyright 2009-2012 Niels Provos and Nick Mathewson - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * 3. The name of the author may not be used to endorse or promote products - * derived from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. - * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, - * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT - * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF - * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ -#include "event2/event-config.h" -#include "evconfig-private.h" - -#ifdef EVENT__HAVE_DEVPOLL - -#include <sys/types.h> -#include <sys/resource.h> -#ifdef EVENT__HAVE_SYS_TIME_H -#include <sys/time.h> -#endif -#include <sys/queue.h> -#include <sys/devpoll.h> -#include <signal.h> -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <unistd.h> -#include <fcntl.h> -#include <errno.h> - -#include "event2/event.h" -#include "event2/event_struct.h" -#include "event2/thread.h" -#include "event-internal.h" -#include "evsignal-internal.h" -#include "log-internal.h" -#include "evmap-internal.h" -#include "evthread-internal.h" - -struct devpollop { - struct pollfd *events; - int nevents; - int dpfd; - struct pollfd *changes; - int nchanges; -}; - -static void *devpoll_init(struct event_base *); -static int devpoll_add(struct event_base *, int fd, short old, short events, void *); -static int devpoll_del(struct event_base *, int fd, short old, short events, void *); -static int devpoll_dispatch(struct event_base *, struct timeval *); -static void devpoll_dealloc(struct event_base *); - -const struct eventop devpollops = { - "devpoll", - devpoll_init, - devpoll_add, - devpoll_del, - devpoll_dispatch, - devpoll_dealloc, - 1, /* need reinit */ - EV_FEATURE_FDS|EV_FEATURE_O1, - 0 -}; - -#define NEVENT 32000 - -static int -devpoll_commit(struct devpollop *devpollop) -{ - /* - * Due to a bug in Solaris, we have to use pwrite with an offset of 0. - * Write is limited to 2GB of data, until it will fail. - */ - if (pwrite(devpollop->dpfd, devpollop->changes, - sizeof(struct pollfd) * devpollop->nchanges, 0) == -1) - return (-1); - - devpollop->nchanges = 0; - return (0); -} - -static int -devpoll_queue(struct devpollop *devpollop, int fd, int events) { - struct pollfd *pfd; - - if (devpollop->nchanges >= devpollop->nevents) { - /* - * Change buffer is full, must commit it to /dev/poll before - * adding more - */ - if (devpoll_commit(devpollop) != 0) - return (-1); - } - - pfd = &devpollop->changes[devpollop->nchanges++]; - pfd->fd = fd; - pfd->events = events; - pfd->revents = 0; - - return (0); -} - -static void * -devpoll_init(struct event_base *base) -{ - int dpfd, nfiles = NEVENT; - struct rlimit rl; - struct devpollop *devpollop; - - if (!(devpollop = mm_calloc(1, sizeof(struct devpollop)))) - return (NULL); - - if (getrlimit(RLIMIT_NOFILE, &rl) == 0 && - rl.rlim_cur != RLIM_INFINITY) - nfiles = rl.rlim_cur; - - /* Initialize the kernel queue */ - if ((dpfd = evutil_open_closeonexec_("/dev/poll", O_RDWR, 0)) == -1) { - event_warn("open: /dev/poll"); - mm_free(devpollop); - return (NULL); - } - - devpollop->dpfd = dpfd; - - /* Initialize fields */ - /* FIXME: allocating 'nfiles' worth of space here can be - * expensive and unnecessary. See how epoll.c does it instead. */ - devpollop->events = mm_calloc(nfiles, sizeof(struct pollfd)); - if (devpollop->events == NULL) { - mm_free(devpollop); - close(dpfd); - return (NULL); - } - devpollop->nevents = nfiles; - - devpollop->changes = mm_calloc(nfiles, sizeof(struct pollfd)); - if (devpollop->changes == NULL) { - mm_free(devpollop->events); - mm_free(devpollop); - close(dpfd); - return (NULL); - } - - evsig_init_(base); - - return (devpollop); -} - -static int -devpoll_dispatch(struct event_base *base, struct timeval *tv) -{ - struct devpollop *devpollop = base->evbase; - struct pollfd *events = devpollop->events; - struct dvpoll dvp; - int i, res, timeout = -1; - - if (devpollop->nchanges) - devpoll_commit(devpollop); - - if (tv != NULL) - timeout = tv->tv_sec * 1000 + (tv->tv_usec + 999) / 1000; - - dvp.dp_fds = devpollop->events; - dvp.dp_nfds = devpollop->nevents; - dvp.dp_timeout = timeout; - - EVBASE_RELEASE_LOCK(base, th_base_lock); - - res = ioctl(devpollop->dpfd, DP_POLL, &dvp); - - EVBASE_ACQUIRE_LOCK(base, th_base_lock); - - if (res == -1) { - if (errno != EINTR) { - event_warn("ioctl: DP_POLL"); - return (-1); - } - - return (0); - } - - event_debug(("%s: devpoll_wait reports %d", __func__, res)); - - for (i = 0; i < res; i++) { - int which = 0; - int what = events[i].revents; - - if (what & POLLHUP) - what |= POLLIN | POLLOUT; - else if (what & POLLERR) - what |= POLLIN | POLLOUT; - - if (what & POLLIN) - which |= EV_READ; - if (what & POLLOUT) - which |= EV_WRITE; - - if (!which) - continue; - - /* XXX(niels): not sure if this works for devpoll */ - evmap_io_active_(base, events[i].fd, which); - } - - return (0); -} - - -static int -devpoll_add(struct event_base *base, int fd, short old, short events, void *p) -{ - struct devpollop *devpollop = base->evbase; - int res; - (void)p; - - /* - * It's not necessary to OR the existing read/write events that we - * are currently interested in with the new event we are adding. - * The /dev/poll driver ORs any new events with the existing events - * that it has cached for the fd. - */ - - res = 0; - if (events & EV_READ) - res |= POLLIN; - if (events & EV_WRITE) - res |= POLLOUT; - - if (devpoll_queue(devpollop, fd, res) != 0) - return (-1); - - return (0); -} - -static int -devpoll_del(struct event_base *base, int fd, short old, short events, void *p) -{ - struct devpollop *devpollop = base->evbase; - int res; - (void)p; - - res = 0; - if (events & EV_READ) - res |= POLLIN; - if (events & EV_WRITE) - res |= POLLOUT; - - /* - * The only way to remove an fd from the /dev/poll monitored set is - * to use POLLREMOVE by itself. This removes ALL events for the fd - * provided so if we care about two events and are only removing one - * we must re-add the other event after POLLREMOVE. - */ - - if (devpoll_queue(devpollop, fd, POLLREMOVE) != 0) - return (-1); - - if ((res & (POLLIN|POLLOUT)) != (POLLIN|POLLOUT)) { - /* - * We're not deleting all events, so we must resubmit the - * event that we are still interested in if one exists. - */ - - if ((res & POLLIN) && (old & EV_WRITE)) { - /* Deleting read, still care about write */ - devpoll_queue(devpollop, fd, POLLOUT); - } else if ((res & POLLOUT) && (old & EV_READ)) { - /* Deleting write, still care about read */ - devpoll_queue(devpollop, fd, POLLIN); - } - } - - return (0); -} - -static void -devpoll_dealloc(struct event_base *base) -{ - struct devpollop *devpollop = base->evbase; - - evsig_dealloc_(base); - if (devpollop->events) - mm_free(devpollop->events); - if (devpollop->changes) - mm_free(devpollop->changes); - if (devpollop->dpfd >= 0) - close(devpollop->dpfd); - - memset(devpollop, 0, sizeof(struct devpollop)); - mm_free(devpollop); -} - -#endif /* EVENT__HAVE_DEVPOLL */ |