]> jfr.im git - irc/rqf/shadowircd.git/blobdiff - src/s_auth.c
dlink -> rb_dlink
[irc/rqf/shadowircd.git] / src / s_auth.c
index 3494e5b618b15023489d3d7d44a7e605da28154d..124a3c1ca995985bffb4d00fc11862015feb738a 100644 (file)
@@ -21,7 +21,7 @@
  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
  *  USA
  *
- *  $Id: s_auth.c 1683 2006-06-20 14:26:16Z jilles $ */
+ *  $Id: s_auth.c 3354 2007-04-03 09:21:31Z nenolod $ */
 
 /*
  * Changes:
 
 static const char *HeaderMessages[] =
 {
-       "NOTICE AUTH :*** Looking up your hostname...",
-       "NOTICE AUTH :*** Found your hostname",
-       "NOTICE AUTH :*** Couldn't look up your hostname",
-       "NOTICE AUTH :*** Checking Ident",
-       "NOTICE AUTH :*** Got Ident response",
-       "NOTICE AUTH :*** No Ident response",
-       "NOTICE AUTH :*** Your hostname is too long, ignoring hostname",
-       "NOTICE AUTH :*** Your forward and reverse DNS do not match, ignoring hostname",
-       "NOTICE AUTH :*** Cannot verify hostname validity, ignoring hostname",
+       ":*** Looking up your hostname...",
+       ":*** Found your hostname",
+       ":*** Couldn't look up your hostname",
+       ":*** Checking Ident",
+       ":*** Got Ident response",
+       ":*** No Ident response",
+       ":*** Your hostname is too long, ignoring hostname",
+       ":*** Your forward and reverse DNS do not match, ignoring hostname",
+       ":*** Cannot verify hostname validity, ignoring hostname",
 };
 
 typedef enum
@@ -87,9 +87,9 @@ typedef enum
 }
 ReportType;
 
-#define sendheader(c, r) sendto_one(c, HeaderMessages[(r)]) 
+#define sendheader(c, r) sendto_one_notice(c, HeaderMessages[(r)]) 
 
-static dlink_list auth_poll_list;
+static rb_dlink_list auth_poll_list;
 static BlockHeap *auth_heap;
 static EVH timeout_auth_queries_event;
 
@@ -147,10 +147,10 @@ release_auth_client(struct AuthRequest *auth)
                return;
 
        client->localClient->auth_request = NULL;
-       dlinkDelete(&auth->node, &auth_poll_list);
+       rb_dlinkDelete(&auth->node, &auth_poll_list);
        free_auth_request(auth);        
-       if(client->localClient->fd > highest_fd)
-               highest_fd = client->localClient->fd;
+       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
@@ -158,9 +158,9 @@ release_auth_client(struct AuthRequest *auth)
         *     -- adrian
         */
        client->localClient->allow_read = MAX_FLOOD;
-       comm_setflush(client->localClient->fd, 1000, flood_recalc, client);
-       dlinkAddTail(client, &client->node, &global_client_list);
-       read_packet(client->localClient->fd, client);
+       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);
 }
 
 /*
@@ -182,7 +182,7 @@ auth_dns_callback(void *vptr, struct DNSReply *reply)
                sendto_realops_snomask(SNO_GENERAL, L_ALL,
                        "auth_dns_callback(): auth->client->localClient (%s) is NULL", get_client_name(auth->client, HIDE_IP));
 
-               dlinkDelete(&auth->node, &auth_poll_list);
+               rb_dlinkDelete(&auth->node, &auth_poll_list);
                free_auth_request(auth);
 
                /* and they will silently drop through and all will hopefully be ok... -nenolod */
