diff options
Diffstat (limited to 'data/lighttpd/lighttpd-1.4.53/src/fdevent_solaris_devpoll.c')
| -rw-r--r-- | data/lighttpd/lighttpd-1.4.53/src/fdevent_solaris_devpoll.c | 172 |
1 files changed, 172 insertions, 0 deletions
diff --git a/data/lighttpd/lighttpd-1.4.53/src/fdevent_solaris_devpoll.c b/data/lighttpd/lighttpd-1.4.53/src/fdevent_solaris_devpoll.c new file mode 100644 index 000000000..1eb8f756b --- /dev/null +++ b/data/lighttpd/lighttpd-1.4.53/src/fdevent_solaris_devpoll.c @@ -0,0 +1,172 @@ +#include "first.h" + +#include "fdevent_impl.h" +#include "fdevent.h" +#include "buffer.h" +#include "log.h" + +#include <sys/types.h> + +#include <unistd.h> +#include <stdlib.h> +#include <string.h> +#include <errno.h> +#include <fcntl.h> + +#ifdef FDEVENT_USE_SOLARIS_DEVPOLL + +# include <sys/devpoll.h> +# include <sys/ioctl.h> + +static void fdevent_solaris_devpoll_free(fdevents *ev) { + free(ev->devpollfds); + close(ev->devpoll_fd); +} + +/* return -1 is fine here */ + +static int fdevent_solaris_devpoll_event_del(fdevents *ev, int fde_ndx, int fd) { + struct pollfd pfd; + + if (fde_ndx < 0) return -1; + + pfd.fd = fd; + pfd.events = POLLREMOVE; + pfd.revents = 0; + + if (-1 == write(ev->devpoll_fd, &pfd, sizeof(pfd))) { + log_error_write(ev->srv, __FILE__, __LINE__, "S(D, S)", + "(del) write failed: ", fd, strerror(errno)); + + return -1; + } + + return -1; +} + +static int fdevent_solaris_devpoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { + struct pollfd pfd; + int add = 0; + + int pevents = 0; + if (events & FDEVENT_IN) pevents |= POLLIN; + if (events & FDEVENT_OUT) pevents |= POLLOUT; + + if (fde_ndx == -1) add = 1; + + pfd.fd = fd; + pfd.events = pevents; + pfd.revents = 0; + + if (-1 == write(ev->devpoll_fd, &pfd, sizeof(pfd))) { + log_error_write(ev->srv, __FILE__, __LINE__, "S(D, S)", + "(set) write failed: ", fd, strerror(errno)); + + return -1; + } + + return fd; +} + +static int fdevent_solaris_devpoll_poll(fdevents *ev, int timeout_ms) { + struct dvpoll dopoll; + int ret; + + dopoll.dp_timeout = timeout_ms; + dopoll.dp_nfds = ev->maxfds - 1; + dopoll.dp_fds = ev->devpollfds; + + ret = ioctl(ev->devpoll_fd, DP_POLL, &dopoll); + + return ret; +} + +static int fdevent_solaris_devpoll_event_get_revent(fdevents *ev, size_t ndx) { + int r, poll_r; + + r = 0; + poll_r = ev->devpollfds[ndx].revents; + + /* map POLL* to FDEVEN_*; they are probably the same, but still. */ + + if (poll_r & POLLIN) r |= FDEVENT_IN; + if (poll_r & POLLOUT) r |= FDEVENT_OUT; + if (poll_r & POLLERR) r |= FDEVENT_ERR; + if (poll_r & POLLHUP) r |= FDEVENT_HUP; + if (poll_r & POLLNVAL) r |= FDEVENT_NVAL; + if (poll_r & POLLPRI) r |= FDEVENT_PRI; + + return r; +} + +static int fdevent_solaris_devpoll_event_get_fd(fdevents *ev, size_t ndx) { + return ev->devpollfds[ndx].fd; +} + +static int fdevent_solaris_devpoll_event_next_fdndx(fdevents *ev, int last_ndx) { + size_t i; + + UNUSED(ev); + + i = (last_ndx < 0) ? 0 : last_ndx + 1; + + return i; +} + +int fdevent_solaris_devpoll_reset(fdevents *ev) { + /* a forked process does only inherit the filedescriptor, + * but every operation on the device will lead to a EACCES */ + if ((ev->devpoll_fd = open("/dev/poll", O_RDWR)) < 0) { + log_error_write(ev->srv, __FILE__, __LINE__, "SSS", + "opening /dev/poll failed (", strerror(errno), "), try to set server.event-handler = \"poll\" or \"select\""); + + return -1; + } + + fdevent_setfd_cloexec(ev->devpoll_fd); + return 0; +} +int fdevent_solaris_devpoll_init(fdevents *ev) { + ev->type = FDEVENT_HANDLER_SOLARIS_DEVPOLL; +#define SET(x) \ + ev->x = fdevent_solaris_devpoll_##x; + + SET(free); + SET(poll); + SET(reset); + + SET(event_del); + SET(event_set); + + SET(event_next_fdndx); + SET(event_get_fd); + SET(event_get_revent); + + ev->devpollfds = malloc(sizeof(*ev->devpollfds) * ev->maxfds); + force_assert(NULL != ev->devpollfds); + + if ((ev->devpoll_fd = open("/dev/poll", O_RDWR)) < 0) { + log_error_write(ev->srv, __FILE__, __LINE__, "SSS", + "opening /dev/poll failed (", strerror(errno), "), try to set server.event-handler = \"poll\" or \"select\""); + + return -1; + } + + /* we just wanted to check if it works */ + close(ev->devpoll_fd); + + ev->devpoll_fd = -1; + + return 0; +} + +#else +int fdevent_solaris_devpoll_init(fdevents *ev) { + UNUSED(ev); + + log_error_write(ev->srv, __FILE__, __LINE__, "S", + "solaris-devpoll not supported, try to set server.event-handler = \"poll\" or \"select\""); + + return -1; +} +#endif |