2 * Copyright (C) 1994, Index Data I/S
4 * Sebastian Hammer, Adam Dickmeiss
7 * Revision 1.5 1995-03-15 08:37:41 quinn
8 * Now we're pretty much set for nonblocking I/O.
10 * Revision 1.4 1995/03/14 16:59:48 quinn
13 * Revision 1.3 1995/03/14 11:30:14 quinn
16 * Revision 1.2 1995/03/14 10:27:59 quinn
17 * More work on demo server.
19 * Revision 1.1 1995/03/10 18:22:44 quinn
20 * The rudiments of an asynchronous server.
26 #include <sys/types.h>
34 IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags)
38 if (!(new = malloc(sizeof(*new))))
55 fd_set in, out, except;
57 static struct timeval nullto = {0, 0};
58 struct timeval *timeout;
63 timeout = 0; /* hang on select */
65 for (p = iochans; p; p = p->next)
69 if (p->flags & EVENT_INPUT)
71 if (p->flags & EVENT_OUTPUT)
73 if (p->flags & EVENT_EXCEPT)
74 FD_SET(p->fd, &except);
78 if ((res = select(max + 1, &in, &out, &except, timeout)) < 0)
84 for (p = iochans; p; p = nextp)
86 int force_event = p->force_event;
90 if (FD_ISSET(p->fd, &in) || force_event == EVENT_INPUT)
91 (*p->fun)(p, EVENT_INPUT);
92 if (!p->destroyed && (FD_ISSET(p->fd, &out) ||
93 force_event == EVENT_OUTPUT))
94 (*p->fun)(p, EVENT_OUTPUT);
95 if (!p->destroyed && (FD_ISSET(p->fd, &except) ||
96 force_event == EVENT_EXCEPT))
97 (*p->fun)(p, EVENT_EXCEPT);
106 for (pr = iochans; pr; pr = pr->next)