X-Git-Url: https://jfr.im/git/irc/rqf/shadowircd.git/blobdiff_plain/6e9b4415cce8808ad39f90612f0218274f3cb1c1..13ae2f4b6904ebf7b8160902f9ffeb80f7585ed2:/src/s_auth.c

diff --git a/src/s_auth.c b/src/s_auth.c
index dc3aecd..2ea496d 100644
--- a/src/s_auth.c
+++ b/src/s_auth.c
@@ -39,13 +39,12 @@
 #include "s_conf.h"
 #include "client.h"
 #include "common.h"
-#include "irc_string.h"
-#include "sprintf_irc.h"
+#include "match.h"
 #include "ircd.h"
 #include "numeric.h"
 #include "packet.h"
 #include "res.h"
-#include "s_log.h"
+#include "logger.h"
 #include "s_stats.h"
 #include "send.h"
 #include "hook.h"
@@ -102,8 +101,8 @@ init_auth(void)
 {
 	/* This hook takes a struct Client for its argument */
 	memset(&auth_poll_list, 0, sizeof(auth_poll_list));
-	eventAddIsh("timeout_auth_queries_event", timeout_auth_queries_event, NULL, 1);
-	auth_heap = rb_bh_create(sizeof(struct AuthRequest), LCLIENT_HEAP_SIZE);
+	rb_event_addish("timeout_auth_queries_event", timeout_auth_queries_event, NULL, 1);
+	auth_heap = rb_bh_create(sizeof(struct AuthRequest), LCLIENT_HEAP_SIZE, "auth_heap");
 }
 
 /*
@@ -114,7 +113,7 @@ make_auth_request(struct Client *client)
 {
 	struct AuthRequest *request = rb_bh_alloc(auth_heap);
 	client->localClient->auth_request = request;
-	request->fd = -1;
+	request->F = NULL;
 	request->client = client;
 	request->timeout = rb_current_time() + ConfigFileEntry.connect_timeout;
 	return request;
@@ -145,8 +144,6 @@ release_auth_client(struct AuthRequest *auth)
 	client->localClient->auth_request = NULL;
 	rb_dlinkDelete(&auth->node, &auth_poll_list);
 	free_auth_request(auth);	
-	if(client->localClient->F->fd > highest_fd)
-		highest_fd = client->localClient->F->fd;
 
 	/*
 	 * When a client has auth'ed, we want to start reading what it sends
@@ -154,9 +151,8 @@ release_auth_client(struct AuthRequest *auth)
 	 *     -- adrian
 	 */
 	client->localClient->allow_read = MAX_FLOOD;
-	rb_setflush(client->localClient->F->fd, 1000, flood_recalc, client);
 	rb_dlinkAddTail(client, &client->node, &global_client_list);
-	read_packet(client->localClient->F->fd, client);
+	read_packet(client->localClient->F, client);
 }
 
 /*
@@ -202,7 +198,7 @@ auth_dns_callback(void *vptr, struct DNSReply *reply)
 				good = 0;
 			}
 		}
-#ifdef IPV6
+#ifdef RB_IPV6
 		else if(auth->client->localClient->ip.ss_family == AF_INET6)
 		{
 			struct sockaddr_in6 *ip, *ip_fwd;
@@ -225,7 +221,7 @@ auth_dns_callback(void *vptr, struct DNSReply *reply)
 
                 if(good && strlen(reply->h_name) <= HOSTLEN)
                 {
-                        strlcpy(auth->client->host, reply->h_name, sizeof(auth->client->host));
+                        rb_strlcpy(auth->client->host, reply->h_name, sizeof(auth->client->host));
                         sendheader(auth->client, REPORT_FIN_DNS);
                 }
                 else if (strlen(reply->h_name) > HOSTLEN)
@@ -243,10 +239,10 @@ auth_dns_callback(void *vptr, struct DNSReply *reply)
 static void
 auth_error(struct AuthRequest *auth)
 {
-	++ServerStats->is_abad;
+	++ServerStats.is_abad;
 
-	rb_close(auth->fd);
-	auth->fd = -1;
+	rb_close(auth->F);
+	auth->F = NULL;
 
 	ClearAuth(auth);
 	sendheader(auth->client, REPORT_FAIL_ID);
@@ -265,33 +261,31 @@ auth_error(struct AuthRequest *auth)
 static int
 start_auth_query(struct AuthRequest *auth)
 {
-	struct irc_sockaddr_storage localaddr;
-	socklen_t locallen = sizeof(struct irc_sockaddr_storage);
-	int fd;
+	struct rb_sockaddr_storage localaddr, destaddr;
+	socklen_t locallen = sizeof(struct rb_sockaddr_storage);
+	rb_fde_t *F;
 	int family;
 	
 	if(IsAnyDead(auth->client))
 		return 0;
 	
 	family = auth->client->localClient->ip.ss_family;
-	if((fd = rb_socket(family, SOCK_STREAM, 0, "ident")) == -1)
+	if((F = rb_socket(family, SOCK_STREAM, 0, "ident")) == NULL)
 	{
-		report_error("creating auth stream socket %s:%s",
-			     get_client_name(auth->client, SHOW_IP), 
-			     log_client_name(auth->client, SHOW_IP), errno);
-		++ServerStats->is_abad;
+		ilog_error("creating auth stream socket");
+		++ServerStats.is_abad;
 		return 0;
 	}
 
 	/*
 	 * TBD: this is a pointless arbitrary limit .. we either have a socket or not. -nenolod
 	 */
