1 |
|
/* |
2 |
< |
* ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd). |
3 |
< |
* s_bsd_kqueue.c: FreeBSD kqueue compatible network routines. |
2 |
> |
* ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd) |
3 |
|
* |
4 |
< |
* Originally by Adrian Chadd <adrian@creative.net.au> |
6 |
< |
* Copyright (C) 2005 Hybrid Development Team |
4 |
> |
* Copyright (c) 2000-2014 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 |
17 |
|
* along with this program; if not, write to the Free Software |
18 |
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 |
19 |
|
* USA |
20 |
< |
* |
21 |
< |
* $Id$ |
20 |
> |
*/ |
21 |
> |
|
22 |
> |
/*! \file s_bsd_kqueue.c |
23 |
> |
* \brief kqueue() compatible network routines. |
24 |
> |
* \version $Id$ |
25 |
|
*/ |
26 |
|
|
27 |
|
#include "stdinc.h" |
29 |
|
#include <sys/event.h> |
30 |
|
#include "fdlist.h" |
31 |
|
#include "ircd.h" |
31 |
– |
#include "memory.h" |
32 |
|
#include "s_bsd.h" |
33 |
|
#include "log.h" |
34 |
|
|
35 |
|
#define KE_LENGTH 128 |
36 |
|
|
37 |
– |
/* jlemon goofed up and didn't add EV_SET until fbsd 4.3 */ |
38 |
– |
|
39 |
– |
#ifndef EV_SET |
40 |
– |
#define EV_SET(kevp, a, b, c, d, e, f) do { \ |
41 |
– |
(kevp)->ident = (a); \ |
42 |
– |
(kevp)->filter = (b); \ |
43 |
– |
(kevp)->flags = (c); \ |
44 |
– |
(kevp)->fflags = (d); \ |
45 |
– |
(kevp)->data = (e); \ |
46 |
– |
(kevp)->udata = (f); \ |
47 |
– |
} while(0) |
48 |
– |
#endif |
49 |
– |
|
37 |
|
static fde_t kqfd; |
38 |
|
static struct kevent kq_fdlist[KE_LENGTH]; /* kevent buffer */ |
39 |
|
static int kqoff; /* offset into the buffer */ |
40 |
|
|
41 |
+ |
|
42 |
|
/* |
43 |
|
* init_netio |
44 |
|
* |
105 |
|
} |
106 |
|
|
107 |
|
new_events = (F->read_handler ? COMM_SELECT_READ : 0) | |
108 |
< |
(F->write_handler ? COMM_SELECT_WRITE : 0); |
108 |
> |
(F->write_handler ? COMM_SELECT_WRITE : 0); |
109 |
|
|
110 |
|
if (timeout != 0) |
111 |
+ |
{ |
112 |
|
F->timeout = CurrentTime + (timeout / 1000); |
113 |
+ |
F->timeout_handler = handler; |
114 |
+ |
F->timeout_data = client_data; |
115 |
+ |
} |
116 |
|
|
117 |
|
diff = new_events ^ F->evcache; |
118 |
|
|
170 |
|
continue; |
171 |
|
|
172 |
|
if (ke[i].filter == EVFILT_READ) |
173 |
+ |
{ |
174 |
|
if ((hdl = F->read_handler) != NULL) |
175 |
|
{ |
176 |
|
F->read_handler = NULL; |
178 |
|
if (!F->flags.open) |
179 |
|
continue; |
180 |
|
} |
181 |
+ |
} |
182 |
|
|
183 |
|
if (ke[i].filter == EVFILT_WRITE) |
184 |
+ |
{ |
185 |
|
if ((hdl = F->write_handler) != NULL) |
186 |
|
{ |
187 |
|
F->write_handler = NULL; |
189 |
|
if (!F->flags.open) |
190 |
|
continue; |
191 |
|
} |
192 |
+ |
} |
193 |
|
|
194 |
|
comm_setselect(F, 0, NULL, NULL, 0); |
195 |
|
} |