]> andersk Git - openssh.git/blobdiff - sshconnect.c
- markus@cvs.openbsd.org 2001/10/01 21:51:16
[openssh.git] / sshconnect.c
index 21eff6c6bb5a90bd98114a6fe2b63b37fcaab611..6a9b5489ee9d45c1203b23ee54fac4c9d92653d5 100644 (file)
@@ -2,45 +2,75 @@
  * Author: Tatu Ylonen <ylo@cs.hut.fi>
  * Copyright (c) 1995 Tatu Ylonen <ylo@cs.hut.fi>, Espoo, Finland
  *                    All rights reserved
- * Created: Sat Mar 18 22:15:47 1995 ylo
  * Code to connect to a remote host, and to perform the client side of the
  * login (authentication) dialog.
+ *
+ * As far as I am concerned, the code I have written for this software
+ * can be used freely for any purpose.  Any derived versions of this
+ * software must be clearly marked as such, and if the derived work is
+ * incompatible with the protocol description in the RFC file, it must be
+ * called by a name other than "ssh" or "Secure Shell".
  */
 
 #include "includes.h"
-RCSID("$OpenBSD: sshconnect.c,v 1.77 2000/08/28 03:50:54 deraadt Exp $");
+RCSID("$OpenBSD: sshconnect.c,v 1.111 2001/10/01 21:51:16 markus Exp $");
 
 #include <openssl/bn.h>
-#include <openssl/dsa.h>
-#include <openssl/rsa.h>
 
+#include "ssh.h"
 #include "xmalloc.h"
 #include "rsa.h"
-#include "ssh.h"
 #include "buffer.h"
 #include "packet.h"
 #include "uidswap.h"
 #include "compat.h"
-#include "readconf.h"
 #include "key.h"
 #include "sshconnect.h"
 #include "hostfile.h"
+#include "log.h"
+#include "readconf.h"
+#include "atomicio.h"
+#include "misc.h"
 
 char *client_version_string = NULL;
 char *server_version_string = NULL;
 
 extern Options options;
-#ifdef HAVE___PROGNAME
 extern char *__progname;
-#else /* HAVE___PROGNAME */
-static const char *__progname = "ssh";
-#endif /* HAVE___PROGNAME */
+
+/* AF_UNSPEC or AF_INET or AF_INET6 */
+extern int IPv4or6;
+
+#ifndef INET6_ADDRSTRLEN               /* for non IPv6 machines */
+#define INET6_ADDRSTRLEN 46
+#endif
+
+static const char *
+sockaddr_ntop(struct sockaddr *sa)
+{
+       void *addr;
+       static char addrbuf[INET6_ADDRSTRLEN];
+
+       switch (sa->sa_family) {
+               case AF_INET:
+                       addr = &((struct sockaddr_in *)sa)->sin_addr;
+                       break;
+               case AF_INET6:
+                       addr = &((struct sockaddr_in6 *)sa)->sin6_addr;
+                       break;
+               default:
+                       /* This case should be protected against elsewhere */
+                       abort();
+       }
+       inet_ntop(sa->sa_family, addr, addrbuf, sizeof(addrbuf));
+       return addrbuf;
+}
 
 /*
  * Connect to the given ssh server using a proxy command.
  */
