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)
38 # if defined(__FreeBSD__) || defined(__APPLE__) || defined(__NetBSD__)
39 /* FreeBSD 4.7 defines it in sys/uio.h only if _KERNEL is specified */
40 # define RB_UIO_MAXIOV 1024
42 /* IRIX 6.5 has sysconf(_SC_IOV_MAX) which might return 512 or bigger */
43 # define RB_UIO_MAXIOV 512
45 /* Solaris (and SunOS?) defines IOV_MAX instead */
47 # define RB_UIO_MAXIOV 16
49 # define RB_UIO_MAXIOV IOV_MAX
52 # elif defined(IOV_MAX)
53 # define RB_UIO_MAXIOV IOV_MAX
55 # define RB_UIO_MAXIOV 16
58 #define RB_UIO_MAXIOV UIO_MAXIOV
62 /* We don't need the host here ? */
63 struct rb_sockaddr_storage S
;
64 struct rb_sockaddr_storage hostaddr
;
68 /* We'd also add the retry count here when we get to that -- adrian */
73 struct rb_sockaddr_storage S
;
80 /* Only have open flags for now, could be more later */
82 #define IsFDOpen(F) (F->flags & FLAG_OPEN)
83 #define SetFDOpen(F) (F->flags |= FLAG_OPEN)
84 #define ClearFDOpen(F) (F->flags &= ~FLAG_OPEN)
88 /* New-school stuff, again pretty much ripped from squid */
90 * Yes, this gives us only one pending read and one pending write per
91 * filedescriptor. Think though: when do you think we'll need more?
94 int fd
; /* So we can use the rb_fde_t as a callback ptr */
103 struct timeout_data
*timeout
;
104 struct conndata
*connect
;
105 struct acceptdata
*accept
;
107 unsigned int handshake_count
;
108 unsigned long ssl_errno
;
111 typedef void (*comm_event_cb_t
) (void *);
113 #ifdef USE_TIMER_CREATE
114 typedef struct timer_data
117 comm_event_cb_t td_cb
;
123 extern rb_dlink_list
*rb_fd_table
;
125 static inline rb_fde_t
*
128 rb_dlink_list
*hlist
;
131 if(rb_unlikely(fd
< 0))
134 hlist
= &rb_fd_table
[rb_hash_fd(fd
)];
136 if(hlist
->head
== NULL
)
139 RB_DLINK_FOREACH(ptr
, hlist
->head
)
141 rb_fde_t
*F
= ptr
->data
;
149 int rb_setup_fd(rb_fde_t
*F
);
150 void rb_connect_callback(rb_fde_t
*F
, int status
);
153 int rb_io_sched_event(struct ev_entry
*ev
, int when
);
154 void rb_io_unsched_event(struct ev_entry
*ev
);
155 int rb_io_supports_event(void);
156 void rb_io_init_event(void);
159 void rb_setselect_epoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
160 int rb_init_netio_epoll(void);
161 int rb_select_epoll(long);
162 int rb_setup_fd_epoll(rb_fde_t
*F
);
164 void rb_epoll_init_event(void);
165 int rb_epoll_sched_event(struct ev_entry
*event
, int when
);
166 void rb_epoll_unsched_event(struct ev_entry
*event
);
167 int rb_epoll_supports_event(void);
171 void rb_setselect_poll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
172 int rb_init_netio_poll(void);
173 int rb_select_poll(long);
174 int rb_setup_fd_poll(rb_fde_t
*F
);
176 /* devpoll versions */
177 void rb_setselect_devpoll(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
178 int rb_init_netio_devpoll(void);
179 int rb_select_devpoll(long);
180 int rb_setup_fd_devpoll(rb_fde_t
*F
);
183 void rb_setselect_sigio(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
184 int rb_init_netio_sigio(void);
185 int rb_select_sigio(long);
186 int rb_setup_fd_sigio(rb_fde_t
*F
);
188 void rb_sigio_init_event(void);
189 int rb_sigio_sched_event(struct ev_entry
*event
, int when
);
190 void rb_sigio_unsched_event(struct ev_entry
*event
);
191 int rb_sigio_supports_event(void);
195 void rb_setselect_ports(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
196 int rb_init_netio_ports(void);
197 int rb_select_ports(long);
198 int rb_setup_fd_ports(rb_fde_t
*F
);
200 void rb_ports_init_event(void);
201 int rb_ports_sched_event(struct ev_entry
*event
, int when
);
202 void rb_ports_unsched_event(struct ev_entry
*event
);
203 int rb_ports_supports_event(void);
206 /* kqueue versions */
207 void rb_setselect_kqueue(rb_fde_t
*F
, unsigned int type
, PF
* handler
, void *client_data
);
208 int rb_init_netio_kqueue(void);
209 int rb_select_kqueue(long);
210 int rb_setup_fd_kqueue(rb_fde_t
*F
);
212 void rb_kqueue_init_event(void);
213 int rb_kqueue_sched_event(struct ev_entry
*event
, int when
);
214 void rb_kqueue_unsched_event(struct ev_entry
*event
);
215 int rb_kqueue_supports_event(void);