]>
git.ipfire.org Git - thirdparty/squid.git/blob - src/comm/ModKqueue.cc
4 * DEBUG: section 05 Socket Functions
6 * SQUID Web Proxy Cache http://www.squid-cache.org/
7 * ----------------------------------------------------------
9 * Squid is the result of efforts by numerous individuals from
10 * the Internet community; see the CONTRIBUTORS file for full
11 * details. Many organizations have provided support for Squid's
12 * development; see the SPONSORS file for full details. Squid is
13 * Copyrighted (C) 2001 by the Regents of the University of
14 * California; see the COPYRIGHT file for full details. Squid
15 * incorporates software developed and/or copyrighted by other
16 * sources; see the CREDITS file for full details.
18 * This program is free software; you can redistribute it and/or modify
19 * it under the terms of the GNU General Public License as published by
20 * the Free Software Foundation; either version 2 of the License, or
21 * (at your option) any later version.
23 * This program is distributed in the hope that it will be useful,
24 * but WITHOUT ANY WARRANTY; without even the implied warranty of
25 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
26 * GNU General Public License for more details.
28 * You should have received a copy of the GNU General Public License
29 * along with this program; if not, write to the Free Software
30 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
35 * This code was originally written by Benno Rice and hacked on quite
36 * a bit by Adrian. Adrian then took it to the hybrid-ircd project to use
37 * in their new IO subsystem. After a year of modifications and some
38 * rather interesting changes (event aggregation) its back in squid.
39 * Thanks to the ircd-hybrid guys.
43 * XXX Currently not implemented / supported by this module XXX
47 * - flags.read_pending
49 * So, its not entirely useful in a production setup since if a read
50 * is meant to be deferred it isn't (we're not even throwing the event
51 * away here). Eventually the rest of the code will be rewritten
52 * so deferred reads aren't required.
58 #include "comm/Loops.h"
60 #include "SquidTime.h"
61 #include "StatCounters.h"
65 #include <sys/event.h>
73 /* jlemon goofed up and didn't add EV_SET until fbsd 4.3 */
76 #define EV_SET(kevp, a, b, c, d, e, f) do { \
77 (kevp)->ident = (a); \
78 (kevp)->filter = (b); \
79 (kevp)->flags = (c); \
80 (kevp)->fflags = (d); \
82 (kevp)->udata = (f); \
86 static void kq_update_events(int, short, PF
*);
89 static struct timespec zero_timespec
;
91 static struct kevent
*kqlst
; /* kevent buffer */
92 static int kqmax
; /* max structs to buffer */
93 static int kqoff
; /* offset into the buffer */
94 static int max_poll_time
= 1000;
96 static void commKQueueRegisterWithCacheManager(void);
98 /* XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX */
99 /* Private functions */
102 kq_update_events(int fd
, short filter
, PF
* handler
)
110 cur_handler
= fd_table
[fd
].read_handler
;
114 cur_handler
= fd_table
[fd
].write_handler
;
118 /* XXX bad! -- adrian */
123 if ((cur_handler
== NULL
&& handler
!= NULL
)
124 || (cur_handler
!= NULL
&& handler
== NULL
)) {
130 if (handler
!= NULL
) {
131 kep_flags
= (EV_ADD
| EV_ONESHOT
);
133 kep_flags
= EV_DELETE
;
136 EV_SET(kep
, (uintptr_t) fd
, filter
, kep_flags
, 0, 0, 0);
138 /* Check if we've used the last one. If we have then submit them all */
139 if (kqoff
== kqmax
- 1) {
142 ret
= kevent(kq
, kqlst
, kqmax
, NULL
, 0, &zero_timespec
);
143 /* jdc -- someone needs to do error checking... */
146 perror("kq_update_events(): kevent()");
159 /* XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX */
160 /* Public functions */
166 * This is a needed exported function which will be called to initialise
167 * the network loop code.
170 Comm::SelectLoopInit(void)
175 fatal("comm_select_init: Couldn't open kqueue fd!\n");
178 kqmax
= getdtablesize();
180 kqlst
= (struct kevent
*)xmalloc(sizeof(*kqlst
) * kqmax
);
181 zero_timespec
.tv_sec
= 0;
182 zero_timespec
.tv_nsec
= 0;
184 commKQueueRegisterWithCacheManager();
190 * This is a needed exported function which will be called to register
191 * and deregister interest in a pending IO state for a given FD.
194 Comm::SetSelect(int fd
, unsigned int type
, PF
* handler
, void *client_data
, time_t timeout
)
196 fde
*F
= &fd_table
[fd
];
198 assert(F
->flags
.open
);
199 debugs(5, 5, HERE
<< "FD " << fd
<< ", type=" << type
<<
200 ", handler=" << handler
<< ", client_data=" << client_data
<<
201 ", timeout=" << timeout
);
203 if (type
& COMM_SELECT_READ
) {
204 kq_update_events(fd
, EVFILT_READ
, handler
);
205 F
->read_handler
= handler
;
206 F
->read_data
= client_data
;
209 if (type
& COMM_SELECT_WRITE
) {
210 kq_update_events(fd
, EVFILT_WRITE
, handler
);
211 F
->write_handler
= handler
;
212 F
->write_data
= client_data
;
216 F
->timeout
= squid_curtime
+ timeout
;
221 Comm::ResetSelect(int fd
)
223 fde
*F
= &fd_table
[fd
];
224 if (F
->read_handler
) {
225 kq_update_events(fd
, EVFILT_READ
, (PF
*)1);
227 if (F
->write_handler
) {
228 kq_update_events(fd
, EVFILT_WRITE
, (PF
*)1);
233 * Check all connections for new connections and input data that is to be
234 * processed. Also check for connections with data queued and whether we can
241 * Called to do the new-style IO, courtesy of of squid (like most of this
242 * new IO code). This routine handles the stuff we've hidden in
243 * comm_setselect and fd_table[] and calls callbacks for IO ready
248 Comm::DoSelect(int msec
)
252 static struct kevent ke
[KE_LENGTH
];
254 struct timespec poll_time
;
256 if (msec
> max_poll_time
)
257 msec
= max_poll_time
;
259 poll_time
.tv_sec
= msec
/ 1000;
261 poll_time
.tv_nsec
= (msec
% 1000) * 1000000;
264 num
= kevent(kq
, kqlst
, kqoff
, ke
, KE_LENGTH
, &poll_time
);
265 ++statCounter
.select_loops
;
271 if (ignoreErrno(errno
))
284 return COMM_OK
; /* No error.. */
286 for (i
= 0; i
< num
; ++i
) {
287 int fd
= (int) ke
[i
].ident
;
289 fde
*F
= &fd_table
[fd
];
291 if (ke
[i
].flags
& EV_ERROR
) {
293 /* XXX error == bad! -- adrian */
297 switch (ke
[i
].filter
) {
301 if ((hdl
= F
->read_handler
) != NULL
) {
302 F
->read_handler
= NULL
;
303 F
->flags
.read_pending
= 0;
304 hdl(fd
, F
->read_data
);
311 if ((hdl
= F
->write_handler
) != NULL
) {
312 F
->write_handler
= NULL
;
313 hdl(fd
, F
->write_data
);
320 debugs(5, DBG_IMPORTANT
, "comm_select: kevent returned " << ke
[i
].filter
<< "!");
329 Comm::QuickPollRequired(void)
335 commKQueueRegisterWithCacheManager(void)
339 #endif /* USE_KQUEUE */