-int
-ssh_proxy_connect(const char *host, u_short port, uid_t original_real_uid,
+static int
+ssh_proxy_connect(const char *host, u_short port, struct passwd *pw,
                  const char *proxy_command)
 {
        Buffer command;
@@ -91,7 +121,7 @@ ssh_proxy_connect(const char *host, u_short port, uid_t original_real_uid,
                char *argv[10];
 
                /* Child.  Permanently give up superuser privileges. */
-               permanently_set_uid(original_real_uid);
+               permanently_set_uid(pw);
 
                /* Redirect stdin and stdout. */
                close(pin[1]);
@@ -115,8 +145,8 @@ ssh_proxy_connect(const char *host, u_short port, uid_t original_real_uid,
 
                /* Execute the proxy command.  Note that we gave up any
                   extra privileges above. */
-               execv(_PATH_BSHELL, argv);
-               perror(_PATH_BSHELL);
+               execv(argv[0], argv);
+               perror(argv[0]);
                exit(1);
        }
        /* Parent. */
@@ -133,16 +163,18 @@ ssh_proxy_connect(const char *host, u_short port, uid_t original_real_uid,
        /* Set the connection file descriptors. */
        packet_set_connection(pout[0], pin[1]);
 
-       return 1;
+       /* Indicate OK return */
+       return 0;
 }
 
 /*
  * Creates a (possibly privileged) socket for use as the ssh connection.
  */
-int
-ssh_create_socket(uid_t original_real_uid, int privileged, int family)
+static int
+ssh_create_socket(struct passwd *pw, int privileged, int family)
 {
-       int sock;
+       int sock, gaierr;
+       struct addrinfo hints, *res;
 
        /*
         * If we are running as root and want to connect to a privileged
@@ -155,17 +187,40 @@ ssh_create_socket(uid_t original_real_uid, int privileged, int family)
                        error("rresvport: af=%d %.100s", family, strerror(errno));
                else
                        debug("Allocated local port %d.", p);
-       } else {
-               /*
-                * Just create an ordinary socket on arbitrary port.  We use
-                * the user's uid to create the socket.
-                */
-               temporarily_use_uid(original_real_uid);
-               sock = socket(family, SOCK_STREAM, 0);
-               if (sock < 0)
-                       error("socket: %.100s", strerror(errno));
-               restore_uid();
+               return sock;
        }
+       /*
+        * Just create an ordinary socket on arbitrary port.  We use
+        * the user's uid to create the socket.
+        */
+       temporarily_use_uid(pw);
+       sock = socket(family, SOCK_STREAM, 0);
+       if (sock < 0)
+               error("socket: %.100s", strerror(errno));
+       restore_uid();
+
+       /* Bind the socket to an alternative local IP address */
+       if (options.bind_address == NULL)
+               return sock;
+
+       memset(&hints, 0, sizeof(hints));
+       hints.ai_family = IPv4or6;
+       hints.ai_socktype = SOCK_STREAM;
+       hints.ai_flags = AI_PASSIVE;
+       gaierr = getaddrinfo(options.bind_address, "0", &hints, &res);
+       if (gaierr) {
+               error("getaddrinfo: %s: %s", options.bind_address,
+                   gai_strerror(gaierr));
+               close(sock);
+               return -1;
+       }
+       if (bind(sock, res->ai_addr, res->ai_addrlen) < 0) {
+               error("bind: %s: %s", options.bind_address, strerror(errno));
+               close(sock);
+               freeaddrinfo(res);
+               return -1;
+       }
+       freeaddrinfo(res);
        return sock;
 }
 
@@ -179,19 +234,32 @@ ssh_create_socket(uid_t original_real_uid, int privileged, int family)
  * second).  If proxy_command is non-NULL, it specifies the command (with %h
  * and %p substituted for host and port, respectively) to use to contact
  * the daemon.
+ * Return values:
+ *    0 for OK
+ *    ECONNREFUSED if we got a "Connection Refused" by the peer on any address
+ *    ECONNABORTED if we failed without a "Connection refused"
+ * Suitable error messages for the connection failure will already have been
+ * printed.
  */
 int
 ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
            u_short port, int connection_attempts,
-           int anonymous, uid_t original_real_uid,
+           int anonymous, struct passwd *pw,
            const char *proxy_command)
 {
+       int gaierr;
+       int on = 1;
        int sock = -1, attempt;
-       struct servent *sp;
-       struct addrinfo hints, *ai, *aitop;
        char ntop[NI_MAXHOST], strport[NI_MAXSERV];
-       int gaierr;
+       struct addrinfo hints, *ai, *aitop;
        struct linger linger;
+       struct servent *sp;
+       /*
+        * Did we get only other errors than "Connection refused" (which
+        * should block fallback to rsh and similar), or did we get at least
+        * one "Connection refused"?
+        */
+       int full_failure = 1;
 
        debug("ssh_connect: getuid %u geteuid %u anon %d",
              (u_int) getuid(), (u_int) geteuid(), anonymous);
@@ -206,7 +274,7 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
        }
        /* If a proxy command is given, connect using it. */
        if (proxy_command != NULL)
