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
31 #include "ircd_defs.h"
34 #include "s_newconf.h"
46 #if defined(NO_IN6ADDR_ANY) && defined(RB_IPV6)
47 static const struct in6_addr in6addr_any
=
48 { { { 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 } } };
51 static struct Listener
*ListenerPollList
= NULL
;
52 static int accept_precallback(rb_fde_t
*F
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
);
53 static void accept_callback(rb_fde_t
*F
, int status
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
);
54 static SSL_OPEN_CB accept_sslcallback
;
56 static struct Listener
*
57 make_listener(struct rb_sockaddr_storage
*addr
)
59 struct Listener
*listener
= (struct Listener
*) rb_malloc(sizeof(struct Listener
));
60 s_assert(0 != listener
);
61 listener
->name
= me
.name
;
64 memcpy(&listener
->addr
, addr
, sizeof(struct rb_sockaddr_storage
));
65 listener
->next
= NULL
;
70 free_listener(struct Listener
*listener
)
72 s_assert(NULL
!= listener
);
76 * remove from listener list
78 if(listener
== ListenerPollList
)
79 ListenerPollList
= listener
->next
;
82 struct Listener
*prev
= ListenerPollList
;
83 for (; prev
; prev
= prev
->next
)
85 if(listener
== prev
->next
)
87 prev
->next
= listener
->next
;
97 #define PORTNAMELEN 6 /* ":31337" */
100 * get_listener_port - return displayable listener port
103 get_listener_port(const struct Listener
*listener
)
105 return ntohs(GET_SS_PORT(&listener
->addr
));
109 * get_listener_name - return displayable listener name and port
110 * returns "host.foo.org:6667" for a given listener
113 get_listener_name(const struct Listener
*listener
)
115 static char buf
[HOSTLEN
+ HOSTLEN
+ PORTNAMELEN
+ 4];
117 s_assert(NULL
!= listener
);
121 snprintf(buf
, sizeof(buf
), "%s[%s/%u]",
122 me
.name
, listener
->name
, get_listener_port(listener
));
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 struct Listener
*listener
= 0;
137 for (listener
= ListenerPollList
; listener
; listener
= listener
->next
)
139 sendto_one_numeric(source_p
, RPL_STATSPLINE
,
140 form_str(RPL_STATSPLINE
), 'P',
141 get_listener_port(listener
),
142 IsOperAdmin(source_p
) ? listener
->name
: me
.name
,
143 listener
->ref_count
, (listener
->active
) ? "active" : "disabled",
144 listener
->ssl
? " ssl" : "");
149 * inetport - create a listener socket in the AF_INET or AF_INET6 domain,
150 * bind it to the port given in 'port' and listen to it
151 * returns true (1) if successful false (0) on error.
155 inetport(struct Listener
*listener
)
162 * At first, open a new socket
165 F
= rb_socket(GET_SS_FAMILY(&listener
->addr
), SOCK_STREAM
, 0, "Listener socket");
168 if(GET_SS_FAMILY(&listener
->addr
) == AF_INET6
)
170 struct sockaddr_in6
*in6
= (struct sockaddr_in6
*)&listener
->addr
;
171 if(!IN6_ARE_ADDR_EQUAL(&in6
->sin6_addr
, &in6addr_any
))
173 rb_inet_ntop(AF_INET6
, &in6
->sin6_addr
, listener
->vhost
, sizeof(listener
->vhost
));
174 listener
->name
= listener
->vhost
;
179 struct sockaddr_in
*in
= (struct sockaddr_in
*)&listener
->addr
;
180 if(in
->sin_addr
.s_addr
!= INADDR_ANY
)
182 rb_inet_ntop(AF_INET
, &in
->sin_addr
, listener
->vhost
, sizeof(listener
->vhost
));
183 listener
->name
= listener
->vhost
;
189 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
190 "Cannot open socket for listener on port %d",
191 get_listener_port(listener
));
192 ilog(L_MAIN
, "Cannot open socket for listener %s",
193 get_listener_name(listener
));
196 else if((maxconnections
- 10) < rb_get_fd(F
)) /* XXX this is kinda bogus*/
198 ilog_error("no more connections left for listener");
199 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
200 "No more connections left for listener on port %d",
201 get_listener_port(listener
));
202 ilog(L_MAIN
, "No more connections left for listener %s",
203 get_listener_name(listener
));
209 * XXX - we don't want to do all this crap for a listener
210 * set_sock_opts(listener);
212 * FIXME - doesn't this belong in librb? --Elizafox
214 if(setsockopt(rb_get_fd(F
), SOL_SOCKET
, SO_REUSEADDR
, (char *) &opt
, sizeof(opt
)))
216 errstr
= strerror(rb_get_sockerr(F
));
217 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
218 "Cannot set SO_REUSEADDR for listener on port %d: %s",
219 get_listener_port(listener
), errstr
);
220 ilog(L_MAIN
, "Cannot set SO_REUSEADDR for listener %s: %s",
221 get_listener_name(listener
), errstr
);
226 /* FIXME - doesn't this belong in librb? --Elizafox */
227 if(bind(rb_get_fd(F
), (struct sockaddr
*) &listener
->addr
, GET_SS_LEN(&listener
->addr
)))
229 errstr
= strerror(rb_get_sockerr(F
));
230 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
231 "Cannot bind for listener on port %d: %s",
232 get_listener_port(listener
), errstr
);
233 ilog(L_MAIN
, "Cannot bind for listener %s: %s",
234 get_listener_name(listener
), errstr
);
239 if(rb_listen(F
, SOMAXCONN
, listener
->defer_accept
))
241 errstr
= strerror(rb_get_sockerr(F
));
242 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
243 "Cannot listen() for listener on port %d: %s",
244 get_listener_port(listener
), errstr
);
245 ilog(L_MAIN
, "Cannot listen() for listener %s: %s",
246 get_listener_name(listener
), errstr
);
253 rb_accept_tcp(listener
->F
, accept_precallback
, accept_callback
, listener
);
257 static struct Listener
*
258 find_listener(struct rb_sockaddr_storage
*addr
)
260 struct Listener
*listener
= NULL
;
261 struct Listener
*last_closed
= NULL
;
263 for (listener
= ListenerPollList
; listener
; listener
= listener
->next
)
265 if(GET_SS_FAMILY(addr
) != GET_SS_FAMILY(&listener
->addr
))
268 switch(GET_SS_FAMILY(addr
))
272 struct sockaddr_in
*in4
= (struct sockaddr_in
*)addr
;
273 struct sockaddr_in
*lin4
= (struct sockaddr_in
*)&listener
->addr
;
274 if(in4
->sin_addr
.s_addr
== lin4
->sin_addr
.s_addr
&&
275 in4
->sin_port
== lin4
->sin_port
)
277 if(listener
->F
== NULL
)
278 last_closed
= listener
;
287 struct sockaddr_in6
*in6
= (struct sockaddr_in6
*)addr
;
288 struct sockaddr_in6
*lin6
=(struct sockaddr_in6
*)&listener
->addr
;
289 if(IN6_ARE_ADDR_EQUAL(&in6
->sin6_addr
, &lin6
->sin6_addr
) &&
290 in6
->sin6_port
== lin6
->sin6_port
)
292 if(listener
->F
== NULL
)
293 last_closed
= listener
;
311 * add_listener- create a new listener
312 * port - the port number to listen on
313 * vhost_ip - if non-null must contain a valid IP address string in
314 * the format "255.255.255.255"
317 add_listener(int port
, const char *vhost_ip
, int family
, int ssl
, int defer_accept
, int wsock
)
319 struct Listener
*listener
;
320 struct rb_sockaddr_storage vaddr
;
323 * if no port in conf line, don't bother
327 memset(&vaddr
, 0, sizeof(vaddr
));
328 SET_SS_FAMILY(&vaddr
, family
);
332 if(family
== AF_INET
)
334 if(rb_inet_pton(family
, vhost_ip
, &((struct sockaddr_in
*)&vaddr
)->sin_addr
) <= 0)
340 if(rb_inet_pton(family
, vhost_ip
, &((struct sockaddr_in6
*)&vaddr
)->sin6_addr
) <= 0)
350 ((struct sockaddr_in
*)&vaddr
)->sin_addr
.s_addr
= INADDR_ANY
;
354 memcpy(&((struct sockaddr_in6
*)&vaddr
)->sin6_addr
, &in6addr_any
, sizeof(struct in6_addr
));
364 SET_SS_LEN(&vaddr
, sizeof(struct sockaddr_in
));
365 SET_SS_FAMILY(&vaddr
, AF_INET
);
366 SET_SS_PORT(&vaddr
, htons(port
));
370 SET_SS_LEN(&vaddr
, sizeof(struct sockaddr_in6
));
371 SET_SS_FAMILY(&vaddr
, AF_INET6
);
372 SET_SS_PORT(&vaddr
, htons(port
));
378 if((listener
= find_listener(&vaddr
)))
380 if(listener
->F
!= NULL
)
385 listener
= make_listener(&vaddr
);
386 listener
->next
= ListenerPollList
;
387 ListenerPollList
= listener
;
392 listener
->defer_accept
= defer_accept
;
393 listener
->wsock
= wsock
;
395 if(inetport(listener
))
396 listener
->active
= 1;
398 close_listener(listener
);
402 * close_listener - close a single listener
405 close_listener(struct Listener
*listener
)
407 s_assert(listener
!= NULL
);
410 if(listener
->F
!= NULL
)
412 rb_close(listener
->F
);
416 listener
->active
= 0;
418 if(listener
->ref_count
)
421 free_listener(listener
);
425 * close_listeners - close and free all listeners that are not being used
430 struct Listener
*listener
;
431 struct Listener
*listener_next
= 0;
433 * close all 'extra' listening ports we have
435 for (listener
= ListenerPollList
; listener
; listener
= listener_next
)
437 listener_next
= listener
->next
;
438 close_listener(listener
);
443 * add_connection - creates a client which has just connected to us on
444 * the given fd. The sockhost field is initialized with the ip# of the host.
445 * The client is sent to the auth module for verification, and not put in
446 * any client list yet.
449 add_connection(struct Listener
*listener
, rb_fde_t
*F
, struct sockaddr
*sai
, struct sockaddr
*lai
)
451 struct Client
*new_client
;
453 s_assert(NULL
!= listener
);
456 * get the client socket name from the socket
457 * the client has already been checked out in accept_connection
459 new_client
= make_client(NULL
);
460 new_client
->localClient
->F
= F
;
462 memcpy(&new_client
->localClient
->ip
, sai
, sizeof(struct rb_sockaddr_storage
));
463 memcpy(&new_client
->preClient
->lip
, lai
, sizeof(struct rb_sockaddr_storage
));
466 * copy address to 'sockhost' as a string, copy it to host too
467 * so we have something valid to put into error messages...
469 rb_inet_ntop_sock((struct sockaddr
*)&new_client
->localClient
->ip
, new_client
->sockhost
,
470 sizeof(new_client
->sockhost
));
472 rb_strlcpy(new_client
->host
, new_client
->sockhost
, sizeof(new_client
->host
));
477 if(rb_socketpair(AF_UNIX
, SOCK_STREAM
, 0, &xF
[0], &xF
[1], "Incoming ssld Connection") == -1)
479 SetIOError(new_client
);
480 exit_client(new_client
, new_client
, new_client
, "Fatal Error");
483 new_client
->localClient
->ssl_callback
= accept_sslcallback
;
485 new_client
->localClient
->ssl_ctl
= start_ssld_accept(F
, xF
[1], connid_get(new_client
)); /* this will close F for us */
486 if(new_client
->localClient
->ssl_ctl
== NULL
)
488 SetIOError(new_client
);
489 exit_client(new_client
, new_client
, new_client
, "Service Unavailable");
493 new_client
->localClient
->F
= F
;
500 if(rb_socketpair(AF_UNIX
, SOCK_STREAM
, 0, &xF
[0], &xF
[1], "Incoming wsockd Connection") == -1)
502 SetIOError(new_client
);
503 exit_client(new_client
, new_client
, new_client
, "Fatal Error");
506 new_client
->localClient
->ws_ctl
= start_wsockd_accept(F
, xF
[1], connid_get(new_client
)); /* this will close F for us */
507 if(new_client
->localClient
->ws_ctl
== NULL
)
509 SetIOError(new_client
);
510 exit_client(new_client
, new_client
, new_client
, "Service Unavailable");
514 new_client
->localClient
->F
= F
;
517 new_client
->localClient
->listener
= listener
;
519 ++listener
->ref_count
;
521 authd_initiate_client(new_client
, defer
);
525 accept_sslcallback(struct Client
*client_p
, int status
)
527 authd_deferred_client(client_p
);
528 return 0; /* use default handler if status != RB_OK */
531 static const char *toofast
= "ERROR :Reconnecting too fast, throttled.\r\n";
534 accept_precallback(rb_fde_t
*F
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
)
536 struct Listener
*listener
= (struct Listener
*)data
;
538 struct ConfItem
*aconf
;
539 static time_t last_oper_notice
= 0;
542 if(listener
->ssl
&& (!ircd_ssl_ok
|| !get_ssld_count()))
548 if((maxconnections
- 10) < rb_get_fd(F
)) /* XXX this is kinda bogus */
550 ++ServerStats
.is_ref
;
552 * slow down the whining to opers bit
554 if((last_oper_notice
+ 20) <= rb_current_time())
556 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
557 "All connections in use. (%s)",
558 get_listener_name(listener
));
559 last_oper_notice
= rb_current_time();
562 rb_write(F
, "ERROR :All connections in use\r\n", 31);
567 aconf
= find_dline(addr
, addr
->sa_family
);
568 if(aconf
!= NULL
&& (aconf
->status
& CONF_EXEMPTDLINE
))
571 /* Do an initial check we aren't connecting too fast or with too many
575 ServerStats
.is_ref
++;
577 if(ConfigFileEntry
.dline_with_reason
)
579 len
= snprintf(buf
, sizeof(buf
), "ERROR :*** Banned: %s\r\n", get_user_ban_reason(aconf
));
580 if (len
>= (int)(sizeof(buf
)-1))
582 buf
[sizeof(buf
) - 3] = '\r';
583 buf
[sizeof(buf
) - 2] = '\n';
584 buf
[sizeof(buf
) - 1] = '\0';
588 strcpy(buf
, "ERROR :You have been D-lined.\r\n");
590 rb_write(F
, buf
, strlen(buf
));
595 if(check_reject(F
, addr
)) {
596 /* Reject the connection without closing the socket
597 * because it is now on the delay_exit list. */
601 if(throttle_add(addr
))
603 rb_write(F
, toofast
, strlen(toofast
));
612 accept_callback(rb_fde_t
*F
, int status
, struct sockaddr
*addr
, rb_socklen_t addrlen
, void *data
)
614 struct Listener
*listener
= data
;
615 struct rb_sockaddr_storage lip
;
616 unsigned int locallen
= sizeof(struct rb_sockaddr_storage
);
620 if(getsockname(rb_get_fd(F
), (struct sockaddr
*) &lip
, &locallen
) < 0)
622 /* this can fail if the connection disappeared in the meantime */
627 add_connection(listener
, F
, addr
, (struct sockaddr
*)&lip
);