X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Feventl.c;h=f2963a1b0f954468d1422177ab9d457cc2fd019a;hp=74509c8d3fdfcfeabe86a635f3033d5147fa6d76;hb=2979c8fc3b5c53c06facad850dcae09645b43044;hpb=413ed128af037bdb681d673fc6ae68163ad218a4 diff --git a/src/eventl.c b/src/eventl.c index 74509c8..f2963a1 100644 --- a/src/eventl.c +++ b/src/eventl.c @@ -2,7 +2,7 @@ * Copyright (C) 1995-2007, Index Data ApS * See the file LICENSE for details. * - * $Id: eventl.c,v 1.12 2007-11-09 18:47:50 adam Exp $ + * $Id: eventl.c,v 1.17 2007-11-30 11:44:47 adam Exp $ */ /** @@ -10,7 +10,7 @@ * \brief Implements event loop handling for GFS. * * This source implements the main event loop for the Generic Frontend - * Server. It uses select(2). + * Server. */ #include @@ -26,22 +26,7 @@ #include #endif -#define NPOLL 1 - -#if NPOLL #include -#else - -#ifdef WIN32 -#include -#endif -#if HAVE_UNISTD_H -#include -#endif -#if HAVE_SYS_SELECT_H -#include -#endif -#endif #include #include @@ -50,15 +35,6 @@ #include "session.h" #include -#if YAZ_GNU_THREADS -#include -#define YAZ_EV_SELECT pth_select -#endif - -#ifndef YAZ_EV_SELECT -#define YAZ_EV_SELECT select -#endif - static int log_level=0; static int log_level_initialized=0; @@ -88,22 +64,12 @@ IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags, int chan_id) int iochan_is_alive(IOCHAN chan) { - static struct timeval to; - fd_set in, out, except; - int res, max; - - to.tv_sec = 0; - to.tv_usec = 0; - - FD_ZERO(&in); - FD_ZERO(&out); - FD_ZERO(&except); + struct yaz_poll_fd fds; + int res; - FD_SET(chan->fd, &in); - - max = chan->fd + 1; - - res = YAZ_EV_SELECT(max + 1, &in, 0, 0, &to); + fds.fd = chan->fd; + fds.input_mask = yaz_poll_read; + res = yaz_poll(&fds, 1, 0, 0); if (res == 0) return 1; if (!ir_read(chan, EVENT_INPUT)) @@ -111,21 +77,15 @@ int iochan_is_alive(IOCHAN chan) return 1; } -int event_loop(IOCHAN *iochans) +int iochan_event_loop(IOCHAN *iochans) { do /* loop as long as there are active associations to process */ { IOCHAN p, nextp; -#if NPOLL int i; int tv_sec = 3600; int no_fds = 0; struct yaz_poll_fd *fds = 0; -#else - fd_set in, out, except; - static struct timeval to; - int max; -#endif int res; time_t now = time(0); @@ -134,24 +94,23 @@ int event_loop(IOCHAN *iochans) for (p = *iochans; p; p = p->next) p->force_event = EVENT_TIMEOUT; } -#if NPOLL for (p = *iochans; p; p = p->next) no_fds++; - fds = xmalloc(no_fds * sizeof(*fds)); + fds = (struct yaz_poll_fd *) xmalloc(no_fds * sizeof(*fds)); for (i = 0, p = *iochans; p; p = p->next, i++) { time_t w, ftime; - enum yaz_poll_mask input_mask = 0; + enum yaz_poll_mask input_mask = yaz_poll_none; yaz_log(log_level, "fd=%d flags=%d force_event=%d", p->fd, p->flags, p->force_event); if (p->force_event) tv_sec = 0; /* polling select */ if (p->flags & EVENT_INPUT) - input_mask += yaz_poll_read; + yaz_poll_add(input_mask, yaz_poll_read); if (p->flags & EVENT_OUTPUT) - input_mask += yaz_poll_write; + yaz_poll_add(input_mask, yaz_poll_write); if (p->flags & EVENT_EXCEPT) - input_mask += yaz_poll_except; + yaz_poll_add(input_mask, yaz_poll_except); if (p->max_idle && p->last_event) { ftime = p->last_event + p->max_idle; @@ -165,44 +124,7 @@ int event_loop(IOCHAN *iochans) fds[i].fd = p->fd; fds[i].input_mask = input_mask; } - res = yaz_poll(fds, no_fds, tv_sec); -#else - FD_ZERO(&in); - FD_ZERO(&out); - FD_ZERO(&except); - to.tv_sec = 3600; - to.tv_usec = 0; - max = 0; - for (p = *iochans; p; p = p->next) - { - time_t w, ftime; - yaz_log(log_level, "fd=%d flags=%d force_event=%d", - p->fd, p->flags, p->force_event); - if (p->force_event) - to.tv_sec = 0; /* polling select */ - if (p->flags & EVENT_INPUT) - FD_SET(p->fd, &in); - if (p->flags & EVENT_OUTPUT) - FD_SET(p->fd, &out); - if (p->flags & EVENT_EXCEPT) - FD_SET(p->fd, &except); - if (p->fd > max) - max = p->fd; - if (p->max_idle && p->last_event) - { - ftime = p->last_event + p->max_idle; - if (ftime < now) - w = p->max_idle; - else - w = ftime - now; - if (w < to.tv_sec) - to.tv_sec = w; - } - } - yaz_log(log_level, "select start %ld", (long) to.tv_sec); - res = YAZ_EV_SELECT(max + 1, &in, &out, &except, &to); - yaz_log(log_level, "select end"); -#endif + res = yaz_poll(fds, no_fds, tv_sec, 0); if (res < 0) { if (yaz_errno() == EINTR) @@ -229,7 +151,6 @@ int event_loop(IOCHAN *iochans) } } now = time(0); -#if NPOLL for (i = 0, p = *iochans; p; p = p->next, i++) { int force_event = p->force_event; @@ -262,38 +183,6 @@ int event_loop(IOCHAN *iochans) } } xfree(fds); -#else - for (p = *iochans; p; p = p->next) - { - int force_event = p->force_event; - - p->force_event = 0; - if (!p->destroyed && (FD_ISSET(p->fd, &in) || - force_event == EVENT_INPUT)) - { - p->last_event = now; - (*p->fun)(p, EVENT_INPUT); - } - if (!p->destroyed && (FD_ISSET(p->fd, &out) || - force_event == EVENT_OUTPUT)) - { - p->last_event = now; - (*p->fun)(p, EVENT_OUTPUT); - } - if (!p->destroyed && (FD_ISSET(p->fd, &except) || - force_event == EVENT_EXCEPT)) - { - p->last_event = now; - (*p->fun)(p, EVENT_EXCEPT); - } - if (!p->destroyed && ((p->max_idle && now - p->last_event >= - p->max_idle) || force_event == EVENT_TIMEOUT)) - { - p->last_event = now; - (*p->fun)(p, EVENT_TIMEOUT); - } - } -#endif for (p = *iochans; p; p = nextp) { nextp = p->next;