@@ -249,7 +249,7 @@ auth_error(struct AuthRequest *auth)
 {
        ++ServerStats->is_abad;
 
-       comm_close(auth->fd);
+       rb_close(auth->fd);
        auth->fd = -1;
 
        ClearAuth(auth);
@@ -278,7 +278,7 @@ start_auth_query(struct AuthRequest *auth)
                return 0;
        
        family = auth->client->localClient->ip.ss_family;
-       if((fd = comm_socket(family, SOCK_STREAM, 0, "ident")) == -1)
+       if((fd = rb_socket(family, SOCK_STREAM, 0, "ident")) == -1)
        {
                report_error("creating auth stream socket %s:%s",
                             get_client_name(auth->client, SHOW_IP), 
@@ -286,12 +286,16 @@ start_auth_query(struct AuthRequest *auth)
                ++ServerStats->is_abad;
                return 0;
        }
-       if((MAXCONNECTIONS - 10) < fd)
+
+       /*
+        * TBD: this is a pointless arbitrary limit .. we either have a socket or not. -nenolod
+        */
+       if((rb_get_maxconnections() - 10) < fd)
        {
                sendto_realops_snomask(SNO_GENERAL, L_ALL,
                                     "Can't allocate fd for auth on %s",
                                     get_client_name(auth->client, SHOW_IP));
-               comm_close(fd);
+               rb_close(fd);
                return 0;
        }
 
@@ -305,7 +309,7 @@ start_auth_query(struct AuthRequest *auth)
         * and machines with multiple IP addresses are common now
         */
        memset(&localaddr, 0, locallen);
-       getsockname(auth->client->localClient->fd,
+       getsockname(auth->client->localClient->F->fd,
                    (struct sockaddr *) &localaddr, &locallen);
        
        mangle_mapped_sockaddr((struct sockaddr *)&localaddr);
@@ -320,7 +324,7 @@ start_auth_query(struct AuthRequest *auth)
        auth->fd = fd;
        SetAuthConnect(auth);
 
-       comm_connect_tcp(fd, auth->client->sockhost, 113,
+       rb_connect_tcp(fd, auth->client->sockhost, 113,
                         (struct sockaddr *) &localaddr, GET_SS_LEN(localaddr),
                         auth_connect_callback, auth, 
                         localaddr.ss_family, GlobalSetOptions.ident_timeout);
@@ -400,10 +404,6 @@ start_auth(struct Client *client)
        if(client == NULL)
                return;
 
-       /* to aid bopm which needs something unique to match against */
-       sendto_one(client, "NOTICE AUTH :*** Processing connection to %s",
-                       me.name);
-
        auth = make_auth_request(client);
 
        auth->dns_query.ptr = auth;
@@ -419,7 +419,7 @@ start_auth(struct Client *client)
        if(ConfigFileEntry.disable_auth == 0)
                start_auth_query(auth);
 
-       dlinkAdd(auth, &auth->node, &auth_poll_list);
+       rb_dlinkAdd(auth, &auth->node, &auth_poll_list);
 }
 
 /*
@@ -429,8 +429,8 @@ start_auth(struct Client *client)
 static void
 timeout_auth_queries_event(void *notused)
 {
-       dlink_node *ptr;
-       dlink_node *next_ptr;
+       rb_dlink_node *ptr;
+       rb_dlink_node *next_ptr;
        struct AuthRequest *auth;
 
        DLINK_FOREACH_SAFE(ptr, next_ptr, auth_poll_list.head)
@@ -440,7 +440,7 @@ timeout_auth_queries_event(void *notused)
                if(auth->timeout < CurrentTime)
                {
                        if(auth->fd >= 0)
-                               comm_close(auth->fd);
+                               rb_close(auth->fd);
 
                        if(IsDoingAuth(auth))
                        {
@@ -463,7 +463,7 @@ timeout_auth_queries_event(void *notused)
 }
 
 /*
- * auth_connect_callback() - deal with the result of comm_connect_tcp()
+ * auth_connect_callback() - deal with the result of rb_connect_tcp()
  *
  * If the connection failed, we simply close the auth fd and report
  * a failure. If the connection suceeded send the ident server a query
@@ -492,9 +492,9 @@ auth_connect_callback(int fd, int error, void *data)
        }
 
        if(getsockname
-          (auth->client->localClient->fd, (struct sockaddr *) &us,
+          (auth->client->localClient->F->fd, (struct sockaddr *) &us,
            (socklen_t *) & ulen)
-          || getpeername(auth->client->localClient->fd,
+          || getpeername(auth->client->localClient->F->fd,
                          (struct sockaddr *) &them, (socklen_t *) & tlen))
        {
                ilog(L_IOERROR, "auth get{sock,peer}name error for %s:%m",
@@ -502,7 +502,7 @@ auth_connect_callback(int fd, int error, void *data)
                auth_error(auth);
                return;
        }
-       ircsnprintf(authbuf, sizeof(authbuf), "%u , %u\r\n",
+       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)
@@ -538,7 +538,7 @@ read_auth_reply(int fd, void *data)
 
        if(len < 0 && ignoreErrno(errno))
        {
-               comm_setselect(fd, FDLIST_IDLECLIENT, COMM_SELECT_READ, read_auth_reply, auth, 0);
+               rb_setselect(fd, FDLIST_IDLECLIENT, COMM_SELECT_READ, read_auth_reply, auth, 0);
                return;
        }
 
@@ -569,7 +569,7 @@ read_auth_reply(int fd, void *data)
                }
        }
 
-       comm_close(auth->fd);
+       rb_close(auth->fd);
        auth->fd = -1;
        ClearAuth(auth);
 
@@ -611,8 +611,8 @@ delete_auth_queries(struct Client *target_p)
                delete_resolver_queries(&auth->dns_query);
 
        if(auth->fd >= 0)
-               comm_close(auth->fd);
+               rb_close(auth->fd);
                
-       dlinkDelete(&auth->node, &auth_poll_list);
+       rb_dlinkDelete(&auth->node, &auth_poll_list);
        free_auth_request(auth);
 }