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
27 #define _COMMIO_INT_H 1
29 #define RB_FD_HASH_BITS 12
30 #define RB_FD_HASH_SIZE (1UL << RB_FD_HASH_BITS)
31 #define RB_FD_HASH_MASK (RB_FD_HASH_SIZE-1)
33 #define FD_DESC_SZ 128 /* hostlen + comment */
35 #define rb_hash_fd(x) ((x ^ (x >> RB_FD_HASH_BITS) ^ (x >> (RB_FD_HASH_BITS * 2))) & RB_FD_HASH_MASK)
39 # if defined(__FreeBSD__) || defined(__APPLE__) || defined(__NetBSD__)
40 /* FreeBSD 4.7 defines it in sys/uio.h only if _KERNEL is specified */
41 # define RB_UIO_MAXIOV 1024
43 /* IRIX 6.5 has sysconf(_SC_IOV_MAX) which might return 512 or bigger */
44 # define RB_UIO_MAXIOV 512
46 /* Solaris (and SunOS?) defines IOV_MAX instead */
48 # define RB_UIO_MAXIOV 16
50 # define RB_UIO_MAXIOV IOV_MAX
53 # elif defined(IOV_MAX)
54 # define RB_UIO_MAXIOV IOV_MAX
56 # define RB_UIO_MAXIOV 16
59 #define RB_UIO_MAXIOV UIO_MAXIOV
62 #define RB_UIO_MAXIOV 16
66 /* We don't need the host here ? */
67 struct rb_sockaddr_storage S
;
68 struct rb_sockaddr_storage hostaddr
;
72 /* We'd also add the retry count here when we get to that -- adrian */
77 struct rb_sockaddr_storage S
;
84 /* Only have open flags for now, could be more later */
86 #define IsFDOpen(F) (F->flags & FLAG_OPEN)
87 #define SetFDOpen(F) (F->flags |= FLAG_OPEN)
88 #define ClearFDOpen(F) (F->flags &= ~FLAG_OPEN)
93 /* New-school stuff, again pretty much ripped from squid */
95 * Yes, this gives us only one pending read and one pending write per
96 * filedescriptor. Think though: when do you think we'll need more?
99 rb_platform_fd_t fd
; /* So we can use the rb_fde_t as a callback ptr */
108 struct timeout_data
*timeout
;
109 struct conndata
*connect
;
110 struct acceptdata
*accept
;
112 unsigned int handshake_count
;
113 unsigned long ssl_errno
;
116 typedef void (*comm_event_cb_t
) (void *);
118 #ifdef USE_TIMER_CREATE
119 typedef struct timer_data
122 comm_event_cb_t td_cb
;
128 extern rb_dlink_list
*rb_fd_table
;
130 static inline rb_fde_t
*
131 rb_find_fd(rb_platform_fd_t fd
)
133 rb_dlink_list
*hlist
;
136 if(rb_unlikely(fd
< 0))
139 hlist
= &rb_fd_table
[rb_hash_fd(fd
)];
141 if(hlist
->head
== NULL
)
144 RB_DLINK_FOREACH(ptr
, hlist
->head
)
146 rb_fde_t
*F
= ptr
->data
;
154 int rb_setup_fd(rb_fde_t
*F
);
155 void rb_connect_callback(rb_fde_t
*F
, int status
);
158 int rb_io_sched_event(struct ev_entry
*ev
, int when
);
159 void rb_io_unsched_event(struct ev_entry
*ev
);
160 int rb_io_supports_event(void);
161 void rb_io_init_event(void);
164 void rb_setselect_epoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
165 int rb_init_netio_epoll(void);
166 int rb_select_epoll(long);
167 int rb_setup_fd_epoll(rb_fde_t
*F
);
169 void rb_epoll_init_event(void);
170 int rb_epoll_sched_event(struct ev_entry
*event
, int when
);
171 void rb_epoll_unsched_event(struct ev_entry
*event
);
172 int rb_epoll_supports_event(void);
176 void rb_setselect_poll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
177 int rb_init_netio_poll(void);
178 int rb_select_poll(long);
179 int rb_setup_fd_poll(rb_fde_t
*F
);
181 /* devpoll versions */
182 void rb_setselect_devpoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
183 int rb_init_netio_devpoll(void);
184 int rb_select_devpoll(long);
185 int rb_setup_fd_devpoll(rb_fde_t
*F
);
188 void rb_setselect_sigio(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
189 int rb_init_netio_sigio(void);
190 int rb_select_sigio(long);
191 int rb_setup_fd_sigio(rb_fde_t
*F
);
193 void rb_sigio_init_event(void);
194 int rb_sigio_sched_event(struct ev_entry
*event
, int when
);
195 void rb_sigio_unsched_event(struct ev_entry
*event
);
196 int rb_sigio_supports_event(void);
200 void rb_setselect_ports(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
201 int rb_init_netio_ports(void);
202 int rb_select_ports(long);
203 int rb_setup_fd_ports(rb_fde_t
*F
);
205 void rb_ports_init_event(void);
206 int rb_ports_sched_event(struct ev_entry
*event
, int when
);
207 void rb_ports_unsched_event(struct ev_entry
*event
);
208 int rb_ports_supports_event(void);
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
);