2 * ircd-ratbox: A slightly useful ircd.
3 * listener.c: Listens on a port.
5 * Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center
6 * Copyright (C) 1996-2002 Hybrid Development Team
7 * Copyright (C) 2002-2005 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307
24 * $Id: listener.c 3460 2007-05-18 20:31:33Z jilles $
31 #include "irc_string.h"
32 #include "sprintf_irc.h"
34 #include "ircd_defs.h"
37 #include "s_newconf.h"
46 #define INADDR_NONE ((unsigned int) 0xffffffff)
49 #if defined(NO_IN6ADDR_ANY) && defined(IPV6)
50 static const struct in6_addr in6addr_any
=
51 { { { 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 } } };
54 static listener_t
*ListenerPollList
= NULL
;
55 static int accept_precallback(rb_fde_t
*F
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
);
56 static void accept_callback(rb_fde_t
*F
, int status
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
);
59 make_listener(struct rb_sockaddr_storage
*addr
)
61 listener_t
*listener
= (listener_t
*) rb_malloc(sizeof(listener_t
));
62 s_assert(0 != listener
);
63 listener
->name
= me
.name
;
66 memcpy(&listener
->addr
, addr
, sizeof(struct rb_sockaddr_storage
));
67 listener
->next
= NULL
;
72 free_listener(listener_t
*listener
)
74 s_assert(NULL
!= listener
);
78 * remove from listener list
80 if(listener
== ListenerPollList
)
81 ListenerPollList
= listener
->next
;
84 listener_t
*prev
= ListenerPollList
;
85 for (; prev
; prev
= prev
->next
)
87 if(listener
== prev
->next
)
89 prev
->next
= listener
->next
;
99 #define PORTNAMELEN 6 /* ":31337" */
102 * get_listener_name - return displayable listener name and port
103 * returns "host.foo.org:6667" for a given listener
106 get_listener_name(const listener_t
*listener
)
108 static char buf
[HOSTLEN
+ HOSTLEN
+ PORTNAMELEN
+ 4];
111 s_assert(NULL
!= listener
);
116 if(listener
->addr
.ss_family
== AF_INET6
)
117 port
= ntohs(((const struct sockaddr_in6
*)&listener
->addr
)->sin6_port
);
120 port
= ntohs(((const struct sockaddr_in
*)&listener
->addr
)->sin_port
);
122 rb_snprintf(buf
, sizeof(buf
), "%s[%s/%u]", me
.name
, listener
->name
, port
);
127 * show_ports - send port listing to a client
128 * inputs - pointer to client to show ports to
130 * side effects - show ports
133 show_ports(struct Client
*source_p
)
135 listener_t
*listener
= 0;
137 for (listener
= ListenerPollList
; listener
; listener
= listener
->next
)
139 sendto_one_numeric(source_p
, RPL_STATSPLINE
,
140 form_str(RPL_STATSPLINE
), 'P',
142 ntohs(listener
->addr
.ss_family
== AF_INET
? ((struct sockaddr_in
*)&listener
->addr
)->sin_port
:
143 ((struct sockaddr_in6
*)&listener
->addr
)->sin6_port
),
145 ntohs(((struct sockaddr_in
*)&listener
->addr
)->sin_port
),
147 IsOperAdmin(source_p
) ? listener
->name
: me
.name
,
148 listener
->ref_count
, (listener
->active
) ? "active" : "disabled");
153 * inetport - create a listener socket in the AF_INET or AF_INET6 domain,
154 * bind it to the port given in 'port' and listen to it
155 * returns true (1) if successful false (0) on error.
157 * If the operating system has a define for SOMAXCONN, use it, otherwise
158 * use RATBOX_SOMAXCONN
161 #undef RATBOX_SOMAXCONN
162 #define RATBOX_SOMAXCONN SOMAXCONN
166 inetport(listener_t
*listener
)
173 * At first, open a new socket
176 F
= rb_socket(GET_SS_FAMILY(&listener
->addr
), SOCK_STREAM
, 0, "Listener socket");
179 if(listener
->addr
.ss_family
== AF_INET6
)
181 struct sockaddr_in6
*in6
= (struct sockaddr_in6
*)&listener
->addr
;
182 if(!IN6_ARE_ADDR_EQUAL(&in6
->sin6_addr
, &in6addr_any
))
184 inetntop(AF_INET6
, &in6
->sin6_addr
, listener
->vhost
, sizeof(listener
->vhost
));
185 listener
->name
= listener
->vhost
;
190 struct sockaddr_in
*in
= (struct sockaddr_in
*)&listener
->addr
;
191 if(in
->sin_addr
.s_addr
!= INADDR_ANY
)
193 inetntop(AF_INET
, &in
->sin_addr
, listener
->vhost
, sizeof(listener
->vhost
));
194 listener
->name
= listener
->vhost
;
200 report_error("opening listener socket %s:%s",
201 get_listener_name(listener
),
202 get_listener_name(listener
), errno
);
205 else if((maxconnections
- 10) < rb_get_fd(F
)) /* XXX this is kinda bogus*/
207 report_error("no more connections left for listener %s:%s",
208 get_listener_name(listener
),
209 get_listener_name(listener
), errno
);
215 * XXX - we don't want to do all this crap for a listener
216 * set_sock_opts(listener);
218 if(setsockopt(rb_get_fd(F
), SOL_SOCKET
, SO_REUSEADDR
, (char *) &opt
, sizeof(opt
)))
220 report_error("setting SO_REUSEADDR for listener %s:%s",
221 get_listener_name(listener
),
222 get_listener_name(listener
), errno
);
228 * Bind a port to listen for new connections if port is non-null,
229 * else assume it is already open and try get something from it.
232 if(bind(rb_get_fd(F
), (struct sockaddr
*) &listener
->addr
, GET_SS_LEN(&listener
->addr
)))
234 report_error("binding listener socket %s:%s",
235 get_listener_name(listener
),
236 get_listener_name(listener
), errno
);
241 if((ret
= rb_listen(F
, RATBOX_SOMAXCONN
)))
243 report_error("listen failed for %s:%s",
244 get_listener_name(listener
),
245 get_listener_name(listener
), errno
);
252 rb_accept_tcp(listener
->F
, accept_precallback
, accept_callback
, listener
);
257 find_listener(struct rb_sockaddr_storage
*addr
)
259 listener_t
*listener
= NULL
;
260 listener_t
*last_closed
= NULL
;
262 for (listener
= ListenerPollList
; listener
; listener
= listener
->next
)
264 if(addr
->ss_family
!= listener
->addr
.ss_family
)
267 switch(addr
->ss_family
)
271 struct sockaddr_in
*in4
= (struct sockaddr_in
*)addr
;
272 struct sockaddr_in
*lin4
= (struct sockaddr_in
*)&listener
->addr
;
273 if(in4
->sin_addr
.s_addr
== lin4
->sin_addr
.s_addr
&&
274 in4
->sin_port
== lin4
->sin_port
)
276 if(listener
->F
== NULL
)
277 last_closed
= listener
;
286 struct sockaddr_in6
*in6
= (struct sockaddr_in6
*)addr
;
287 struct sockaddr_in6
*lin6
=(struct sockaddr_in6
*)&listener
->addr
;
288 if(IN6_ARE_ADDR_EQUAL(&in6
->sin6_addr
, &lin6
->sin6_addr
) &&
289 in6
->sin6_port
== lin6
->sin6_port
)
291 if(listener
->F
== NULL
)
292 last_closed
= listener
;
310 * add_listener- create a new listener
311 * port - the port number to listen on
312 * vhost_ip - if non-null must contain a valid IP address string in
313 * the format "255.255.255.255"
316 add_listener(int port
, const char *vhost_ip
, int family
)
318 listener_t
*listener
;
319 struct rb_sockaddr_storage vaddr
;
322 * if no port in conf line, don't bother
326 memset(&vaddr
, 0, sizeof(vaddr
));
327 vaddr
.ss_family
= family
;
331 if(family
== AF_INET
)
333 if(inetpton(family
, vhost_ip
, &((struct sockaddr_in
*)&vaddr
)->sin_addr
) <= 0)
339 if(inetpton(family
, vhost_ip
, &((struct sockaddr_in6
*)&vaddr
)->sin6_addr
) <= 0)
349 ((struct sockaddr_in
*)&vaddr
)->sin_addr
.s_addr
= INADDR_ANY
;
353 memcpy(&((struct sockaddr_in6
*)&vaddr
)->sin6_addr
, &in6addr_any
, sizeof(struct in6_addr
));
363 SET_SS_LEN(&vaddr
, sizeof(struct sockaddr_in
));
364 ((struct sockaddr_in
*)&vaddr
)->sin_port
= htons(port
);
368 SET_SS_LEN(&vaddr
, sizeof(struct sockaddr_in6
));
369 ((struct sockaddr_in6
*)&vaddr
)->sin6_port
= htons(port
);
375 if((listener
= find_listener(&vaddr
)))
377 if(listener
->F
!= NULL
)
382 listener
= make_listener(&vaddr
);
383 listener
->next
= ListenerPollList
;
384 ListenerPollList
= listener
;
389 if(inetport(listener
))
390 listener
->active
= 1;
392 close_listener(listener
);
396 * close_listener - close a single listener
399 close_listener(listener_t
*listener
)
401 s_assert(listener
!= NULL
);
404 if(listener
->F
!= NULL
)
406 rb_close(listener
->F
);
410 listener
->active
= 0;
412 if(listener
->ref_count
)
415 free_listener(listener
);
419 * close_listeners - close and free all listeners that are not being used
424 listener_t
*listener
;
425 listener_t
*listener_next
= 0;
427 * close all 'extra' listening ports we have
429 for (listener
= ListenerPollList
; listener
; listener
= listener_next
)
431 listener_next
= listener
->next
;
432 close_listener(listener
);
436 #define DLINE_WARNING "ERROR :You have been D-lined.\r\n"
439 * add_connection - creates a client which has just connected to us on
440 * the given fd. The sockhost field is initialized with the ip# of the host.
441 * The client is sent to the auth module for verification, and not put in
442 * any client list yet.
445 add_connection(struct Listener
*listener
, rb_fde_t
*F
, struct sockaddr
*sai
, int exempt
)
447 struct Client
*new_client
;
448 s_assert(NULL
!= listener
);
451 * get the client socket name from the socket
452 * the client has already been checked out in accept_connection
454 new_client
= make_client(NULL
);
456 memcpy(&new_client
->localClient
->ip
, sai
, sizeof(struct rb_sockaddr_storage
));
459 * copy address to 'sockhost' as a string, copy it to host too
460 * so we have something valid to put into error messages...
462 inetntop_sock((struct sockaddr
*)&new_client
->localClient
->ip
, new_client
->sockhost
,
463 sizeof(new_client
->sockhost
));
466 strlcpy(new_client
->host
, new_client
->sockhost
, sizeof(new_client
->host
));
468 new_client
->localClient
->F
= F
;
470 new_client
->localClient
->listener
= listener
;
471 ++listener
->ref_count
;
475 if(check_reject(new_client
))
477 if(add_unknown_ip(new_client
))
481 start_auth(new_client
);
485 accept_precallback(rb_fde_t
*F
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
)
487 struct Listener
*listener
= (struct Listener
*)data
;
489 struct ConfItem
*aconf
;
490 static time_t last_oper_notice
= 0;
492 if((maxconnections
- 10) < rb_get_fd(F
)) /* XXX this is kinda bogus */
494 ++ServerStats
->is_ref
;
496 * slow down the whining to opers bit
498 if((last_oper_notice
+ 20) <= rb_current_time())
500 sendto_realops_flags(SNO_GENERAL
, L_ALL
,
501 "All connections in use. (%s)",
502 get_listener_name(listener
));
503 last_oper_notice
= rb_current_time();
506 rb_write(F
, "ERROR :All connections in use\r\n", 32);
508 /* Re-register a new IO request for the next accept .. */
512 aconf
= find_dline(addr
, addr
.ss_family
);
513 if(aconf
!= NULL
&& (aconf
->status
& CONF_EXEMPTDLINE
))
516 /* Do an initial check we aren't connecting too fast or with too many
520 ServerStats
->is_ref
++;
522 if(ConfigFileEntry
.dline_with_reason
)
524 if (rb_snprintf(buf
, sizeof(buf
), "ERROR :*** Banned: %s\r\n", aconf
->passwd
) >= (int)(sizeof(buf
)-1))
526 buf
[sizeof(buf
) - 3] = '\r';
527 buf
[sizeof(buf
) - 2] = '\n';
528 buf
[sizeof(buf
) - 1] = '\0';
532 strcpy(buf
, "ERROR :You have been D-lined.\r\n");
534 rb_write(F
, buf
, strlen(buf
));
543 accept_callback(rb_fde_t
*F
, int status
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
)
545 struct Listener
*listener
= data
;
546 struct rb_sockaddr_storage lip
;
547 unsigned int locallen
= sizeof(struct rb_sockaddr_storage
);
549 ServerStats
->is_ac
++;
551 if(getsockname(rb_get_fd(F
), (struct sockaddr
*) &lip
, &locallen
) < 0)
553 /* this shouldn't fail so... */
554 /* XXX add logging of this */
558 add_connection(listener
, F
, addr
, 1);