/[svn]/ircd-hybrid/branches/8.2.x/src/s_bsd_devpoll.c
ViewVC logotype

Contents of /ircd-hybrid/branches/8.2.x/src/s_bsd_devpoll.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 6554 - (show annotations)
Sat Oct 3 16:56:36 2015 UTC (4 years, 11 months ago) by michael
File MIME type: text/x-chdr
File size: 4684 byte(s)
- Use EXIT_FAILURE in some places instead of hardcoded values

1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 2001-2015 ircd-hybrid development team
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 * USA
20 */
21
22 /*! \file s_bsd_devpoll.c
23 * \brief /dev/poll compatible network routines.
24 * \version $Id$
25 */
26
27 #include "stdinc.h"
28 #if USE_IOPOLL_MECHANISM == __IOPOLL_MECHANISM_DEVPOLL
29 #include <sys/ioctl.h>
30 /* HPUX uses devpoll.h and not sys/devpoll.h */
31 #ifdef HAVE_DEVPOLL_H
32 # include <devpoll.h>
33 #else
34 # ifdef HAVE_SYS_DEVPOLL_H
35 # include <sys/devpoll.h>
36 # else
37 # error "No devpoll.h found! Try ./configuring and letting the script choose for you."
38 # endif
39 #endif
40 #include "fdlist.h"
41 #include "ircd.h"
42 #include "s_bsd.h"
43 #include "log.h"
44
45 static fde_t dpfd;
46
47 /*
48 * init_netio
49 *
50 * This is a needed exported function which will be called to initialise
51 * the network loop code.
52 */
53 void
54 init_netio(void)
55 {
56 int fd;
57
58 if ((fd = open("/dev/poll", O_RDWR)) < 0)
59 {
60 ilog(LOG_TYPE_IRCD, "init_netio: Couldn't open /dev/poll - %d: %s",
61 errno, strerror(errno));
62 exit(EXIT_FAILURE); /* Whee! */
63 }
64
65 fd_open(&dpfd, fd, 0, "/dev/poll file descriptor");
66 }
67
68 /*
69 * Write an update to the devpoll filter.
70 * See, we end up having to do a seperate (?) remove before we do an
71 * add of a new polltype, so we have to have this function seperate from
72 * the others.
73 */
74 static void
75 devpoll_write_update(int fd, int events)
76 {
77 struct pollfd pfd;
78
79 /* Build the pollfd entry */
80 pfd.revents = 0;
81 pfd.fd = fd;
82 pfd.events = events;
83
84 /* Write the thing to our poll fd */
85 if (write(dpfd.fd, &pfd, sizeof(pfd)) != sizeof(pfd))
86 ilog(LOG_TYPE_IRCD, "devpoll_write_update: dpfd write failed %d: %s",
87 errno, strerror(errno));
88 }
89
90 /*
91 * comm_setselect
92 *
93 * This is a needed exported function which will be called to register
94 * and deregister interest in a pending IO state for a given FD.
95 */
96 void
97 comm_setselect(fde_t *F, unsigned int type, void (*handler)(fde_t *, void *),
98 void *client_data, time_t timeout)
99 {
100 int new_events;
101
102 if ((type & COMM_SELECT_READ))
103 {
104 F->read_handler = handler;
105 F->read_data = client_data;
106 }
107
108 if ((type & COMM_SELECT_WRITE))
109 {
110 F->write_handler = handler;
111 F->write_data = client_data;
112 }
113
114 new_events = (F->read_handler ? POLLIN : 0) |
115 (F->write_handler ? POLLOUT : 0);
116
117 if (timeout != 0)
118 {
119 F->timeout = CurrentTime + (timeout / 1000);
120 F->timeout_handler = handler;
121 F->timeout_data = client_data;
122 }
123
124 if (new_events != F->evcache)
125 {
126 devpoll_write_update(F->fd, POLLREMOVE);
127 if ((F->evcache = new_events))
128 devpoll_write_update(F->fd, new_events);
129 }
130 }
131
132 /*
133 * comm_select
134 *
135 * Called to do the new-style IO, courtesy of squid (like most of this
136 * new IO code). This routine handles the stuff we've hidden in
137 * comm_setselect and fd_table[] and calls callbacks for IO ready
138 * events.
139 */
140 void
141 comm_select(void)
142 {
143 int num, i;
144 struct pollfd pollfds[128];
145 struct dvpoll dopoll;
146 void (*hdl)(fde_t *, void *);
147 fde_t *F;
148
149 dopoll.dp_timeout = SELECT_DELAY;
150 dopoll.dp_nfds = 128;
151 dopoll.dp_fds = &pollfds[0];
152 num = ioctl(dpfd.fd, DP_POLL, &dopoll);
153
154 set_time();
155
156 if (num < 0)
157 {
158 const struct timespec req = { .tv_sec = 0, .tv_nsec = 50000000 };
159 nanosleep(&req, NULL); /* Avoid 99% CPU in comm_select */
160 return;
161 }
162
163 for (i = 0; i < num; i++)
164 {
165 F = lookup_fd(dopoll.dp_fds[i].fd);
166 if (F == NULL || !F->flags.open)
167 continue;
168
169 if ((dopoll.dp_fds[i].revents & POLLIN))
170 {
171 if ((hdl = F->read_handler) != NULL)
172 {
173 F->read_handler = NULL;
174 hdl(F, F->read_data);
175 if (!F->flags.open)
176 continue;
177 }
178 }
179
180 if ((dopoll.dp_fds[i].revents & POLLOUT))
181 {
182 if ((hdl = F->write_handler) != NULL)
183 {
184 F->write_handler = NULL;
185 hdl(F, F->write_data);
186 if (!F->flags.open)
187 continue;
188 }
189 }
190
191 comm_setselect(F, 0, NULL, NULL, 0);
192 }
193 }
194 #endif

Properties

Name Value
svn:eol-style native
svn:keywords Id Revision

svnadmin@ircd-hybrid.org
ViewVC Help
Powered by ViewVC 1.1.28