2 * ircd-ratbox: A slightly useful ircd.
3 * commio-int.h: A header for the network subsystem.
5 * Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center
6 * Copyright (C) 1996-2002 Hybrid Development Team
7 * Copyright (C) 2002-2007 ircd-ratbox development team
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
24 * $Id: commio.h 24059 2007-07-24 17:25:41Z androsyn $
28 #define RB_FD_HASH_BITS 12
29 #define RB_FD_HASH_SIZE (1UL << RB_FD_HASH_BITS)
30 #define RB_FD_HASH_MASK (RB_FD_HASH_SIZE-1)
32 #define FD_DESC_SZ 128 /* hostlen + comment */
36 #define rb_get_errno() do { errno = WSAGetLastError(); WSASetLastError(errno); } while(0)
38 #define rb_get_errno()
41 #define rb_hash_fd(x) ((x ^ (x >> RB_FD_HASH_BITS) ^ (x >> (RB_FD_HASH_BITS * 2))) & RB_FD_HASH_MASK)
45 # if defined(__FreeBSD__) || defined(__APPLE__) || defined(__NetBSD__)
46 /* FreeBSD 4.7 defines it in sys/uio.h only if _KERNEL is specified */
47 # define RB_UIO_MAXIOV 1024
49 /* IRIX 6.5 has sysconf(_SC_IOV_MAX) which might return 512 or bigger */
50 # define RB_UIO_MAXIOV 512
52 /* Solaris (and SunOS?) defines IOV_MAX instead */
54 # define RB_UIO_MAXIOV 16
56 # define RB_UIO_MAXIOV IOV_MAX
59 # elif defined(IOV_MAX)
60 # define RB_UIO_MAXIOV IOV_MAX
62 # define RB_UIO_MAXIOV 16
65 #define RB_UIO_MAXIOV UIO_MAXIOV
68 #define RB_UIO_MAXIOV 16
72 /* We don't need the host here ? */
73 struct rb_sockaddr_storage S
;
74 struct rb_sockaddr_storage hostaddr
;
78 /* We'd also add the retry count here when we get to that -- adrian */
83 struct rb_sockaddr_storage S
;
90 /* Only have open flags for now, could be more later */
92 #define IsFDOpen(F) (F->flags & FLAG_OPEN)
93 #define SetFDOpen(F) (F->flags |= FLAG_OPEN)
94 #define ClearFDOpen(F) (F->flags &= ~FLAG_OPEN)
99 /* New-school stuff, again pretty much ripped from squid */
101 * Yes, this gives us only one pending read and one pending write per
102 * filedescriptor. Think though: when do you think we'll need more?
105 int fd
; /* So we can use the rb_fde_t as a callback ptr */
114 struct timeout_data
*timeout
;
115 struct conndata
*connect
;
116 struct acceptdata
*accept
;
118 unsigned int handshake_count
;
119 unsigned long ssl_errno
;
122 typedef void (*comm_event_cb_t
) (void *);
124 #ifdef USE_TIMER_CREATE
125 typedef struct timer_data
128 comm_event_cb_t td_cb
;
134 extern rb_dlink_list
*rb_fd_table
;
136 static inline rb_fde_t
*
139 rb_dlink_list
*hlist
;
142 if(rb_unlikely(fd
< 0))
145 hlist
= &rb_fd_table
[rb_hash_fd(fd
)];
147 if(hlist
->head
== NULL
)
150 RB_DLINK_FOREACH(ptr
, hlist
->head
)
152 rb_fde_t
*F
= ptr
->data
;
160 int rb_setup_fd(rb_fde_t
*F
);
161 void rb_connect_callback(rb_fde_t
*F
, int status
);
164 int rb_io_sched_event(struct ev_entry
*ev
, int when
);
165 void rb_io_unsched_event(struct ev_entry
*ev
);
166 int rb_io_supports_event(void);
167 void rb_io_init_event(void);
170 void rb_setselect_epoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
171 int rb_init_netio_epoll(void);
172 int rb_select_epoll(long);
173 int rb_setup_fd_epoll(rb_fde_t
*F
);
175 void rb_epoll_init_event(void);
176 int rb_epoll_sched_event(struct ev_entry
*event
, int when
);
177 void rb_epoll_unsched_event(struct ev_entry
*event
);
178 int rb_epoll_supports_event(void);
182 void rb_setselect_poll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
183 int rb_init_netio_poll(void);
184 int rb_select_poll(long);
185 int rb_setup_fd_poll(rb_fde_t
*F
);
187 /* devpoll versions */
188 void rb_setselect_devpoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
189 int rb_init_netio_devpoll(void);
190 int rb_select_devpoll(long);
191 int rb_setup_fd_devpoll(rb_fde_t
*F
);
194 void rb_setselect_sigio(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
195 int rb_init_netio_sigio(void);
196 int rb_select_sigio(long);
197 int rb_setup_fd_sigio(rb_fde_t
*F
);
199 void rb_sigio_init_event(void);
200 int rb_sigio_sched_event(struct ev_entry
*event
, int when
);
201 void rb_sigio_unsched_event(struct ev_entry
*event
);
202 int rb_sigio_supports_event(void);
206 void rb_setselect_ports(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
207 int rb_init_netio_ports(void);
208 int rb_select_ports(long);
209 int rb_setup_fd_ports(rb_fde_t
*F
);
211 /* kqueue versions */
212 void rb_setselect_kqueue(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
213 int rb_init_netio_kqueue(void);
214 int rb_select_kqueue(long);
215 int rb_setup_fd_kqueue(rb_fde_t
*F
);
217 void rb_kqueue_init_event(void);
218 int rb_kqueue_sched_event(struct ev_entry
*event
, int when
);
219 void rb_kqueue_unsched_event(struct ev_entry
*event
);
220 int rb_kqueue_supports_event(void);
223 /* select versions */
224 void rb_setselect_select(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
225 int rb_init_netio_select(void);
226 int rb_select_select(long);
227 int rb_setup_fd_select(rb_fde_t
*F
);
230 void rb_setselect_win32(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
231 int rb_init_netio_win32(void);
232 int rb_select_win32(long);
233 int rb_setup_fd_win32(rb_fde_t
*F
);