#include "s_conf.h"
#include "hostmask.h"
-#ifndef INADDR_NONE
-#define INADDR_NONE ((unsigned int) 0xffffffff)
-#endif
-
-#if defined(NO_IN6ADDR_ANY) && defined(IPV6)
-static const struct in6_addr in6addr_any =
-{ { { 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 } } };
-#endif
-
-static PF accept_connection;
-
-static listener_t *ListenerPollList = NULL;
-
-static listener_t *
-make_listener(struct irc_sockaddr_storage *addr)
-{
- listener_t *listener = (listener_t *) rb_malloc(sizeof(listener_t));
- s_assert(0 != listener);
-
- listener->name = me.name;
- listener->fd = -1;
- memcpy(&listener->addr, addr, sizeof(struct irc_sockaddr_storage));
- listener->next = NULL;
- return listener;
-}
-
-void
-free_listener(listener_t *listener)
-{
- s_assert(NULL != listener);
- if(listener == NULL)
- return;
- /*
- * remove from listener list
- */
- if(listener == ListenerPollList)
- ListenerPollList = listener->next;
- else
- {
- listener_t *prev = ListenerPollList;
- for (; prev; prev = prev->next)
- {
- if(listener == prev->next)
- {
- prev->next = listener->next;
- break;
- }
- }
- }
-
- /* free */
- rb_free(listener);
-}
-
-#define PORTNAMELEN 6 /* ":31337" */
-
-/*
- * get_listener_name - return displayable listener name and port
- * returns "host.foo.org:6667" for a given listener
- */
-const char *
-get_listener_name(const listener_t *listener)
-{
- static char buf[HOSTLEN + HOSTLEN + PORTNAMELEN + 4];
- int port = 0;
-
- s_assert(NULL != listener);
- if(listener == NULL)
- return NULL;
-
-#ifdef IPV6
- if(listener->addr.ss_family == AF_INET6)
- port = ntohs(((const struct sockaddr_in6 *)&listener->addr)->sin6_port);
- else
-#endif
- port = ntohs(((const struct sockaddr_in *)&listener->addr)->sin_port);
-
- rb_snprintf(buf, sizeof(buf), "%s[%s/%u]", me.name, listener->name, port);
- return buf;
-}
-
-/*
- * show_ports - send port listing to a client
- * inputs - pointer to client to show ports to
- * output - none
- * side effects - show ports
- */
-void
-show_ports(struct Client *source_p)
-{
- listener_t *listener = 0;
-
- for (listener = ListenerPollList; listener; listener = listener->next)
- {
- sendto_one_numeric(source_p, RPL_STATSPLINE,
- form_str(RPL_STATSPLINE), 'P',
-#ifdef IPV6
- ntohs(listener->addr.ss_family == AF_INET ? ((struct sockaddr_in *)&listener->addr)->sin_port :
- ((struct sockaddr_in6 *)&listener->addr)->sin6_port),
-#else
- ntohs(((struct sockaddr_in *)&listener->addr)->sin_port),
-#endif
- IsOperAdmin(source_p) ? listener->name : me.name,
- listener->ref_count, (listener->active) ? "active" : "disabled");
- }
-}
-
-/*
- * inetport - create a listener socket in the AF_INET or AF_INET6 domain,
- * bind it to the port given in 'port' and listen to it
- * returns true (1) if successful false (0) on error.
- *
- * If the operating system has a define for SOMAXCONN, use it, otherwise
- * use RATBOX_SOMAXCONN
- */
-#ifdef SOMAXCONN
-#undef RATBOX_SOMAXCONN
-#define RATBOX_SOMAXCONN SOMAXCONN
-#endif
-
-static int
-inetport(listener_t *listener)
-{
- int fd;
- int opt = 1;
-
- /*
- * At first, open a new socket
- */
-
- fd = rb_socket(listener->addr.ss_family, SOCK_STREAM, 0, "Listener socket");
-
-#ifdef IPV6
- if(listener->addr.ss_family == AF_INET6)
- {
- struct sockaddr_in6 *in6 = (struct sockaddr_in6 *)&listener->addr;
- if(!IN6_ARE_ADDR_EQUAL(&in6->sin6_addr, &in6addr_any))
- {
- inetntop(AF_INET6, &in6->sin6_addr, listener->vhost, sizeof(listener->vhost));
- listener->name = listener->vhost;
- }
- } else
-#endif
- {
- struct sockaddr_in *in = (struct sockaddr_in *)&listener->addr;
- if(in->sin_addr.s_addr != INADDR_ANY)
- {
- inetntop(AF_INET, &in->sin_addr, listener->vhost, sizeof(listener->vhost));
- listener->name = listener->vhost;
- }
- }
-
- /*
- * At one point, we enforced a strange arbitrary limit here.
- * We no longer do this, and just check if the fd is valid or not.
- * -nenolod
- */
- if(fd == -1)
- {
- report_error("opening listener socket %s:%s",
- get_listener_name(listener),
- get_listener_name(listener), errno);
- return 0;
- }
-
- /*
- * XXX - we don't want to do all this crap for a listener
- * set_sock_opts(listener);
- */
- if(setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (char *) &opt, sizeof(opt)))
- {
- report_error("setting SO_REUSEADDR for listener %s:%s",
- get_listener_name(listener),
- get_listener_name(listener), errno);
- rb_close(fd);
- return 0;
- }
-
- /*
- * Bind a port to listen for new connections if port is non-null,
- * else assume it is already open and try get something from it.
- */
-
- if(bind(fd, (struct sockaddr *) &listener->addr, GET_SS_LEN(listener->addr)))
- {
- report_error("binding listener socket %s:%s",
- get_listener_name(listener),
- get_listener_name(listener), errno);
- rb_close(fd);
- return 0;
- }
-
- if(listen(fd, RATBOX_SOMAXCONN))
- {
- report_error("listen failed for %s:%s",
- get_listener_name(listener),
- get_listener_name(listener), errno);
- rb_close(fd);
- return 0;
- }
-
- listener->fd = fd;
-
- /* Listen completion events are READ events .. */
-
- accept_connection(fd, listener);
- return 1;
-}
-
-static listener_t *
-find_listener(struct irc_sockaddr_storage *addr)
-{
- listener_t *listener = NULL;
- listener_t *last_closed = NULL;
-
- for (listener = ListenerPollList; listener; listener = listener->next)
- {
- if(addr->ss_family != listener->addr.ss_family)
- continue;
-
- switch(addr->ss_family)
- {
- case AF_INET:
- {
- struct sockaddr_in *in4 = (struct sockaddr_in *)addr;
- struct sockaddr_in *lin4 = (struct sockaddr_in *)&listener->addr;
- if(in4->sin_addr.s_addr == lin4->sin_addr.s_addr &&
- in4->sin_port == lin4->sin_port )
- {
- if(listener->fd == -1)
- last_closed = listener;
- else
- return(listener);
- }
- break;
- }
-#ifdef IPV6
- case AF_INET6:
- {
- struct sockaddr_in6 *in6 = (struct sockaddr_in6 *)addr;
- struct sockaddr_in6 *lin6 =(struct sockaddr_in6 *)&listener->addr;
- if(IN6_ARE_ADDR_EQUAL(&in6->sin6_addr, &lin6->sin6_addr) &&
- in6->sin6_port == lin6->sin6_port)
- {
- if(listener->fd == -1)
- last_closed = listener;
- else
- return(listener);
- }
- break;
-
- }
-#endif
-
- default:
- break;
- }
- }
- return last_closed;
-}
-
-
-/*
- * add_listener- create a new listener
- * port - the port number to listen on
- * vhost_ip - if non-null must contain a valid IP address string in
- * the format "255.255.255.255"
- */
-void
-add_listener(int port, const char *vhost_ip, int family)
-{
- listener_t *listener;
- struct irc_sockaddr_storage vaddr;
-
- /*
- * if no port in conf line, don't bother
- */
- if(port == 0)
- return;
- memset(&vaddr, 0, sizeof(vaddr));
- vaddr.ss_family = family;
-
- if(vhost_ip != NULL)
- {
- if(family == AF_INET)
- {
- if(inetpton(family, vhost_ip, &((struct sockaddr_in *)&vaddr)->sin_addr) <= 0)
- return;
- }
-#ifdef IPV6
- else
- {
- if(inetpton(family, vhost_ip, &((struct sockaddr_in6 *)&vaddr)->sin6_addr) <= 0)
- return;
-
- }
-#endif
- } else
- {
- switch(family)
- {
- case AF_INET:
- ((struct sockaddr_in *)&vaddr)->sin_addr.s_addr = INADDR_ANY;
- break;
-#ifdef IPV6
- case AF_INET6:
- memcpy(&((struct sockaddr_in6 *)&vaddr)->sin6_addr, &in6addr_any, sizeof(struct in6_addr));
- break;
- default:
- return;
-#endif
- }
- }
- switch(family)
- {
- case AF_INET:
- SET_SS_LEN(vaddr, sizeof(struct sockaddr_in));
- ((struct sockaddr_in *)&vaddr)->sin_port = htons(port);
- break;
-#ifdef IPV6
- case AF_INET6:
- SET_SS_LEN(vaddr, sizeof(struct sockaddr_in6));
- ((struct sockaddr_in6 *)&vaddr)->sin6_port = htons(port);
- break;
-#endif
- default:
- break;
- }
- if((listener = find_listener(&vaddr)))
- {
- if(listener->fd > -1)
- return;
- }
- else
- {
- listener = make_listener(&vaddr);
- listener->next = ListenerPollList;
- ListenerPollList = listener;
- }
-
- listener->fd = -1;
-
- if(inetport(listener))
- listener->active = 1;
- else
- close_listener(listener);
-}
-
-/*
- * close_listener - close a single listener
- */
-void
-close_listener(listener_t *listener)
-{
- s_assert(listener != NULL);
- if(listener == NULL)
- return;
- if(listener->fd >= 0)
- {
- rb_close(listener->fd);
- listener->fd = -1;
- }
-
- listener->active = 0;
-
- if(listener->ref_count)
- return;
-
- free_listener(listener);
-}
-
-/*
- * close_listeners - close and free all listeners that are not being used
- */
-void
-close_listeners()
-{
- listener_t *listener;
- listener_t *listener_next = 0;
- /*
- * close all 'extra' listening ports we have
- */
- for (listener = ListenerPollList; listener; listener = listener_next)
- {
- listener_next = listener->next;
- close_listener(listener);
- }
-}
-
-#define DLINE_WARNING "ERROR :You have been D-lined.\r\n"
-
-/*
- * add_connection - creates a client which has just connected to us on
- * the given fd. The sockhost field is initialized with the ip# of the host.
- * The client is sent to the auth module for verification, and not put in
- * any client list yet.
- */
-static void
-add_connection(listener_t *listener, int fd, struct sockaddr *sai, int exempt)
-{
- struct Client *new_client;
- s_assert(NULL != listener);
-
- /*
- * get the client socket name from the socket
- * the client has already been checked out in accept_connection
- */
- new_client = make_client(NULL);
-
- memcpy(&new_client->localClient->ip, sai, sizeof(struct irc_sockaddr_storage));
-
- /*
- * copy address to 'sockhost' as a string, copy it to host too
- * so we have something valid to put into error messages...
- */
- inetntop_sock((struct sockaddr *)&new_client->localClient->ip, new_client->sockhost,
- sizeof(new_client->sockhost));
-
-
- strlcpy(new_client->host, new_client->sockhost, sizeof(new_client->host));
-
- new_client->localClient->F = rb_add_fd(fd);
-
- new_client->localClient->listener = listener;
- ++listener->ref_count;
-
- if(!exempt)
- {
- if(check_reject(new_client))
- return;
- if(add_unknown_ip(new_client))
- return;
- }
-
- start_auth(new_client);
-}
-
-
-static void
-accept_connection(int pfd, void *data)
-{
- static time_t last_oper_notice = 0;
- struct irc_sockaddr_storage sai;
- socklen_t addrlen = sizeof(sai);
- int fd;
- listener_t *listener = data;
- struct ConfItem *aconf;
- char buf[BUFSIZE];
-
- s_assert(listener != NULL);
- if(listener == NULL)
- return;
- /*
- * There may be many reasons for error return, but
- * in otherwise correctly working environment the
- * probable cause is running out of file descriptors
- * (EMFILE, ENFILE or others?). The man pages for
- * accept don't seem to list these as possible,
- * although it's obvious that it may happen here.
- * Thus no specific errors are tested at this
- * point, just assume that connections cannot
- * be accepted until some old is closed first.
- */
-
- fd = rb_accept(listener->fd, (struct sockaddr *)&sai, &addrlen);
- if(fd < 0)
- {
- /* Re-register a new IO request for the next accept .. */
- rb_setselect(listener->fd, FDLIST_SERVICE,
- COMM_SELECT_READ, accept_connection, listener, 0);
- return;
- }
-
- /* This needs to be done here, otherwise we break dlines */
- mangle_mapped_sockaddr((struct sockaddr *)&sai);
-
- /*
- * check for connection limit
- * TBD: this is stupid... either we have a socket or we don't. -nenolod
- */
- if((rb_get_maxconnections() - 10) < fd)
- {
- ++ServerStats->is_ref;
- /*
- * slow down the whining to opers bit
- */
- if((last_oper_notice + 20) <= rb_current_time())
- {
- sendto_realops_snomask(SNO_GENERAL, L_ALL,
- "All connections in use. (%s)",
- get_listener_name(listener));
- last_oper_notice = rb_current_time();
- }
-
- write(fd, "ERROR :All connections in use\r\n", 32);
- rb_close(fd);
- /* Re-register a new IO request for the next accept .. */
- rb_setselect(listener->fd, FDLIST_SERVICE,
- COMM_SELECT_READ, accept_connection, listener, 0);
- return;
- }
-
- /* Do an initial check we aren't connecting too fast or with too many
- * from this IP... */
- aconf = find_dline((struct sockaddr *) &sai, sai.ss_family);
- /* check it wasn't an exempt */
- if (aconf != NULL && (aconf->status & CONF_EXEMPTDLINE) == 0)
- {
- ServerStats->is_ref++;
-
- if(ConfigFileEntry.dline_with_reason)
- {
- if (rb_snprintf(buf, sizeof(buf), "ERROR :*** Banned: %s\r\n", aconf->passwd) >= (sizeof(buf)-1))
- {
- buf[sizeof(buf) - 3] = '\r';
- buf[sizeof(buf) - 2] = '\n';
- buf[sizeof(buf) - 1] = '\0';
- }
- }
- else
- rb_sprintf(buf, "ERROR :You have been D-lined.\r\n");
-
- write(fd, buf, strlen(buf));
- rb_close(fd);
-
- /* Re-register a new IO request for the next accept .. */
- rb_setselect(listener->fd, FDLIST_SERVICE,
- COMM_SELECT_READ, accept_connection, listener, 0);
- return;
- }
-
- ServerStats->is_ac++;
- add_connection(listener, fd, (struct sockaddr *)&sai, aconf ? 1 : 0);
-
- /* Re-register a new IO request for the next accept .. */
- rb_setselect(listener->fd, FDLIST_SERVICE, COMM_SELECT_READ,
- accept_connection, listener, 0);
-}
+static rb_dlink_list listener_list;\r
+static int accept_precallback(rb_fde_t *F, struct sockaddr *addr, rb_socklen_t addrlen, void *data);\r
+static void accept_callback(rb_fde_t *F, int status, struct sockaddr *addr, rb_socklen_t addrlen, void *data);\r
+\r
+static struct Listener *\r
+make_listener(struct rb_sockaddr_storage *addr)\r
+{\r
+ struct Listener *listener = rb_malloc(sizeof(struct Listener));\r
+ s_assert(0 != listener);\r
+ listener->name = ServerInfo.name; /* me.name may not be valid yet -- jilles */\r
+ listener->F = NULL;\r
+ memcpy(&listener->addr, addr, sizeof(struct rb_sockaddr_storage));\r
+ return listener;\r
+}\r
+\r
+void\r
+free_listener(struct Listener *listener)\r
+{\r
+ s_assert(NULL != listener);\r
+ if(listener == NULL)\r
+ return;\r
+ \r
+ rb_dlinkDelete(&listener->node, &listener_list);\r
+ rb_free(listener);\r
+}\r
+\r
+#define PORTNAMELEN 6 /* ":31337" */\r
+\r
+/*\r
+ * get_listener_name - return displayable listener name and port\r
+ * returns "host.foo.org:6667" for a given listener\r
+ */\r
+const char *\r
+get_listener_name(struct Listener *listener)\r
+{\r
+ static char buf[HOSTLEN + HOSTLEN + PORTNAMELEN + 4];\r
+ int port = 0;\r
+\r
+ s_assert(NULL != listener);\r
+ if(listener == NULL)\r
+ return NULL;\r
+\r
+#ifdef IPV6\r
+ if(GET_SS_FAMILY(&listener->addr) == AF_INET6)\r
+ port = ntohs(((const struct sockaddr_in6 *)&listener->addr)->sin6_port);\r
+ else\r
+#endif\r
+ port = ntohs(((const struct sockaddr_in *)&listener->addr)->sin_port); \r
+\r
+ rb_snprintf(buf, sizeof(buf), "%s[%s/%u]", me.name, listener->name, port);\r
+ return buf;\r
+}\r
+\r
+/*\r
+ * show_ports - send port listing to a client\r
+ * inputs - pointer to client to show ports to\r
+ * output - none\r
+ * side effects - show ports\r
+ */\r
+void\r
+show_ports(struct Client *source_p)\r
+{\r
+ struct Listener *listener;\r
+ rb_dlink_node *ptr;\r
+ \r
+ RB_DLINK_FOREACH(ptr, listener_list.head)\r
+ {\r
+ listener = ptr->data;\r
+ sendto_one_numeric(source_p, RPL_STATSPLINE, \r
+ form_str(RPL_STATSPLINE), 'P',\r
+#ifdef IPV6\r
+ ntohs(GET_SS_FAMILY(&listener->addr) == AF_INET ? ((struct sockaddr_in *)&listener->addr)->sin_port :\r
+ ((struct sockaddr_in6 *)&listener->addr)->sin6_port),\r
+#else\r
+ ntohs(((struct sockaddr_in *)&listener->addr)->sin_port),\r
+#endif\r
+ IsOperAdmin(source_p) ? listener->name : me.name,\r
+ listener->ref_count, (listener->active) ? "active" : "disabled",\r
+ listener->ssl ? " ssl" : "");\r
+ }\r
+}\r
+\r
+/*\r
+ * inetport - create a listener socket in the AF_INET or AF_INET6 domain,\r
+ * bind it to the port given in 'port' and listen to it\r
+ * returns true (1) if successful false (0) on error.\r
+ *\r
+ * If the operating system has a define for SOMAXCONN, use it, otherwise\r
+ * use RATBOX_SOMAXCONN\r
+ */\r
+#ifdef SOMAXCONN\r
+#undef RATBOX_SOMAXCONN\r
+#define RATBOX_SOMAXCONN SOMAXCONN\r
+#endif\r
+\r
+static int\r
+inetport(struct Listener *listener)\r
+{\r
+ rb_fde_t *F;\r
+ int ret;\r
+ int opt = 1;\r
+\r
+ /*\r
+ * At first, open a new socket\r
+ */\r
+ \r
+ F = rb_socket(GET_SS_FAMILY(&listener->addr), SOCK_STREAM, 0, "Listener socket");\r
+\r
+#ifdef IPV6\r
+ if(GET_SS_FAMILY(&listener->addr) == AF_INET6)\r
+ {\r
+ struct sockaddr_in6 *in6 = (struct sockaddr_in6 *)&listener->addr;\r
+ if(!IN6_ARE_ADDR_EQUAL(&in6->sin6_addr, &in6addr_any))\r
+ {\r
+ rb_inet_ntop(AF_INET6, &in6->sin6_addr, listener->vhost, sizeof(listener->vhost));\r
+ listener->name = listener->vhost;\r
+ }\r
+ } else\r
+#endif\r
+ {\r
+ struct sockaddr_in *in = (struct sockaddr_in *)&listener->addr;\r
+ if(in->sin_addr.s_addr != INADDR_ANY)\r
+ {\r
+ rb_inet_ntop(AF_INET, &in->sin_addr, listener->vhost, sizeof(listener->vhost));\r
+ listener->name = listener->vhost;\r
+ } \r
+ }\r
+\r
+\r
+ if(F == NULL)\r
+ {\r
+ report_error("opening listener socket %s:%s",\r
+ get_listener_name(listener), \r
+ get_listener_name(listener), errno);\r
+ return 0;\r
+ }\r
+ else if((maxconnections - 10) < rb_get_fd(F)) /* XXX this is kinda bogus*/\r
+ {\r
+ report_error("no more connections left for listener %s:%s",\r
+ get_listener_name(listener), \r
+ get_listener_name(listener), errno);\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+ /*\r
+ * XXX - we don't want to do all this crap for a listener\r
+ * set_sock_opts(listener);\r
+ */\r
+ if(setsockopt(rb_get_fd(F), SOL_SOCKET, SO_REUSEADDR, (char *) &opt, sizeof(opt)))\r
+ {\r
+ report_error("setting SO_REUSEADDR for listener %s:%s",\r
+ get_listener_name(listener), \r
+ get_listener_name(listener), errno);\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+\r
+ /*\r
+ * Bind a port to listen for new connections if port is non-null,\r
+ * else assume it is already open and try get something from it.\r
+ */\r
+\r
+ if(bind(rb_get_fd(F), (struct sockaddr *) &listener->addr, GET_SS_LEN(&listener->addr)))\r
+ {\r
+ report_error("binding listener socket %s:%s",\r
+ get_listener_name(listener), \r
+ get_listener_name(listener), errno);\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+\r
+ if((ret = rb_listen(F, RATBOX_SOMAXCONN)))\r
+ {\r
+ report_error("listen failed for %s:%s", \r
+ get_listener_name(listener), \r
+ get_listener_name(listener), errno);\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+\r
+ listener->F = F;\r
+\r
+ rb_accept_tcp(listener->F, accept_precallback, accept_callback, listener);\r
+ return 1;\r
+}\r
+\r
+static struct Listener *\r
+find_listener(struct rb_sockaddr_storage *addr)\r
+{\r
+ struct Listener *listener = NULL;\r
+ struct Listener *last_closed = NULL;\r
+ rb_dlink_node *ptr;\r
+\r
+ RB_DLINK_FOREACH(ptr, listener_list.head)\r
+ {\r
+ listener = ptr->data;\r
+ if(GET_SS_FAMILY(addr) != GET_SS_FAMILY(&listener->addr))\r
+ continue;\r
+ \r
+ switch(GET_SS_FAMILY(addr))\r
+ {\r
+ case AF_INET:\r
+ {\r
+ struct sockaddr_in *in4 = (struct sockaddr_in *)addr;\r
+ struct sockaddr_in *lin4 = (struct sockaddr_in *)&listener->addr;\r
+ if(in4->sin_addr.s_addr == lin4->sin_addr.s_addr && \r
+ in4->sin_port == lin4->sin_port )\r
+ {\r
+ if(listener->F == NULL)\r
+ last_closed = listener;\r
+ else\r
+ return(listener);\r
+ }\r
+ break;\r
+ }\r
+#ifdef IPV6\r
+ case AF_INET6:\r
+ {\r
+ struct sockaddr_in6 *in6 = (struct sockaddr_in6 *)addr;\r
+ struct sockaddr_in6 *lin6 =(struct sockaddr_in6 *)&listener->addr;\r
+ if(IN6_ARE_ADDR_EQUAL(&in6->sin6_addr, &lin6->sin6_addr) &&\r
+ in6->sin6_port == lin6->sin6_port)\r
+ {\r
+ if(listener->F == NULL)\r
+ last_closed = listener;\r
+ else\r
+ return(listener);\r
+ }\r
+ break;\r
+ \r
+ }\r
+#endif\r
+\r
+ default:\r
+ break;\r
+ }\r
+ }\r
+ return last_closed;\r
+}\r
+\r
+/*\r
+ * add_listener- create a new listener\r
+ * port - the port number to listen on\r
+ * vhost_ip - if non-null must contain a valid IP address string in\r
+ * the format "255.255.255.255"\r
+ */\r
+void\r
+add_listener(int port, const char *vhost_ip, int family, int ssl)\r
+{\r
+ struct Listener *listener;\r
+ struct rb_sockaddr_storage vaddr;\r
+\r
+ /*\r
+ * if no port in conf line, don't bother\r
+ */\r
+ if(port == 0)\r
+ return;\r
+ \r
+ memset(&vaddr, 0, sizeof(vaddr));\r
+ GET_SS_FAMILY(&vaddr) = family;\r
+\r
+ if(vhost_ip != NULL)\r
+ {\r
+ if(rb_inet_pton_sock(vhost_ip, (struct sockaddr *)&vaddr) <= 0)\r
+ return;\r
+ } else\r
+ {\r
+ switch(family)\r
+ {\r
+ case AF_INET:\r
+ ((struct sockaddr_in *)&vaddr)->sin_addr.s_addr = INADDR_ANY;\r
+ break;\r
+#ifdef IPV6\r
+ case AF_INET6:\r
+ memcpy(&((struct sockaddr_in6 *)&vaddr)->sin6_addr, &in6addr_any, sizeof(struct in6_addr));\r
+ break;\r
+#endif\r
+ default:\r
+ return;\r
+ } \r
+ }\r
+ switch(family)\r
+ {\r
+ case AF_INET:\r
+ SET_SS_LEN(&vaddr, sizeof(struct sockaddr_in));\r
+ ((struct sockaddr_in *)&vaddr)->sin_port = htons(port);\r
+ break;\r
+#ifdef IPV6\r
+ case AF_INET6:\r
+ SET_SS_LEN(&vaddr, sizeof(struct sockaddr_in6));\r
+ ((struct sockaddr_in6 *)&vaddr)->sin6_port = htons(port);\r
+ break;\r
+#endif\r
+ default:\r
+ break;\r
+ }\r
+ if((listener = find_listener(&vaddr)))\r
+ {\r
+ if(listener->F != NULL)\r
+ return;\r
+ }\r
+ else\r
+ {\r
+ listener = make_listener(&vaddr);\r
+ rb_dlinkAdd(listener, &listener->node, &listener_list);\r
+ }\r
+\r
+ listener->F = NULL;\r
+ listener->ssl = ssl;\r
+ if(inetport(listener))\r
+ listener->active = 1;\r
+ else\r
+ close_listener(listener);\r
+}\r
+\r
+/*\r
+ * close_listener - close a single listener\r
+ */\r
+void\r
+close_listener(struct Listener *listener)\r
+{\r
+ s_assert(listener != NULL);\r
+ if(listener == NULL)\r
+ return;\r
+ if(listener->F != NULL)\r
+ {\r
+ rb_close(listener->F);\r
+ listener->F = NULL;\r
+ }\r
+\r
+ listener->active = 0;\r
+\r
+ if(listener->ref_count)\r
+ return;\r
+\r
+ free_listener(listener);\r
+}\r
+\r
+/*\r
+ * close_listeners - close and free all listeners that are not being used\r
+ */\r
+void\r
+close_listeners()\r
+{\r
+ struct Listener *listener;\r
+ rb_dlink_node *ptr, *next;\r
+\r
+ RB_DLINK_FOREACH_SAFE(ptr, next, listener_list.head)\r
+ {\r
+ listener = ptr->data;\r
+ close_listener(listener);\r
+ }\r
+}\r
+\r
+/*\r
+ * add_connection - creates a client which has just connected to us on \r
+ * the given fd. The sockhost field is initialized with the ip# of the host.\r
+ * The client is sent to the auth module for verification, and not put in\r
+ * any client list yet.\r
+ */\r
+static void\r
+add_connection(struct Listener *listener, rb_fde_t *F, struct sockaddr *sai, struct sockaddr *lai, void *ssl_ctl)\r
+{\r
+ struct Client *new_client;\r
+ s_assert(NULL != listener);\r
+ /* \r
+ * get the client socket name from the socket\r
+ * the client has already been checked out in accept_connection\r
+ */\r
+ new_client = make_client(NULL);\r
+\r
+ memcpy(&new_client->localClient->ip, sai, sizeof(struct rb_sockaddr_storage));\r
+ new_client->localClient->lip = rb_malloc(sizeof(struct rb_sockaddr_storage));\r
+ memcpy(new_client->localClient->lip, lai, sizeof(struct rb_sockaddr_storage));\r
+\r
+ /* \r
+ * copy address to 'sockhost' as a string, copy it to host too\r
+ * so we have something valid to put into error messages...\r
+ */\r
+ rb_inet_ntop_sock((struct sockaddr *)&new_client->localClient->ip, new_client->sockhost, \r
+ sizeof(new_client->sockhost));\r
+\r
+\r
+ rb_strlcpy(new_client->host, new_client->sockhost, sizeof(new_client->host));\r
+\r
+#ifdef IPV6\r
+ if(GET_SS_FAMILY(&new_client->localClient->ip) == AF_INET6 && ConfigFileEntry.dot_in_ip6_addr == 1)\r
+ {\r
+ rb_strlcat(new_client->host, ".", sizeof(new_client->host));\r
+ }\r
+#endif\r
+\r
+ new_client->localClient->F = F;\r
+ add_to_cli_fd_hash(new_client);\r
+ new_client->localClient->listener = listener;\r
+ new_client->localClient->ssl_ctl = ssl_ctl;\r
+ if(ssl_ctl != NULL || rb_fd_ssl(F))\r
+ SetSSL(new_client);\r
+\r
+ ++listener->ref_count;\r
+\r
+ start_auth(new_client);\r
+}\r
+\r
+static time_t last_oper_notice = 0;\r
+\r
+static const char *toofast = "ERROR :Reconnecting too fast, throttled.\r\n";\r
+\r
+static int\r
+accept_precallback(rb_fde_t *F, struct sockaddr *addr, rb_socklen_t addrlen, void *data)\r
+{\r
+ struct Listener *listener = (struct Listener *)data;\r
+ char buf[BUFSIZE];\r
+ struct ConfItem *aconf;\r
+\r
+ if(listener->ssl && (!ssl_ok || !get_ssld_count()))\r
+ {\r
+ fprintf(stderr, "closed socket\n");\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+ \r
+ if((maxconnections - 10) < rb_get_fd(F)) /* XXX this is kinda bogus */\r
+ {\r
+ ++ServerStats.is_ref;\r
+ /*\r
+ * slow down the whining to opers bit\r
+ */\r
+ if((last_oper_notice + 20) <= rb_current_time())\r
+ {\r
+ sendto_realops_flags(UMODE_ALL, L_ALL,\r
+ "All connections in use. (%s)",\r
+ get_listener_name(listener));\r
+ last_oper_notice = rb_current_time();\r
+ }\r
+ \r
+ rb_write(F, "ERROR :All connections in use\r\n", 32);\r
+ rb_close(F);\r
+ /* Re-register a new IO request for the next accept .. */\r
+ return 0;\r
+ }\r
+\r
+ aconf = find_dline(addr);\r
+ if(aconf != NULL && (aconf->status & CONF_EXEMPTDLINE))\r
+ return 1;\r
+ \r
+ /* Do an initial check we aren't connecting too fast or with too many\r
+ * from this IP... */\r
+ if(aconf != NULL)\r
+ {\r
+ ServerStats.is_ref++;\r
+ \r
+ if(ConfigFileEntry.dline_with_reason)\r
+ {\r
+ if (rb_snprintf(buf, sizeof(buf), "ERROR :*** Banned: %s\r\n", aconf->passwd) >= (int)(sizeof(buf)-1))\r
+ {\r
+ buf[sizeof(buf) - 3] = '\r';\r
+ buf[sizeof(buf) - 2] = '\n';\r
+ buf[sizeof(buf) - 1] = '\0';\r
+ }\r
+ }\r
+ else\r
+ strcpy(buf, "ERROR :You have been D-lined.\r\n");\r
+ \r
+ rb_write(F, buf, strlen(buf));\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+\r
+ if(check_reject(F, addr))\r
+ return 0;\r
+ \r
+ if(throttle_add(addr))\r
+ {\r
+ rb_write(F, toofast, strlen(toofast));\r
+ rb_close(F);\r
+ return 0;\r
+ }\r
+\r
+ return 1;\r
+}\r
+\r
+static void\r
+accept_ssld(rb_fde_t *F, struct sockaddr *addr, struct sockaddr *laddr, struct Listener *listener)\r
+{\r
+ ssl_ctl_t *ctl;\r
+ rb_fde_t *xF[2];\r
+ rb_socketpair(AF_UNIX, SOCK_STREAM, 0, &xF[0], &xF[1], "Incoming ssld Connection");\r
+ ctl = start_ssld_accept(F, xF[1], rb_get_fd(xF[0])); /* this will close F for us */\r
+ add_connection(listener, xF[0], addr, laddr, ctl);\r
+}\r
+\r
+static void\r
+accept_callback(rb_fde_t *F, int status, struct sockaddr *addr, rb_socklen_t addrlen, void *data)\r
+{\r
+ struct Listener *listener = data;\r
+ struct rb_sockaddr_storage lip;\r
+ unsigned int locallen = sizeof(struct rb_sockaddr_storage);\r
+ \r
+ ServerStats.is_ac++;\r
+ if(getsockname(rb_get_fd(F), (struct sockaddr *) &lip, &locallen) < 0)\r
+ {\r
+ /* this shouldn't fail so... */\r
+ /* XXX add logging of this */\r
+ rb_close(F);\r
+ }\r
+ if(listener->ssl)\r
+ accept_ssld(F, addr, (struct sockaddr *)&lip, listener);\r
+ else\r
+ add_connection(listener, F, addr, (struct sockaddr *)&lip, NULL);\r
+}\r
projects / irc / rqf / shadowircd.git / blobdiff