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 _COMMIO_INT_H 1
30 #define RB_FD_HASH_BITS 12
31 #define RB_FD_HASH_SIZE (1UL << RB_FD_HASH_BITS)
32 #define RB_FD_HASH_MASK (RB_FD_HASH_SIZE-1)
34 #define FD_DESC_SZ 128 /* hostlen + comment */
38 #define rb_get_errno() do { errno = WSAGetLastError(); WSASetLastError(errno); } while(0)
40 #define rb_get_errno()
43 #define rb_hash_fd(x) ((x ^ (x >> RB_FD_HASH_BITS) ^ (x >> (RB_FD_HASH_BITS * 2))) & RB_FD_HASH_MASK)
47 # if defined(__FreeBSD__) || defined(__APPLE__) || defined(__NetBSD__)
48 /* FreeBSD 4.7 defines it in sys/uio.h only if _KERNEL is specified */
49 # define RB_UIO_MAXIOV 1024
51 /* IRIX 6.5 has sysconf(_SC_IOV_MAX) which might return 512 or bigger */
52 # define RB_UIO_MAXIOV 512
54 /* Solaris (and SunOS?) defines IOV_MAX instead */
56 # define RB_UIO_MAXIOV 16
58 # define RB_UIO_MAXIOV IOV_MAX
61 # elif defined(IOV_MAX)
62 # define RB_UIO_MAXIOV IOV_MAX
64 # define RB_UIO_MAXIOV 16
67 #define RB_UIO_MAXIOV UIO_MAXIOV
70 #define RB_UIO_MAXIOV 16
74 /* We don't need the host here ? */
75 struct rb_sockaddr_storage S
;
76 struct rb_sockaddr_storage hostaddr
;
80 /* We'd also add the retry count here when we get to that -- adrian */
85 struct rb_sockaddr_storage S
;
92 /* Only have open flags for now, could be more later */
94 #define IsFDOpen(F) (F->flags & FLAG_OPEN)
95 #define SetFDOpen(F) (F->flags |= FLAG_OPEN)
96 #define ClearFDOpen(F) (F->flags &= ~FLAG_OPEN)
101 /* New-school stuff, again pretty much ripped from squid */
103 * Yes, this gives us only one pending read and one pending write per
104 * filedescriptor. Think though: when do you think we'll need more?
107 int fd
; /* So we can use the rb_fde_t as a callback ptr */
116 struct timeout_data
*timeout
;
117 struct conndata
*connect
;
118 struct acceptdata
*accept
;
120 unsigned int handshake_count
;
121 unsigned long ssl_errno
;
124 typedef void (*comm_event_cb_t
) (void *);
126 #ifdef USE_TIMER_CREATE
127 typedef struct timer_data
130 comm_event_cb_t td_cb
;
136 extern rb_dlink_list
*rb_fd_table
;
138 static inline rb_fde_t
*
141 rb_dlink_list
*hlist
;
144 if(rb_unlikely(fd
< 0))
147 hlist
= &rb_fd_table
[rb_hash_fd(fd
)];
149 if(hlist
->head
== NULL
)
152 RB_DLINK_FOREACH(ptr
, hlist
->head
)
154 rb_fde_t
*F
= ptr
->data
;
162 int rb_setup_fd(rb_fde_t
*F
);
163 void rb_connect_callback(rb_fde_t
*F
, int status
);
166 int rb_io_sched_event(struct ev_entry
*ev
, int when
);
167 void rb_io_unsched_event(struct ev_entry
*ev
);
168 int rb_io_supports_event(void);
169 void rb_io_init_event(void);
172 void rb_setselect_epoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
173 int rb_init_netio_epoll(void);
174 int rb_select_epoll(long);
175 int rb_setup_fd_epoll(rb_fde_t
*F
);
177 void rb_epoll_init_event(void);
178 int rb_epoll_sched_event(struct ev_entry
*event
, int when
);
179 void rb_epoll_unsched_event(struct ev_entry
*event
);
180 int rb_epoll_supports_event(void);
184 void rb_setselect_poll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
185 int rb_init_netio_poll(void);
186 int rb_select_poll(long);
187 int rb_setup_fd_poll(rb_fde_t
*F
);
189 /* devpoll versions */
190 void rb_setselect_devpoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
191 int rb_init_netio_devpoll(void);
192 int rb_select_devpoll(long);
193 int rb_setup_fd_devpoll(rb_fde_t
*F
);
196 void rb_setselect_sigio(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
197 int rb_init_netio_sigio(void);
198 int rb_select_sigio(long);
199 int rb_setup_fd_sigio(rb_fde_t
*F
);
201 void rb_sigio_init_event(void);
202 int rb_sigio_sched_event(struct ev_entry
*event
, int when
);
203 void rb_sigio_unsched_event(struct ev_entry
*event
);
204 int rb_sigio_supports_event(void);
208 void rb_setselect_ports(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
209 int rb_init_netio_ports(void);
210 int rb_select_ports(long);
211 int rb_setup_fd_ports(rb_fde_t
*F
);
213 void rb_ports_init_event(void);
214 int rb_ports_sched_event(struct ev_entry
*event
, int when
);
215 void rb_ports_unsched_event(struct ev_entry
*event
);
216 int rb_ports_supports_event(void);
219 /* kqueue versions */
220 void rb_setselect_kqueue(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
221 int rb_init_netio_kqueue(void);
222 int rb_select_kqueue(long);
223 int rb_setup_fd_kqueue(rb_fde_t
*F
);
225 void rb_kqueue_init_event(void);
226 int rb_kqueue_sched_event(struct ev_entry
*event
, int when
);
227 void rb_kqueue_unsched_event(struct ev_entry
*event
);
228 int rb_kqueue_supports_event(void);
231 /* select versions */
232 void rb_setselect_select(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
233 int rb_init_netio_select(void);
234 int rb_select_select(long);
235 int rb_setup_fd_select(rb_fde_t
*F
);
238 void rb_setselect_win32(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
239 int rb_init_netio_win32(void);
240 int rb_select_win32(long);
241 int rb_setup_fd_win32(rb_fde_t
*F
);