Note rsyncd-over-ssh and documentation TODOs.
[rsync/rsync.git] / socket.c
index e642082..0ad8a16 100644 (file)
--- a/socket.c
+++ b/socket.c
 
 #include "rsync.h"
 
-#ifndef HAVE_GETADDRINFO
-#include "lib/addrinfo.h"
-#endif
-
-// extern int af;                      /* NO MORE BLOODY GLOBALS! */
-
 /* Establish a proxy connection on an open socket to a web roxy by
  * using the CONNECT method. */
 static int establish_proxy_connection(int fd, char *host, int port)
@@ -164,6 +158,10 @@ int open_socket_out(char *host, int port, const char *bind_address,
        }
 
        s = -1;
+       /* Try to connect to all addresses for this machine until we get
+        * through.  It might e.g. be multi-homed, or have both IPv4 and IPv6
+        * addresses.  We need to create a socket for each record, since the
+        * address record tells us what protocol to use to try to connect. */
        for (res = res0; res; res = res->ai_next) {
                s = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
                if (s < 0)
@@ -178,12 +176,16 @@ int open_socket_out(char *host, int port, const char *bind_address,
                        bhints.ai_flags = AI_PASSIVE;
                        error = getaddrinfo(bind_address, NULL, &bhints, &bres);
                        if (error) {
-                               rprintf(FERROR, RSYNC_NAME ": getaddrinfo: bind address %s <noport>: %s\n",
+                               rprintf(FERROR, RSYNC_NAME ": getaddrinfo: "
+                                       "bind address %s <noport>: %s\n",
                                        bind_address, gai_strerror(error));
                                continue;
                        }
                        if (bres->ai_next) {
-                               rprintf(FERROR, RSYNC_NAME ": getaddrinfo: bind address %s resolved to multiple hosts\n",
+                               /* I'm not at all sure that this is the right
+                                * response here... -- mbp */
+                               rprintf(FERROR, RSYNC_NAME ": getaddrinfo: "
+                                       "bind address %s resolved to multiple hosts\n",
                                        bind_address);
                                freeaddrinfo(bres);
                                continue;
@@ -296,6 +298,7 @@ static int open_socket_in(int type, int port, const char *bind_address,
                        case EPROTONOSUPPORT:
                        case EAFNOSUPPORT:
                        case EPFNOSUPPORT:
+                       case EINVAL:
                                /* See if there's another address that will work... */
                                continue;
                        }
@@ -374,8 +377,8 @@ void start_accept_loop(int port, int (*fn)(int ))
        while (1) {
                fd_set fds;
                int fd;
-               struct sockaddr addr;
-               int in_addrlen = sizeof(addr);
+               struct sockaddr_storage addr;
+               int addrlen = sizeof(addr);
 
                /* close log file before the potentially very long select so
                   file can be trimmed by another process instead of growing
@@ -391,7 +394,7 @@ void start_accept_loop(int port, int (*fn)(int ))
 
                if(!FD_ISSET(s, &fds)) continue;
 
-               fd = accept(s,(struct sockaddr *)&addr,&in_addrlen);
+               fd = accept(s,(struct sockaddr *)&addr,&addrlen);
 
                if (fd == -1) continue;
 
@@ -557,7 +560,7 @@ void become_daemon(void)
  **/
 char *client_addr(int fd)
 {
-       struct sockaddr ss;
+       struct sockaddr_storage ss;
        int     length = sizeof(ss);
        static char addr_buf[100];
        static int initialised;
@@ -566,22 +569,28 @@ char *client_addr(int fd)
 
        initialised = 1;
 
-       if (getpeername(fd, &ss, &length)) {
+       if (getpeername(fd, (struct sockaddr *)&ss, &length)) {
                exit_cleanup(RERR_SOCKETIO);
        }
 
-       getnameinfo(&ss, length,
+       getnameinfo((struct sockaddr *)&ss, length,
                addr_buf, sizeof(addr_buf), NULL, 0, NI_NUMERICHOST);
        return addr_buf;
 }
 
 
+static int get_sockaddr_family(const struct sockaddr_storage *ss)
+{
+       return ((struct sockaddr *) ss)->sa_family;
+}
+
+
 /**
  * Return the DNS name of the client 
  **/
 char *client_name(int fd)
 {
-       struct sockaddr ss;
+       struct sockaddr_storage ss;
        int     length = sizeof(ss);
        static char name_buf[100];
        static char port_buf[100];
@@ -599,12 +608,12 @@ char *client_name(int fd)
        if (getpeername(fd, (struct sockaddr *)&ss, &length)) {
                /* FIXME: Can we really not continue? */
                rprintf(FERROR, RSYNC_NAME ": getpeername on fd%d failed: %s\n",
-                       strerror(errno));                       
+                       fd, strerror(errno));
                exit_cleanup(RERR_SOCKETIO);
        }
 
 #ifdef INET6
-        if (ss.ss_family == AF_INET6 && 
+        if (get_sockaddr_family(&ss) == AF_INET6 && 
            IN6_IS_ADDR_V4MAPPED(&((struct sockaddr_in6 *)&ss)->sin6_addr)) {
                struct sockaddr_in6 sin6;
                struct sockaddr_in *sin;
@@ -648,7 +657,7 @@ char *client_name(int fd)
 
        /* XXX sin6_flowinfo and other fields */
        for (res = res0; res; res = res->ai_next) {
-               if (res->ai_family != ss.sa_family)
+               if (res->ai_family != get_sockaddr_family(&ss))
                        continue;
                if (res->ai_addrlen != length)
                        continue;
@@ -656,7 +665,7 @@ char *client_name(int fd)
                        break;
        }
 
-       /* TODO: Do a forward lookup as well to prevent spoofing */
+       /* TODO: Do a  forward lookup as well to prevent spoofing */
 
        if (res == NULL) {
                strcpy(name_buf, def);
@@ -669,69 +678,6 @@ char *client_name(int fd)
        return name_buf;
 }
 
-/**
- * Convert a string to an IP address. The string can be a name or
- * dotted decimal number.
- *
- * Returns a pointer to a static in_addr struct -- if you call this
- * more than once then you should copy it.
- *
- * TODO: Use getaddrinfo() instead, or make this function call getnameinfo
- **/
-struct in_addr *ip_address(const char *str)
-{
-       static struct in_addr ret;
-       struct hostent *hp;
-
-       if (!str) {
-               rprintf (FERROR, "ip_address received NULL name\n");
-               return NULL;
-       }
-
-       /* try as an IP address */
-       if (inet_aton(str, &ret) != 0) {
-               return &ret;
-       }
-
-       /* otherwise assume it's a network name of some sort and use 
-          gethostbyname */
-       if ((hp = gethostbyname (str)) == 0) {
-               rprintf(FERROR, "gethostbyname failed for \"%s\": unknown host?\n",str);
-               return NULL;
-       }
-
-       if (hp->h_addr == NULL) {
-               rprintf(FERROR, "gethostbyname: host address is invalid for host \"%s\"\n",str);
-               return NULL;
-       }
-
-       if (hp->h_length > sizeof ret) {
-               rprintf(FERROR, "gethostbyname: host address for \"%s\" is too large\n",
-                       str);
-               return NULL;
-       }
-
-       if (hp->h_addrtype != AF_INET) {
-               rprintf (FERROR, "gethostname: host address for \"%s\" is not IPv4\n",
-                        str);
-               return NULL;
-       }
-
-       /* This is kind of difficult.  The only field in ret is
-          s_addr, which is the IP address as a 32-bit int.  On
-          UNICOS, s_addr is in fact a *bitfield* for reasons best
-          know to Cray.  This means we can't memcpy in to it.  On the
-          other hand, h_addr is a char*, so we can't just assign.
-
-          Since there's meant to be only one field inside the in_addr
-          structure we will try just copying over the top and see how
-          that goes. */
-       memcpy (&ret, hp->h_addr, hp->h_length);
-
-       return &ret;
-}
-
-
 
 /*******************************************************************
 this is like socketpair but uses tcp. It is used by the Samba