-	if((rb_get_maxconnections() - 10) < fd)
+	if((maxconnections - 10) < rb_get_fd(F))
 	{
 		sendto_realops_snomask(SNO_GENERAL, L_ALL,
 				     "Can't allocate fd for auth on %s",
 				     get_client_name(auth->client, SHOW_IP));
-		rb_close(fd);
+		rb_close(F);
 		return 0;
 	}
 
@@ -305,25 +299,34 @@ start_auth_query(struct AuthRequest *auth)
 	 * and machines with multiple IP addresses are common now
 	 */
 	memset(&localaddr, 0, locallen);
-	getsockname(auth->client->localClient->F->fd,
+	getsockname(rb_get_fd(auth->client->localClient->F),
 		    (struct sockaddr *) &localaddr, &locallen);
 	
-	mangle_mapped_sockaddr((struct sockaddr *)&localaddr);
-#ifdef IPV6
+	/* XXX mangle_mapped_sockaddr((struct sockaddr *)&localaddr); */
+#ifdef RB_IPV6
 	if(localaddr.ss_family == AF_INET6)
 	{
 		((struct sockaddr_in6 *)&localaddr)->sin6_port = 0;
 	} else
 #endif
 	((struct sockaddr_in *)&localaddr)->sin_port = 0;
+
+	destaddr = auth->client->localClient->ip;
+#ifdef RB_IPV6
+	if(localaddr.ss_family == AF_INET6)
+	{
+		((struct sockaddr_in6 *)&destaddr)->sin6_port = htons(113);
+	} else
+#endif
+	((struct sockaddr_in *)&destaddr)->sin_port = htons(113);
 	
-	auth->fd = fd;
+	auth->F = F;
 	SetAuthConnect(auth);
 
-	rb_connect_tcp(fd, auth->client->sockhost, 113,
-			 (struct sockaddr *) &localaddr, GET_SS_LEN(localaddr),
+	rb_connect_tcp(F, (struct sockaddr *)&destaddr,
+			 (struct sockaddr *) &localaddr, GET_SS_LEN(&localaddr),
 			 auth_connect_callback, auth, 
-			 localaddr.ss_family, GlobalSetOptions.ident_timeout);
+			 GlobalSetOptions.ident_timeout);
 	return 1;		/* We suceed here for now */
 }
 
