ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/s_bsd_devpoll.c
Revision: 6560
Committed: Sat Oct 3 18:23:47 2015 UTC (8 years, 5 months ago) by michael
Content type: text/x-csrc
File size: 4672 byte(s)
Log Message:
- s_bsd_devpoll.c, s_bsd_epoll.c:init_netio(): we don't care about the real value of errno

File Contents

# User Rev Content
1 adx 30 /*
2 michael 2916 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 adx 30 *
4 michael 5347 * Copyright (c) 2001-2015 ircd-hybrid development team
5 adx 30 *
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 michael 4565 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 adx 30 * USA
20     */
21    
22 michael 2916 /*! \file s_bsd_devpoll.c
23     * \brief /dev/poll compatible network routines.
24     * \version $Id$
25     */
26    
27 adx 30 #include "stdinc.h"
28 stu 908 #if USE_IOPOLL_MECHANISM == __IOPOLL_MECHANISM_DEVPOLL
29 adx 30 #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 michael 1309 #include "log.h"
44 adx 30
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 michael 6560 ilog(LOG_TYPE_IRCD, "init_netio: couldn't open /dev/poll: %s",
61     strerror(errno));
62 michael 6553 exit(EXIT_FAILURE); /* Whee! */
63 adx 30 }
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 michael 1247 ilog(LOG_TYPE_IRCD, "devpoll_write_update: dpfd write failed %d: %s",
87 adx 30 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 michael 4461 comm_setselect(fde_t *F, unsigned int type, void (*handler)(fde_t *, void *),
98 adx 30 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 adx 282 new_events = (F->read_handler ? POLLIN : 0) |
115     (F->write_handler ? POLLOUT : 0);
116 adx 30
117     if (timeout != 0)
118 michael 2725 {
119 adx 30 F->timeout = CurrentTime + (timeout / 1000);
120 michael 2725 F->timeout_handler = handler;
121     F->timeout_data = client_data;
122     }
123 adx 30
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 michael 4461 void (*hdl)(fde_t *, void *);
147 adx 30 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 michael 6542 const struct timespec req = { .tv_sec = 0, .tv_nsec = 50000000 };
159     nanosleep(&req, NULL); /* Avoid 99% CPU in comm_select */
160 adx 30 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 adx 282 if ((dopoll.dp_fds[i].revents & POLLIN))
170 michael 2650 {
171 adx 30 if ((hdl = F->read_handler) != NULL)
172     {
173     F->read_handler = NULL;
174     hdl(F, F->read_data);
175 adx 242 if (!F->flags.open)
176     continue;
177 adx 30 }
178 michael 2650 }
179 adx 30
180 adx 282 if ((dopoll.dp_fds[i].revents & POLLOUT))
181 michael 2650 {
182 michael 2916 if ((hdl = F->write_handler) != NULL)
183 adx 30 {
184     F->write_handler = NULL;
185     hdl(F, F->write_data);
186 adx 242 if (!F->flags.open)
187     continue;
188 adx 30 }
189 michael 2650 }
190 adx 30
191     comm_setselect(F, 0, NULL, NULL, 0);
192     }
193     }
194 stu 908 #endif

Properties

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