1 /* $Id: eventl.c,v 1.7 2007-07-09 19:30:35 adam Exp $
2 Copyright (c) 2006-2007, Index Data.
4 This file is part of Pazpar2.
6 Pazpar2 is free software; you can redistribute it and/or modify it under
7 the terms of the GNU General Public License as published by the Free
8 Software Foundation; either version 2, or (at your option) any later
11 Pazpar2 is distributed in the hope that it will be useful, but WITHOUT ANY
12 WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
16 You should have received a copy of the GNU General Public License
17 along with Pazpar2; see the file LICENSE. If not, write to the
18 Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
23 * Based on ParaZ - a simple tool for harvesting performance data for
24 * parallel operations using Z39.50.
25 * Copyright (c) 2000-2004 Index Data ApS
26 * See LICENSE file for details.
30 * Based on revision YAZ' server/eventl.c 1.29.
50 #include <yaz/yconfig.h>
52 #include <yaz/comstack.h>
53 #include <yaz/xmalloc.h>
55 #include <yaz/statserv.h>
57 IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags)
61 if (!(new_iochan = (IOCHAN)xmalloc(sizeof(*new_iochan))))
63 new_iochan->destroyed = 0;
65 new_iochan->flags = flags;
67 new_iochan->force_event = 0;
68 new_iochan->last_event = new_iochan->max_idle = 0;
69 new_iochan->next = NULL;
73 int event_loop(IOCHAN *iochans)
75 do /* loop as long as there are active associations to process */
78 fd_set in, out, except;
80 static struct timeval nullto = {0, 0}, to;
81 struct timeval *timeout;
86 timeout = &to; /* hang on select */
90 for (p = *iochans; p; p = p->next)
95 timeout = &nullto; /* polling select */
96 if (p->flags & EVENT_INPUT)
98 if (p->flags & EVENT_OUTPUT)
100 if (p->flags & EVENT_EXCEPT)
101 FD_SET(p->fd, &except);
104 if (p->max_idle && p->max_idle < to.tv_sec)
105 to.tv_sec = p->max_idle;
107 if ((res = select(max + 1, &in, &out, &except, timeout)) < 0)
114 for (p = *iochans; p; p = p->next)
116 int force_event = p->force_event;
117 time_t now = time(0);
120 if (!p->destroyed && ((p->max_idle && now - p->last_event >
121 p->max_idle) || force_event == EVENT_TIMEOUT))
124 (*p->fun)(p, EVENT_TIMEOUT);
128 if (!p->destroyed && (FD_ISSET(p->fd, &in) ||
129 force_event == EVENT_INPUT))
132 (*p->fun)(p, EVENT_INPUT);
134 if (!p->destroyed && (FD_ISSET(p->fd, &out) ||
135 force_event == EVENT_OUTPUT))
138 (*p->fun)(p, EVENT_OUTPUT);
140 if (!p->destroyed && (FD_ISSET(p->fd, &except) ||
141 force_event == EVENT_EXCEPT))
144 (*p->fun)(p, EVENT_EXCEPT);
147 for (p = *iochans; p; p = nextp)
155 /* Now reset the pointers */
160 for (pr = *iochans; pr; pr = pr->next)
163 assert(pr); /* grave error if it weren't there */
179 * indent-tabs-mode: nil
181 * vim: shiftwidth=4 tabstop=8 expandtab