@@ -435,13 +438,13 @@ timeout_auth_queries_event(void *notused)
 
 		if(auth->timeout < rb_current_time())
 		{
-			if(auth->fd >= 0)
-				rb_close(auth->fd);
+			if(auth->F != NULL)
+				rb_close(auth->F);
 
 			if(IsDoingAuth(auth))
 			{
 				ClearAuth(auth);
-				++ServerStats->is_abad;
+				++ServerStats.is_abad;
 				sendheader(auth->client, REPORT_FAIL_ID);
 				auth->client->localClient->auth_request = NULL;
 			}
@@ -470,7 +473,7 @@ timeout_auth_queries_event(void *notused)
  * problems arise. -avalon
  */
 static void
-auth_connect_callback(int fd, int error, void *data)
+auth_connect_callback(rb_fde_t *F, int error, void *data)
 {
 	struct AuthRequest *auth = data;
 	struct sockaddr_in us;
@@ -480,7 +483,7 @@ auth_connect_callback(int fd, int error, void *data)
 	socklen_t tlen = sizeof(struct sockaddr_in);
 
 	/* Check the error */
-	if(error != COMM_OK)
+	if(error != RB_OK)
 	{
 		/* We had an error during connection :( */
 		auth_error(auth);
@@ -488,9 +491,9 @@ auth_connect_callback(int fd, int error, void *data)
 	}
 
 	if(getsockname
-	   (auth->client->localClient->F->fd, (struct sockaddr *) &us,
+	   (rb_get_fd(auth->client->localClient->F), (struct sockaddr *) &us,
 	    (socklen_t *) & ulen)
-	   || getpeername(auth->client->localClient->F->fd,
+	   || getpeername(rb_get_fd(auth->client->localClient->F),
 			  (struct sockaddr *) &them, (socklen_t *) & tlen))
 	{
 		ilog(L_IOERROR, "auth get{sock,peer}name error for %s:%m",
@@ -501,14 +504,14 @@ auth_connect_callback(int fd, int error, void *data)
 	rb_snprintf(authbuf, sizeof(authbuf), "%u , %u\r\n",
 		   (unsigned int) ntohs(them.sin_port), (unsigned int) ntohs(us.sin_port));
 
-	if(write(auth->fd, authbuf, strlen(authbuf)) == -1)
+	if(write(rb_get_fd(auth->F), authbuf, strlen(authbuf)) == -1)
 	{
 		auth_error(auth);
 		return;
 	}
 	ClearAuthConnect(auth);
 	SetAuthPending(auth);
-	read_auth_reply(auth->fd, auth);
+	read_auth_reply(auth->F, auth);
 }
 
 
@@ -521,7 +524,7 @@ auth_connect_callback(int fd, int error, void *data)
 #define AUTH_BUFSIZ 128
 
 static void
-read_auth_reply(int fd, void *data)
+read_auth_reply(rb_fde_t *F, void *data)
 {
 	struct AuthRequest *auth = data;
 	char *s = NULL;
@@ -530,11 +533,11 @@ read_auth_reply(int fd, void *data)
 	int count;
 	char buf[AUTH_BUFSIZ + 1];	/* buffer to read auth reply into */
 
-	len = read(auth->fd, buf, AUTH_BUFSIZ);
+	len = read(rb_get_fd(F), buf, AUTH_BUFSIZ);
 
-	if(len < 0 && ignoreErrno(errno))
+	if(len < 0 && rb_ignore_errno(errno))
 	{
-		rb_setselect(fd, FDLIST_IDLECLIENT, COMM_SELECT_READ, read_auth_reply, auth, 0);
+		rb_setselect(F, RB_SELECT_READ, read_auth_reply, auth);
 		return;
 	}
 
@@ -565,20 +568,20 @@ read_auth_reply(int fd, void *data)
 		}
 	}
 
-	rb_close(auth->fd);
-	auth->fd = -1;
+	rb_close(auth->F);
+	auth->F = NULL;
 	ClearAuth(auth);
 
 	if(s == NULL)
 	{
-		++ServerStats->is_abad;
+		++ServerStats.is_abad;
 		strcpy(auth->client->username, "unknown");
 		sendheader(auth->client, REPORT_FAIL_ID);
 	}
 	else
 	{
 		sendheader(auth->client, REPORT_FIN_ID);
-		++ServerStats->is_asuc;
+		++ServerStats.is_asuc;
 		SetGotId(auth->client);
 	}
 
@@ -606,8 +609,8 @@ delete_auth_queries(struct Client *target_p)
 	if(IsDNSPending(auth))
 		delete_resolver_queries(&auth->dns_query);
 
-	if(auth->fd >= 0)
-		rb_close(auth->fd);
+	if(auth->F != NULL)
+		rb_close(auth->F);
 		
 	rb_dlinkDelete(&auth->node, &auth_poll_list);
 	free_auth_request(auth);