-               return ssh_proxy_connect(host, port, original_real_uid, proxy_command);
+               return ssh_proxy_connect(host, port, pw, proxy_command);
 
        /* No proxy command. */
 
@@ -222,8 +290,8 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
         * Try to connect several times.  On some machines, the first time
         * will sometimes fail.  In general socket code appears to behave
         * quite magically on many machines.
-        */
-       for (attempt = 0; attempt < connection_attempts; attempt++) {
+                */
+       for (attempt = 0; ;) {
                if (attempt > 0)
                        debug("Trying again...");
 
@@ -242,24 +310,33 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
                                host, ntop, strport);
 
                        /* Create a socket for connecting. */
-                       sock = ssh_create_socket(original_real_uid,
-                           !anonymous && geteuid() == 0 && port < IPPORT_RESERVED,
+                       sock = ssh_create_socket(pw,
+#ifdef HAVE_CYGWIN
+                           !anonymous,
+#else
+                           !anonymous && geteuid() == 0,
+#endif
                            ai->ai_family);
                        if (sock < 0)
+                               /* Any error is already output */
                                continue;
 
                        /* Connect to the host.  We use the user's uid in the
                         * hope that it will help with tcp_wrappers showing
                         * the remote uid as root.
                         */
-                       temporarily_use_uid(original_real_uid);
+                       temporarily_use_uid(pw);
                        if (connect(sock, ai->ai_addr, ai->ai_addrlen) >= 0) {
                                /* Successful connection. */
                                memcpy(hostaddr, ai->ai_addr, ai->ai_addrlen);
                                restore_uid();
                                break;
                        } else {
-                               debug("connect: %.100s", strerror(errno));
+                               if (errno == ECONNREFUSED)
+                                       full_failure = 0;
+                               log("ssh: connect to address %s port %s: %s",
+                                   sockaddr_ntop(ai->ai_addr), strport,
+                                   strerror(errno));
                                restore_uid();
                                /*
                                 * Close the failed socket; there appear to
@@ -274,6 +351,9 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
                if (ai)
                        break;  /* Successful connection. */
 
+               attempt++;
+               if (attempt >= connection_attempts)
+                       break;
                /* Sleep a moment before retrying. */
                sleep(1);
        }
@@ -282,7 +362,7 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
 
        /* Return failure if we didn't get a successful connection. */
        if (attempt >= connection_attempts)
-               return 0;
+               return full_failure ? ECONNABORTED : ECONNREFUSED;
 
        debug("Connection established.");
 
@@ -293,25 +373,32 @@ ssh_connect(const char *host, struct sockaddr_storage * hostaddr,
        /* setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (void *)&on, sizeof(on)); */
        linger.l_onoff = 1;
        linger.l_linger = 5;
-       setsockopt(sock, SOL_SOCKET, SO_LINGER, (void *) &linger, sizeof(linger));
+       setsockopt(sock, SOL_SOCKET, SO_LINGER, (void *)&linger, sizeof(linger));
+
+       /* Set keepalives if requested. */
+       if (options.keepalives &&
+           setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, (void *)&on,
+           sizeof(on)) < 0)
+               error("setsockopt SO_KEEPALIVE: %.100s", strerror(errno));
 
        /* Set the connection. */
        packet_set_connection(sock, sock);
 
-       return 1;
+       return 0;
 }
 
 /*
  * Waits for the server identification string, and sends our own
  * identification string.
  */
-void
-ssh_exchange_identification()
+static void
+ssh_exchange_identification(void)
 {
        char buf[256], remote_version[256];     /* must be same size! */
        int remote_major, remote_minor, i, mismatch;
        int connection_in = packet_get_connection_in();
        int connection_out = packet_get_connection_out();
+       int minor1 = PROTOCOL_MINOR_1;
 
        /* Read other side\'s version identification. */
        for (;;) {
@@ -365,9 +452,10 @@ ssh_exchange_identification()
                }
                if (remote_minor < 3) {
                        fatal("Remote machine has too old SSH software version.");
-               } else if (remote_minor == 3) {
+               } else if (remote_minor == 3 || remote_minor == 4) {
                        /* We speak 1.3, too. */
                        enable_compat13();
+                       minor1 = 3;
                        if (options.forward_agent) {
                                log("Agent forwarding disabled for protocol 1.3");
                                options.forward_agent = 0;
@@ -388,12 +476,10 @@ ssh_exchange_identification()
                fatal("Protocol major versions differ: %d vs. %d",
                    (options.protocol & SSH_PROTO_2) ? PROTOCOL_MAJOR_2 : PROTOCOL_MAJOR_1,
                    remote_major);
-       if (compat20)
-               packet_set_ssh2_format();
        /* Send our own protocol version identification. */
        snprintf(buf, sizeof buf, "SSH-%d.%d-%.100s\n",
            compat20 ? PROTOCOL_MAJOR_2 : PROTOCOL_MAJOR_1,
-           compat20 ? PROTOCOL_MINOR_2 : PROTOCOL_MINOR_1,
+           compat20 ? PROTOCOL_MINOR_2 : minor1,
            SSH_VERSION);
        if (atomicio(write, connection_out, buf, strlen(buf)) != strlen(buf))
                fatal("write: %.100s", strerror(errno));
@@ -403,17 +489,21 @@ ssh_exchange_identification()
        debug("Local version string %.100s", client_version_string);
 }
 
-int
+/* defaults to 'no' */
+static int
 read_yes_or_no(const char *prompt, int defval)
 {
        char buf[1024];
        FILE *f;
        int retval = -1;
 
-       if (isatty(0))
+       if (options.batch_mode)
+               return 0;
+
+       if (isatty(STDIN_FILENO))
                f = stdin;
        else
-               f = fopen("/dev/tty", "rw");
+               f = fopen(_PATH_TTY, "rw");
 
        if (f == NULL)
                return 0;
@@ -423,7 +513,10 @@ read_yes_or_no(const char *prompt, int defval)
        while (1) {
                fprintf(stderr, "%s", prompt);
                if (fgets(buf, sizeof(buf), f) == NULL) {
-                       /* Print a newline (the prompt probably didn\'t have one). */
+                       /*
+                        * Print a newline (the prompt probably didn\'t have
+                        * one).
+                        */
                        fprintf(stderr, "\n");
                        strlcpy(buf, "no", sizeof buf);
                }
@@ -435,8 +528,10 @@ read_yes_or_no(const char *prompt, int defval)
                        retval = defval;
                if (strcmp(buf, "yes") == 0)
                        retval = 1;
-               if (strcmp(buf, "no") == 0)
+               else if (strcmp(buf, "no") == 0)
                        retval = 0;
+               else
+                       fprintf(stderr, "Please type 'yes' or 'no'.\n");
 
                if (retval != -1) {
                        if (f != stdin)
@@ -447,22 +542,25 @@ read_yes_or_no(const char *prompt, int defval)
 }
 
 /*
- * check whether the supplied host key is valid, return only if ok.
+ * check whether the supplied host key is valid, return -1 if the key
+ * is not valid. the user_hostfile will not be updated if 'readonly' is true.
  */
 
-void
+static int
 check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
-       const char *user_hostfile, const char *system_hostfile)
+    int readonly, const char *user_hostfile, const char *system_hostfile)
 {
        Key *file_key;
        char *type = key_type(host_key);
        char *ip = NULL;
-       char hostline[1000], *hostp;
+       char hostline[1000], *hostp, *fp;
        HostStatus host_status;
        HostStatus ip_status;
        int local = 0, host_ip_differ = 0;
        int salen;
        char ntop[NI_MAXHOST];
+       int host_line, ip_line;
+       const char *host_file = NULL, *ip_file = NULL;
 
        /*
         * Force accepting of the host key for loopback/localhost. The
@@ -475,11 +573,13 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
        /**  hostaddr == 0! */
        switch (hostaddr->sa_family) {
        case AF_INET:
-               local = (ntohl(((struct sockaddr_in *)hostaddr)->sin_addr.s_addr) >> 24) == IN_LOOPBACKNET;
+               local = (ntohl(((struct sockaddr_in *)hostaddr)->
+                   sin_addr.s_addr) >> 24) == IN_LOOPBACKNET;
                salen = sizeof(struct sockaddr_in);
                break;
        case AF_INET6:
-               local = IN6_IS_ADDR_LOOPBACK(&(((struct sockaddr_in6 *)hostaddr)->sin6_addr));
+               local = IN6_IS_ADDR_LOOPBACK(
+                   &(((struct sockaddr_in6 *)hostaddr)->sin6_addr));
                salen = sizeof(struct sockaddr_in6);
                break;
        default:
@@ -487,23 +587,41 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
                salen = sizeof(struct sockaddr_storage);
                break;
        }
-       if (local) {
-               debug("Forcing accepting of host key for loopback/localhost.");
-               return;
+       if (options.no_host_authentication_for_localhost == 1 && local &&
+           options.host_key_alias == NULL) {
+               debug("Forcing accepting of host key for "
+                   "loopback/localhost.");
+               return 0;
        }
 
        /*
-        * Turn off check_host_ip for proxy connects, since
-        * we don't have the remote ip-address
+        * We don't have the remote ip-address for connections
+        * using a proxy command
         */
-       if (options.proxy_command != NULL && options.check_host_ip)
-               options.check_host_ip = 0;
-
-       if (options.check_host_ip) {
+       if (options.proxy_command == NULL) {
                if (getnameinfo(hostaddr, salen, ntop, sizeof(ntop),
                    NULL, 0, NI_NUMERICHOST) != 0)
                        fatal("check_host_key: getnameinfo failed");
                ip = xstrdup(ntop);
+       } else {
+               ip = xstrdup("<no hostip for proxy command>");
+       }
+       /*
+        * Turn off check_host_ip if the connection is to localhost, via proxy
+        * command or if we don't have a hostname to compare with
+        */
+       if (options.check_host_ip &&
+           (local || strcmp(host, ip) == 0 || options.proxy_command != NULL))
+               options.check_host_ip = 0;
+
+       /*
+        * Allow the user to record the key under a different name. This is
+        * useful for ssh tunneling over forwarded connections or if you run
+        * multiple sshd's on different ports on the same machine.
+        */
+       if (options.host_key_alias != NULL) {
+               host = options.host_key_alias;
+               debug("using hostkeyalias: %s", host);
        }
 
        /*
@@ -516,19 +634,29 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
         * Check if the host key is present in the user\'s list of known
         * hosts or in the systemwide list.
         */
-       host_status = check_host_in_hostfile(user_hostfile, host, host_key, file_key);
-       if (host_status == HOST_NEW)
-               host_status = check_host_in_hostfile(system_hostfile, host, host_key, file_key);
+       host_file = user_hostfile;
+       host_status = check_host_in_hostfile(host_file, host, host_key,
+            file_key, &host_line);
+       if (host_status == HOST_NEW) {
+               host_file = system_hostfile;
+               host_status = check_host_in_hostfile(host_file, host, host_key,
+                   file_key, &host_line);
+       }
        /*
         * Also perform check for the ip address, skip the check if we are
         * localhost or the hostname was an ip address to begin with
         */
-       if (options.check_host_ip && !local && strcmp(host, ip)) {
+       if (options.check_host_ip) {
                Key *ip_key = key_new(host_key->type);
-               ip_status = check_host_in_hostfile(user_hostfile, ip, host_key, ip_key);
 
-               if (ip_status == HOST_NEW)
-                       ip_status = check_host_in_hostfile(system_hostfile, ip, host_key, ip_key);
+               ip_file = user_hostfile;
+               ip_status = check_host_in_hostfile(ip_file, ip, host_key,
+                   ip_key, &ip_line);
+               if (ip_status == HOST_NEW) {
+                       ip_file = system_hostfile;
+                       ip_status = check_host_in_hostfile(ip_file, ip,
+                           host_key, ip_key, &ip_line);
+               }
                if (host_status == HOST_CHANGED &&
                    (ip_status != HOST_CHANGED || !key_equal(ip_key, file_key)))
                        host_ip_differ = 1;
@@ -544,50 +672,68 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
                /* The host is known and the key matches. */
                debug("Host '%.200s' is known and matches the %s host key.",
                    host, type);
-               if (options.check_host_ip) {
-                       if (ip_status == HOST_NEW) {
-                               if (!add_host_to_hostfile(user_hostfile, ip, host_key))
-                                       log("Failed to add the %s host key for IP address '%.30s' to the list of known hosts (%.30s).",
-                                           type, ip, user_hostfile);
-                               else
-                                       log("Warning: Permanently added the %s host key for IP address '%.30s' to the list of known hosts.",
-                                           type, ip);
-                       } else if (ip_status != HOST_OK)
-                               log("Warning: the %s host key for '%.200s' differs from the key for the IP address '%.30s'",
-                                   type, host, ip);
+               debug("Found key in %s:%d", host_file, host_line);
+               if (options.check_host_ip && ip_status == HOST_NEW) {
+                       if (readonly)
+                               log("%s host key for IP address "
+                                   "'%.128s' not in list of known hosts.",
+                                   type, ip);
+                       else if (!add_host_to_hostfile(user_hostfile, ip,
+                            host_key))
+                               log("Failed to add the %s host key for IP "
+                                   "address '%.128s' to the list of known "
+                                   "hosts (%.30s).", type, ip, user_hostfile);
+                       else
+                               log("Warning: Permanently added the %s host "
+                                   "key for IP address '%.128s' to the list "
+                                   "of known hosts.", type, ip);
                }
                break;
        case HOST_NEW:
+               if (readonly)
+                       goto fail;
                /* The host is new. */
                if (options.strict_host_key_checking == 1) {
-                       /* User has requested strict host key checking.  We will not add the host key
-                          automatically.  The only alternative left is to abort. */
-                       fatal("No %s host key is known for %.200s and you have requested strict checking.", type, host);
+                       /*
+                        * User has requested strict host key checking.  We
+                        * will not add the host key automatically.  The only
+                        * alternative left is to abort.
+                        */
+                       error("No %s host key is known for %.200s and you "
+                           "have requested strict checking.", type, host);
+                       goto fail;
                } else if (options.strict_host_key_checking == 2) {
                        /* The default */
                        char prompt[1024];
-                       char *fp = key_fingerprint(host_key);
+                       fp = key_fingerprint(host_key, SSH_FP_MD5, SSH_FP_HEX);
                        snprintf(prompt, sizeof(prompt),
-                           "The authenticity of host '%.200s' can't be established.\n"
+                           "The authenticity of host '%.200s (%s)' can't be "
+                           "established.\n"
                            "%s key fingerprint is %s.\n"
-                           "Are you sure you want to continue connecting (yes/no)? ",
-                           host, type, fp);
-                       if (!read_yes_or_no(prompt, -1))
-                               fatal("Aborted by user!\n");
+                           "Are you sure you want to continue connecting "
+                           "(yes/no)? ", host, ip, type, fp);
+                       xfree(fp);
+                       if (!read_yes_or_no(prompt, -1)) {
+                               log("Aborted by user!");
+                               goto fail;
+                       }
                }
-               if (options.check_host_ip && ip_status == HOST_NEW && strcmp(host, ip)) {
+               if (options.check_host_ip && ip_status == HOST_NEW) {
                        snprintf(hostline, sizeof(hostline), "%s,%s", host, ip);
                        hostp = hostline;
                } else
                        hostp = host;
 
-               /* If not in strict mode, add the key automatically to the local known_hosts file. */
+               /*
+                * If not in strict mode, add the key automatically to the
+                * local known_hosts file.
+                */
                if (!add_host_to_hostfile(user_hostfile, hostp, host_key))
-                       log("Failed to add the host to the list of known hosts (%.500s).",
-                           user_hostfile);
+                       log("Failed to add the host to the list of known "
+                           "hosts (%.500s).", user_hostfile);
                else
-                       log("Warning: Permanently added '%.200s' (%s) to the list of known hosts.",
-                           hostp, type);
+                       log("Warning: Permanently added '%.200s' (%s) to the "
+                           "list of known hosts.", hostp, type);
                break;
        case HOST_CHANGED:
                if (options.check_host_ip && host_ip_differ) {
@@ -605,25 +751,35 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
                        error("and the key for the according IP address %s", ip);
                        error("%s. This could either mean that", msg);
                        error("DNS SPOOFING is happening or the IP address for the host");
-                       error("and its host key have changed at the same time");
+                       error("and its host key have changed at the same time.");
+                       if (ip_status != HOST_NEW)
+                               error("Offending key for IP in %s:%d", ip_file, ip_line);
                }
                /* The host key has changed. */
+               fp = key_fingerprint(host_key, SSH_FP_MD5, SSH_FP_HEX);
                error("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
                error("@    WARNING: REMOTE HOST IDENTIFICATION HAS CHANGED!     @");
                error("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@");
                error("IT IS POSSIBLE THAT SOMEONE IS DOING SOMETHING NASTY!");
                error("Someone could be eavesdropping on you right now (man-in-the-middle attack)!");
                error("It is also possible that the %s host key has just been changed.", type);
+               error("The fingerprint for the %s key sent by the remote host is\n%s.",
+                   type, fp);
                error("Please contact your system administrator.");
                error("Add correct host key in %.100s to get rid of this message.",
-                     user_hostfile);
+                   user_hostfile);
+               error("Offending key in %s:%d", host_file, host_line);
+               xfree(fp);
 
                /*
                 * If strict host key checking is in use, the user will have
                 * to edit the key manually and we can only abort.
                 */
-               if (options.strict_host_key_checking)
-                       fatal("%s host key for %.200s has changed and you have requested strict checking.", type, host);
+               if (options.strict_host_key_checking) {
+                       error("%s host key for %.200s has changed and you have "
+                           "requested strict checking.", type, host);
+                       goto fail;
+               }
 
                /*
                 * If strict host key checking has not been requested, allow
@@ -631,13 +787,27 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
                 * agent forwarding.
                 */
                if (options.password_authentication) {
-                       error("Password authentication is disabled to avoid trojan horses.");
+                       error("Password authentication is disabled to avoid "
+                           "man-in-the-middle attacks.");
                        options.password_authentication = 0;
                }
                if (options.forward_agent) {
-                       error("Agent forwarding is disabled to avoid trojan horses.");
+                       error("Agent forwarding is disabled to avoid "
+                           "man-in-the-middle attacks.");
                        options.forward_agent = 0;
                }
+               if (options.forward_x11) {
+                       error("X11 forwarding is disabled to avoid "
+                           "man-in-the-middle attacks.");
+                       options.forward_x11 = 0;
+               }
+               if (options.num_local_forwards > 0 ||
+                   options.num_remote_forwards > 0) {
+                       error("Port forwarding is disabled to avoid "
+                           "man-in-the-middle attacks.");
+                       options.num_local_forwards =
+                            options.num_remote_forwards = 0;
+               }
                /*
                 * XXX Should permit the user to change to use the new id.
                 * This could be done by converting the host key to an
@@ -647,8 +817,49 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
                 */
                break;
        }
-       if (options.check_host_ip)
-               xfree(ip);
+
+       if (options.check_host_ip && host_status != HOST_CHANGED &&
+           ip_status == HOST_CHANGED) {
+               log("Warning: the %s host key for '%.200s' "
+                   "differs from the key for the IP address '%.128s'",
+                   type, host, ip);
+               if (host_status == HOST_OK)
+                       log("Matching host key in %s:%d", host_file, host_line);
+               log("Offending key for IP in %s:%d", ip_file, ip_line);
+               if (options.strict_host_key_checking == 1) {
+                       error("Exiting, you have requested strict checking.");
+                       goto fail;
+               } else if (options.strict_host_key_checking == 2) {
+                       if (!read_yes_or_no("Are you sure you want " 
+                           "to continue connecting (yes/no)? ", -1)) {
+                               log("Aborted by user!");
+                               goto fail;
+                       }
+               }
+       }
+
+       xfree(ip);
+       return 0;
+
+fail:
+       xfree(ip);
+       return -1;
+}
+
+int
+verify_host_key(char *host, struct sockaddr *hostaddr, Key *host_key)
+{
+       struct stat st;
+
+       /* return ok if the key can be found in an old keyfile */
+       if (stat(options.system_hostfile2, &st) == 0 ||
+           stat(options.user_hostfile2, &st) == 0) {
+               if (check_host_key(host, hostaddr, host_key, /*readonly*/ 1,
+                   options.user_hostfile2, options.system_hostfile2) == 0)
+                       return 0;
+       }
+       return check_host_key(host, hostaddr, host_key, /*readonly*/ 0,
+           options.user_hostfile, options.system_hostfile);
 }
 
 /*
@@ -659,17 +870,12 @@ check_host_key(char *host, struct sockaddr *hostaddr, Key *host_key,
  * This function does not require super-user privileges.
  */
 void
-ssh_login(int host_key_valid, RSA *own_host_key, const char *orighost,
-    struct sockaddr *hostaddr, uid_t original_real_uid)
+ssh_login(Key **keys, int nkeys, const char *orighost,
+    struct sockaddr *hostaddr, struct passwd *pw)
 {
-       struct passwd *pw;
        char *host, *cp;
        char *server_user, *local_user;
 
-       /* Get local user name.  Use it as server user if no user name was given. */
-       pw = getpwuid(original_real_uid);
-       if (!pw)
-               fatal("User id %u not found from user database.", original_real_uid);
        local_user = xstrdup(pw->pw_name);
        server_user = options.user ? options.user : local_user;
 
@@ -689,9 +895,28 @@ ssh_login(int host_key_valid, RSA *own_host_key, const char *orighost,
        /* authenticate user */
        if (compat20) {
                ssh_kex2(host, hostaddr);
-               ssh_userauth2(server_user, host);
+               ssh_userauth2(local_user, server_user, host, keys, nkeys);
        } else {
                ssh_kex(host, hostaddr);
-               ssh_userauth(local_user, server_user, host, host_key_valid, own_host_key);
+               ssh_userauth1(local_user, server_user, host, keys, nkeys);
+       }
+}
+
+void
+ssh_put_password(char *password)
+{
+       int size;
+       char *padded;
+
+       if (datafellows & SSH_BUG_PASSWORDPAD) {
+               packet_put_cstring(password);
+               return;
        }
+       size = roundup(strlen(password) + 1, 32);
+       padded = xmalloc(size);
+       memset(padded, 0, size);
+       strlcpy(padded, password, size);
+       packet_put_string(padded, size);
+       memset(padded, 0, size);
+       xfree(padded);
 }
This page took 0.37612 seconds and 4 git commands to generate.