]> andersk Git - openssh.git/blobdiff - session.c
- (bal) UseLogin patch for Solaris/UNICOS. Patch by Wayne Davison
[openssh.git] / session.c
index d4053b4c947c88014da02406f7d5861da42fc2d7..62026c670e12b62bd68f92dd10771de48f3b70f6 100644 (file)
--- a/session.c
+++ b/session.c
@@ -9,7 +9,7 @@
  * called by a name other than "ssh" or "Secure Shell".
  *
  * SSH2 support by Markus Friedl.
- * Copyright (c) 2000 Markus Friedl. All rights reserved.
+ * Copyright (c) 2000 Markus Friedl.  All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
@@ -33,7 +33,7 @@
  */
 
 #include "includes.h"
-RCSID("$OpenBSD: session.c,v 1.57 2001/02/23 15:37:45 markus Exp $");
+RCSID("$OpenBSD: session.c,v 1.75 2001/05/03 15:45:15 markus Exp $");
 
 #include "ssh.h"
 #include "ssh1.h"
@@ -89,6 +89,10 @@ RCSID("$OpenBSD: session.c,v 1.57 2001/02/23 15:37:45 markus Exp $");
 # define S_UNOFILE_HARD        S_UNOFILE "_hard"
 #endif
 
+#ifdef _AIX
+# include <uinfo.h>
+#endif
+
 /* types */
 
 #define TTYSZ 64
@@ -96,7 +100,6 @@ typedef struct Session Session;
 struct Session {
        int     used;
        int     self;
-       int     extended;
        struct  passwd *pw;
        pid_t   pid;
        /* tty */
@@ -112,6 +115,7 @@ struct Session {
        int     single_connection;
        /* proto 2 */
        int     chanid;
+       int     is_subsystem;
 };
 
 /* func */
@@ -120,14 +124,18 @@ Session *session_new(void);
 void   session_set_fds(Session *s, int fdin, int fdout, int fderr);
 void   session_pty_cleanup(Session *s);
 void   session_proctitle(Session *s);
-void   do_exec_pty(Session *s, const char *command, struct passwd * pw);
-void   do_exec_no_pty(Session *s, const char *command, struct passwd * pw);
+void   do_exec_pty(Session *s, const char *command);
+void   do_exec_no_pty(Session *s, const char *command);
 void   do_login(Session *s, const char *command);
+#ifdef LOGIN_NEEDS_UTMPX
+void   do_pre_login(Session *s);
+#endif
+void   do_child(Session *s, const char *command);
+void   do_motd(void);
+int    check_quietlogin(Session *s, const char *command);
 
-void
-do_child(const char *command, struct passwd * pw, const char *term,
-    const char *display, const char *auth_proto,
-    const char *auth_data, const char *ttyname);
+void   do_authenticated1(Authctxt *authctxt);
+void   do_authenticated2(Authctxt *authctxt);
 
 /* import */
 extern ServerOptions options;
@@ -135,8 +143,8 @@ extern char *__progname;
 extern int log_stderr;
 extern int debug_flag;
 extern u_int utmp_len;
-
 extern int startup_pipe;
+extern void destroy_sensitive_data(void);
 
 /* Local Xauthority file. */
 static char *xauthfile;
@@ -157,6 +165,40 @@ char *aixloginmsg;
 static login_cap_t *lc;
 #endif
 
+void
+do_authenticated(Authctxt *authctxt)
+{
+       /*
+        * Cancel the alarm we set to limit the time taken for
+        * authentication.
+        */
+       alarm(0);
+       if (startup_pipe != -1) {
+               close(startup_pipe);
+               startup_pipe = -1;
+       }
+#if defined(HAVE_LOGIN_CAP) && defined(HAVE_PW_CLASS_IN_PASSWD)
+       if ((lc = login_getclass(authctxt->pw->pw_class)) == NULL) {
+               error("unable to get login class");
+               return;
+       }
+#ifdef BSD_AUTH
+       if (auth_approval(NULL, lc, authctxt->pw->pw_name, "ssh") <= 0) {
+               packet_disconnect("Approval failure for %s",
+                   authctxt->pw->pw_name);
+       }
+#endif
+#endif
+       /* setup the channel layer */
+       if (!no_port_forwarding_flag && options.allow_tcp_forwarding)
+               channel_permit_all_opens();
+
+       if (compat20)
+               do_authenticated2(authctxt);
+       else
+               do_authenticated1(authctxt);
+}
+
 /*
  * Remove local Xauthority file.
  */
@@ -206,54 +248,23 @@ pty_cleanup_proc(void *session)
  * are requested, etc.
  */
 void
-do_authenticated(struct passwd * pw)
+do_authenticated1(Authctxt *authctxt)
 {
        Session *s;
-       int type, fd;
-       int compression_level = 0, enable_compression_after_reply = 0;
-       int have_pty = 0;
        char *command;
-       int n_bytes;
-       int plen;
+       int success, type, fd, n_bytes, plen, screen_flag, have_pty = 0;
+       int compression_level = 0, enable_compression_after_reply = 0;
        u_int proto_len, data_len, dlen;
-       int screen_flag;
-
-       /*
-        * Cancel the alarm we set to limit the time taken for
-        * authentication.
-        */
-       alarm(0);
-       if (startup_pipe != -1) {
-               close(startup_pipe);
-               startup_pipe = -1;
-       }
-
-       /*
-        * Inform the channel mechanism that we are the server side and that
-        * the client may request to connect to any port at all. (The user
-        * could do it anyway, and we wouldn\'t know what is permitted except
-        * by the client telling us, so we can equally well trust the client
-        * not to request anything bogus.)
-        */
-       if (!no_port_forwarding_flag && options.allow_tcp_forwarding)
-               channel_permit_all_opens();
 
        s = session_new();
-       s->pw = pw;
-
-#if defined(HAVE_LOGIN_CAP) && defined(HAVE_PW_CLASS_IN_PASSWD)
-       if ((lc = login_getclass(pw->pw_class)) == NULL) {
-               error("unable to get login class");
-               return;
-       }
-#endif
+       s->pw = authctxt->pw;
 
        /*
         * We stay in this loop until the client requests to execute a shell
         * or a command.
         */
        for (;;) {
-               int success = 0;
+               success = 0;
 
                /* Get a packet from the client. */
                type = packet_read(&plen);
@@ -290,7 +301,7 @@ do_authenticated(struct passwd * pw)
                                break;
                        }
                        fatal_add_cleanup(pty_cleanup_proc, (void *)s);
-                       pty_setowner(pw, s->tty);
+                       pty_setowner(s->pw, s->tty);
 
                        /* Get TERM from the packet.  Note that the value may be of arbitrary length. */
                        s->term = packet_get_string(&dlen);
@@ -365,7 +376,7 @@ do_authenticated(struct passwd * pw)
                        /* Setup to always have a local .Xauthority. */
                        xauthfile = xmalloc(MAXPATHLEN);
                        strlcpy(xauthfile, "/tmp/ssh-XXXXXXXX", MAXPATHLEN);
-                       temporarily_use_uid(pw->pw_uid);
+                       temporarily_use_uid(s->pw);
                        if (mkdtemp(xauthfile) == NULL) {
                                restore_uid();
                                error("private X11 dir: mkdtemp %s failed: %s",
@@ -390,7 +401,7 @@ do_authenticated(struct passwd * pw)
                                break;
                        }
                        debug("Received authentication agent forwarding request.");
-                       success = auth_input_request_forwarding(pw);
+                       success = auth_input_request_forwarding(s->pw);
                        break;
 
                case SSH_CMSG_PORT_FORWARD_REQUEST:
@@ -403,7 +414,7 @@ do_authenticated(struct passwd * pw)
                                break;
                        }
                        debug("Received TCP/IP port forwarding request.");
-                       channel_input_port_forward_request(pw->pw_uid == 0, options.gateway_ports);
+                       channel_input_port_forward_request(s->pw->pw_uid == 0, options.gateway_ports);
                        success = 1;
                        break;
 
@@ -428,9 +439,9 @@ do_authenticated(struct passwd * pw)
                                debug("Forced command '%.500s'", forced_command);
                        }
                        if (have_pty)
-                               do_exec_pty(s, command, pw);
+                               do_exec_pty(s, command);
                        else
-                               do_exec_no_pty(s, command, pw);
+                               do_exec_no_pty(s, command);
 
                        if (command != NULL)
                                xfree(command);
@@ -464,7 +475,7 @@ do_authenticated(struct passwd * pw)
  * setting up file descriptors and such.
  */
 void
-do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
+do_exec_no_pty(Session *s, const char *command)
 {
        int pid;
 
@@ -487,9 +498,8 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
 
        session_proctitle(s);
 
-#if defined(USE_PAM) && defined(PAM_SUN_CODEBASE)
-       /* Solaris-derived PAMs don't like doing this after the fork() */
-       do_pam_setcred();
+#if defined(USE_PAM)
+       do_pam_setcred(1);
 #endif /* USE_PAM */
 
        /* Fork the child. */
@@ -497,8 +507,6 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
                /* Child.  Reinitialize the log since the pid has changed. */
                log_init(__progname, options.log_level, options.log_facility, log_stderr);
 
-               signal(SIGPIPE, SIG_DFL);
-
                /*
                 * Create a new session and process group since the 4.4BSD
                 * setlogin() affects the entire process group.
@@ -544,7 +552,7 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
 #endif /* USE_PIPES */
 
                /* Do processing for the child (exec command etc). */
-               do_child(command, pw, NULL, s->display, s->auth_proto, s->auth_data, NULL);
+               do_child(s, command);
                /* NOTREACHED */
        }
 #ifdef HAVE_CYGWIN
@@ -563,11 +571,11 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
        close(perr[1]);
 
        if (compat20) {
-               session_set_fds(s, pin[1], pout[0], s->extended ? perr[0] : -1);
+               session_set_fds(s, pin[1], pout[0], s->is_subsystem ? -1 : perr[0]);
        } else {
                /* Enter the interactive session. */
                server_loop(pid, pin[1], pout[0], perr[0]);
-               /* server_loop has closed pin[1], pout[1], and perr[1]. */
+               /* server_loop has closed pin[1], pout[0], and perr[0]. */
        }
 #else /* USE_PIPES */
        /* We are the parent.  Close the child sides of the socket pairs. */
@@ -579,7 +587,7 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
         * handle the case that fdin and fdout are the same.
         */
        if (compat20) {
-               session_set_fds(s, inout[1], inout[1], s->extended ? err[1] : -1);
+               session_set_fds(s, inout[1], inout[1], s->is_subsystem ? -1 : err[1]);
        } else {
                server_loop(pid, inout[1], inout[1], err[1]);
                /* server_loop has closed inout[1] and err[1]. */
@@ -594,7 +602,7 @@ do_exec_no_pty(Session *s, const char *command, struct passwd * pw)
  * lastlog, and other such operations.
  */
 void
-do_exec_pty(Session *s, const char *command, struct passwd * pw)
+do_exec_pty(Session *s, const char *command)
 {
        int fdout, ptyfd, ttyfd, ptymaster;
        pid_t pid;
@@ -604,10 +612,9 @@ do_exec_pty(Session *s, const char *command, struct passwd * pw)
        ptyfd = s->ptyfd;
        ttyfd = s->ttyfd;
 
-#if defined(USE_PAM) && defined(PAM_SUN_CODEBASE)
-       /* Solaris-derived PAMs don't like doing this after the fork() */
-       do_pam_session(pw->pw_name, s->tty);
-       do_pam_setcred();
+#if defined(USE_PAM)
+       do_pam_session(s->pw->pw_name, s->tty);
+       do_pam_setcred(1);
 #endif
 
        /* Fork the child. */
@@ -615,8 +622,6 @@ do_exec_pty(Session *s, const char *command, struct passwd * pw)
                /* Child.  Reinitialize the log because the pid has changed. */
                log_init(__progname, options.log_level, options.log_facility, log_stderr);
 
-               signal(SIGPIPE, SIG_DFL);
-
                /* Close the master side of the pseudo tty. */
                close(ptyfd);
 
@@ -639,12 +644,17 @@ do_exec_pty(Session *s, const char *command, struct passwd * pw)
                close(ttyfd);
 
                /* record login, etc. similar to login(1) */
+#ifndef HAVE_OSF_SIA
                if (!(options.use_login && command == NULL))
                        do_login(s, command);
+# ifdef LOGIN_NEEDS_UTMPX
+               else
+                       do_pre_login(s);
+# endif
+#endif
 
                /* Do common processing for the child, such as execing the command. */
-               do_child(command, pw, s->term, s->display, s->auth_proto,
-                   s->auth_data, s->tty);
+               do_child(s, command);
                /* NOTREACHED */
        }
 #ifdef HAVE_CYGWIN
@@ -684,28 +694,42 @@ do_exec_pty(Session *s, const char *command, struct passwd * pw)
        }
 }
 
-const char *
-get_remote_name_or_ip(void)
+#ifdef LOGIN_NEEDS_UTMPX
+void
+do_pre_login(Session *s)
 {
-       static const char *remote = "";
-       if (utmp_len > 0)
-               remote = get_canonical_hostname(options.reverse_mapping_check);
-       if (utmp_len == 0 || strlen(remote) > utmp_len)
-               remote = get_remote_ipaddr();
-       return remote;
+       socklen_t fromlen;
+       struct sockaddr_storage from;
+       pid_t pid = getpid();
+
+       /*
+        * Get IP address of client. If the connection is not a socket, let
+        * the address be 0.0.0.0.
+        */
+       memset(&from, 0, sizeof(from));
+       if (packet_connection_is_on_socket()) {
+               fromlen = sizeof(from);
+               if (getpeername(packet_get_connection_in(),
+                    (struct sockaddr *) & from, &fromlen) < 0) {
+                       debug("getpeername: %.100s", strerror(errno));
+                       fatal_cleanup();
+               }
+       }
+
+       record_utmp_only(pid, s->tty, s->pw->pw_name,
+           get_remote_name_or_ip(utmp_len, options.reverse_mapping_check),
+           (struct sockaddr *)&from);
 }
+#endif
 
 /* administrative, login(1)-like work */
 void
 do_login(Session *s, const char *command)
 {
-       FILE *f;
        char *time_string;
-       char buf[256];
        char hostname[MAXHOSTNAMELEN];
        socklen_t fromlen;
        struct sockaddr_storage from;
-       struct stat st;
        time_t last_login_time;
        struct passwd * pw = s->pw;
        pid_t pid = getpid();
@@ -725,13 +749,16 @@ do_login(Session *s, const char *command)
        }
 
        /* Get the time and hostname when the user last logged in. */
-       hostname[0] = '\0';
-       last_login_time = get_last_login_time(pw->pw_uid, pw->pw_name,
-           hostname, sizeof(hostname));
+       if (options.print_lastlog) {
+               hostname[0] = '\0';
+               last_login_time = get_last_login_time(pw->pw_uid, pw->pw_name,
+                   hostname, sizeof(hostname));
+       }
 
        /* Record that there was a login on that tty from the remote host. */
        record_login(pid, s->tty, pw->pw_name, pw->pw_uid,
-           get_remote_name_or_ip(), (struct sockaddr *)&from);
+           get_remote_name_or_ip(utmp_len, options.reverse_mapping_check),
+           (struct sockaddr *)&from);
 
 #ifdef USE_PAM
        /*
@@ -744,15 +771,7 @@ do_login(Session *s, const char *command)
        }
 #endif
 
-       /* Done if .hushlogin exists or a command given. */
-       if (command != NULL)
-               return;
-       snprintf(buf, sizeof(buf), "%.200s/.hushlogin", pw->pw_dir);
-#ifdef HAVE_LOGIN_CAP
-       if (login_getcapbool(lc, "hushlogin", 0) || stat(buf, &st) >= 0)
-#else
-       if (stat(buf, &st) >= 0)
-#endif
+       if (check_quietlogin(s, command))
                return;
 
 #ifdef USE_PAM
@@ -764,7 +783,7 @@ do_login(Session *s, const char *command)
                printf("%s\n", aixloginmsg);
 #endif /* WITH_AIXAUTHENTICATE */
 
-       if (last_login_time != 0) {
+       if (options.print_lastlog && last_login_time != 0) {
                time_string = ctime(&last_login_time);
                if (strchr(time_string, '\n'))
                        *strchr(time_string, '\n') = 0;
@@ -773,6 +792,19 @@ do_login(Session *s, const char *command)
                else
                        printf("Last login: %s from %s\r\n", time_string, hostname);
        }
+
+       do_motd();
+}
+
+/*
+ * Display the message of the day.
+ */
+void
+do_motd(void)
+{
+       FILE *f;
+       char buf[256];
+
        if (options.print_motd) {
 #ifdef HAVE_LOGIN_CAP
                f = fopen(login_getcapstr(lc, "welcome", "/etc/motd",
@@ -788,6 +820,31 @@ do_login(Session *s, const char *command)
        }
 }
 
+
+/*
+ * Check for quiet login, either .hushlogin or command given.
+ */
+int
+check_quietlogin(Session *s, const char *command)
+{
+       char buf[256];
+       struct passwd * pw = s->pw;
+       struct stat st;
+
+       /* Return 1 if .hushlogin exists or a command given. */
+       if (command != NULL)
+               return 1;
+       snprintf(buf, sizeof(buf), "%.200s/.hushlogin", pw->pw_dir);
+#ifdef HAVE_LOGIN_CAP
+       if (login_getcapbool(lc, "hushlogin", 0) || stat(buf, &st) >= 0)
+               return 1;
+#else
+       if (stat(buf, &st) >= 0)
+               return 1;
+#endif
+       return 0;
+}
+
 /*
  * Sets the value of the given variable in the environment.  If the variable
  * already exists, its value is overriden.
@@ -1010,11 +1067,10 @@ void set_limits_from_userattr(char *user)
  * ids, and executing the command or shell.
  */
 void
-do_child(const char *command, struct passwd * pw, const char *term,
-        const char *display, const char *auth_proto,
-        const char *auth_data, const char *ttyname)
+do_child(Session *s, const char *command)
 {
        const char *shell, *hostname = NULL, *cp = NULL;
+       struct passwd * pw = s->pw;
        char buf[256];
        char cmd[1024];
        FILE *f = NULL;
@@ -1023,6 +1079,7 @@ do_child(const char *command, struct passwd * pw, const char *term,
        extern char **environ;
        struct stat st;
        char *argv[10];
+       int do_xauth = s->auth_proto != NULL && s->auth_data != NULL;
 #ifdef WITH_IRIX_PROJECT
        prid_t projid;
 #endif /* WITH_IRIX_PROJECT */
@@ -1034,17 +1091,14 @@ do_child(const char *command, struct passwd * pw, const char *term,
 #endif /* WITH_IRIX_ARRAY */
 #endif /* WITH_IRIX_JOBS */
 
-#if defined(USE_PAM) && !defined(PAM_SUN_CODEBASE)
-       /* Solaris-derived PAMs don't like doing this after the fork() */
-       do_pam_session(pw->pw_name, s->tty);
-       do_pam_setcred();
-#endif
+       /* remove hostkey from the child's memory */
+       destroy_sensitive_data();
 
        /* login(1) is only called if we execute the login shell */
        if (options.use_login && command != NULL)
                options.use_login = 0;
 
-#ifndef USE_PAM /* pam_nologin handles this */
+#if !defined(USE_PAM) && !defined(HAVE_OSF_SIA)
        if (!options.use_login) {
 # ifdef HAVE_LOGIN_CAP
                if (!login_getcapbool(lc, "ignorenologin", 0) && pw->pw_uid)
@@ -1062,14 +1116,16 @@ do_child(const char *command, struct passwd * pw, const char *term,
                        exit(254);
                }
        }
-#endif /* USE_PAM */
+#endif /* USE_PAM || HAVE_OSF_SIA */
 
        /* Set login name, uid, gid, and groups. */
        /* Login(1) does this as well, and it needs uid 0 for the "-h"
           switch, so we let login(1) to this for us. */
        if (!options.use_login) {
 #ifdef HAVE_OSF_SIA
-               session_setup_sia(pw->pw_name, ttyname);
+               session_setup_sia(pw->pw_name, s->ttyfd == -1 ? NULL : s->tty);
+               if (!check_quietlogin(s, command))
+                       do_motd();
 #else /* HAVE_OSF_SIA */
 #ifdef HAVE_CYGWIN
                if (is_winnt) {
@@ -1085,13 +1141,6 @@ do_child(const char *command, struct passwd * pw, const char *term,
                                perror("unable to set user context");
                                exit(1);
                        }
-#ifdef BSD_AUTH
-                       if (auth_approval(NULL, lc, pw->pw_name, "ssh") <= 0) {
-                               error("approval failure for %s", pw->pw_name);
-                               fprintf(stderr, "Approval failure");
-                               exit(1);
-                       }
-#endif
 # else /* HAVE_LOGIN_CAP */
 #if defined(HAVE_GETLUID) && defined(HAVE_SETLUID)
                        /* Sets login uid for accounting */
@@ -1111,6 +1160,15 @@ do_child(const char *command, struct passwd * pw, const char *term,
                                exit(1);
                        }
                        endgrent();
+#  ifdef USE_PAM
+                       /*
+                        * PAM credentials may take the form of 
+                        * supplementary groups. These will have been 
+                        * wiped by the above initgroups() call.
+                        * Reestablish them here.
+                        */
+                       do_pam_setcred(0);
+#  endif /* USE_PAM */
 #  ifdef WITH_IRIX_JOBS
                        jid = jlimit_startjob(pw->pw_name, pw->pw_uid, "interactive");
                        if (jid == -1) {
@@ -1144,8 +1202,27 @@ do_child(const char *command, struct passwd * pw, const char *term,
                        }
 #endif /* WITH_IRIX_AUDIT */
 
+#ifdef _AIX
+                       /*
+                        * AIX has a "usrinfo" area where logname and
+                        * other stuff is stored - a few applications
+                        * actually use this and die if it's not set
+                        */
+                       if (s->ttyfd == -1)
+                               s->tty[0] = '\0';
+                       cp = xmalloc(22 + strlen(s->tty) + 
+                           2 * strlen(pw->pw_name));
+                       i = sprintf(cp, "LOGNAME=%s%cNAME=%s%cTTY=%s%c%c",
+                           pw->pw_name, 0, pw->pw_name, 0, s->tty, 0, 0);
+                       if (usrinfo(SETUINFO, cp, i) == -1)
+                               fatal("Couldn't set usrinfo: %s", 
+                                   strerror(errno));
+                       debug3("AIX/UsrInfo: set len %d", i);
+                       xfree(cp);
+#endif
+
                        /* Permanently switch to the desired uid. */
-                       permanently_set_uid(pw->pw_uid);
+                       permanently_set_uid(pw);
 # endif /* HAVE_LOGIN_CAP */
                }
 #endif /* HAVE_OSF_SIA */
@@ -1239,12 +1316,12 @@ do_child(const char *command, struct passwd * pw, const char *term,
                 get_remote_ipaddr(), get_remote_port(), get_local_port());
        child_set_env(&env, &envsize, "SSH_CLIENT", buf);
 
-       if (ttyname)
-               child_set_env(&env, &envsize, "SSH_TTY", ttyname);
-       if (term)
-               child_set_env(&env, &envsize, "TERM", term);
-       if (display)
-               child_set_env(&env, &envsize, "DISPLAY", display);
+       if (s->ttyfd != -1)
+               child_set_env(&env, &envsize, "SSH_TTY", s->tty);
+       if (s->term)
+               child_set_env(&env, &envsize, "TERM", s->term);
+       if (s->display)
+               child_set_env(&env, &envsize, "DISPLAY", s->display);
        if (original_command)
                child_set_env(&env, &envsize, "SSH_ORIGINAL_COMMAND",
                    original_command);
@@ -1291,7 +1368,8 @@ do_child(const char *command, struct passwd * pw, const char *term,
        }
        /* we have to stash the hostname before we close our socket. */
        if (options.use_login)
-               hostname = get_remote_name_or_ip();
+               hostname = get_remote_name_or_ip(utmp_len,
+                   options.reverse_mapping_check);
        /*
         * Close the connection descriptors; note that this is the child, and
         * the server will still have the socket open, and it is important
@@ -1348,62 +1426,67 @@ do_child(const char *command, struct passwd * pw, const char *term,
         * in this order).
         */
        if (!options.use_login) {
-               if (stat(_PATH_SSH_USER_RC, &st) >= 0) {
+               /* ignore _PATH_SSH_USER_RC for subsystems */
+               if (!s->is_subsystem && (stat(_PATH_SSH_USER_RC, &st) >= 0)) {
+                       snprintf(cmd, sizeof cmd, "%s -c '%s %s'",
+                           shell, _PATH_BSHELL, _PATH_SSH_USER_RC);
                        if (debug_flag)
-                               fprintf(stderr, "Running %s %s\n", _PATH_BSHELL, _PATH_SSH_USER_RC);
-
-                       f = popen(_PATH_BSHELL " " _PATH_SSH_USER_RC, "w");
+                               fprintf(stderr, "Running %s\n", cmd);
+                       f = popen(cmd, "w");
                        if (f) {
-                               if (auth_proto != NULL && auth_data != NULL)
-                                       fprintf(f, "%s %s\n", auth_proto, auth_data);
+                               if (do_xauth)
+                                       fprintf(f, "%s %s\n", s->auth_proto,
+                                           s->auth_data);
                                pclose(f);
                        } else
-                               fprintf(stderr, "Could not run %s\n", _PATH_SSH_USER_RC);
+                               fprintf(stderr, "Could not run %s\n",
+                                   _PATH_SSH_USER_RC);
                } else if (stat(_PATH_SSH_SYSTEM_RC, &st) >= 0) {
                        if (debug_flag)
-                               fprintf(stderr, "Running %s %s\n", _PATH_BSHELL, _PATH_SSH_SYSTEM_RC);
-
+                               fprintf(stderr, "Running %s %s\n", _PATH_BSHELL,
+                                   _PATH_SSH_SYSTEM_RC);
                        f = popen(_PATH_BSHELL " " _PATH_SSH_SYSTEM_RC, "w");
                        if (f) {
-                               if (auth_proto != NULL && auth_data != NULL)
-                                       fprintf(f, "%s %s\n", auth_proto, auth_data);
+                               if (do_xauth)
+                                       fprintf(f, "%s %s\n", s->auth_proto,
+                                           s->auth_data);
                                pclose(f);
                        } else
-                               fprintf(stderr, "Could not run %s\n", _PATH_SSH_SYSTEM_RC);
-               } else if (options.xauth_location != NULL) {
+                               fprintf(stderr, "Could not run %s\n",
+                                   _PATH_SSH_SYSTEM_RC);
+               } else if (do_xauth && options.xauth_location != NULL) {
                        /* Add authority data to .Xauthority if appropriate. */
-                       if (auth_proto != NULL && auth_data != NULL) {
-                               char *screen = strchr(display, ':');
-                               if (debug_flag) {
+                       char *screen = strchr(s->display, ':');
+
+                       if (debug_flag) {
+                               fprintf(stderr,
+                                   "Running %.100s add "
+                                   "%.100s %.100s %.100s\n",
+                                   options.xauth_location, s->display,
+                                   s->auth_proto, s->auth_data);
+                               if (screen != NULL)
                                        fprintf(stderr,
-                                           "Running %.100s add %.100s %.100s %.100s\n",
-                                           options.xauth_location, display,
-                                           auth_proto, auth_data);
-#ifndef NO_X11_UNIX_SOCKETS
-                                       if (screen != NULL)
-                                               fprintf(stderr,
-                                                   "Adding %.*s/unix%s %s %s\n",
-                                                   (int)(screen-display), display,
-                                                   screen, auth_proto, auth_data);
-#endif /* NO_X11_UNIX_SOCKETS */
-                               }
-                               snprintf(cmd, sizeof cmd, "%s -q -",
-                                   options.xauth_location);
-                               f = popen(cmd, "w");
-                               if (f) {
-                                       fprintf(f, "add %s %s %s\n", display,
-                                           auth_proto, auth_data);
-#ifndef NO_X11_UNIX_SOCKETS
-                                       if (screen != NULL)
-                                               fprintf(f, "add %.*s/unix%s %s %s\n",
-                                                   (int)(screen-display), display,
-                                                   screen, auth_proto, auth_data);
-#endif /* NO_X11_UNIX_SOCKETS */
-                                       pclose(f);
-                               } else {
-                                       fprintf(stderr, "Could not run %s\n",
-                                           cmd);
-                               }
+                                           "Adding %.*s/unix%s %s %s\n",
+                                           (int)(screen - s->display),
+                                           s->display, screen,
+                                           s->auth_proto, s->auth_data);
+                       }
+                       snprintf(cmd, sizeof cmd, "%s -q -",
+                           options.xauth_location);
+                       f = popen(cmd, "w");
+                       if (f) {
+                               fprintf(f, "add %s %s %s\n", s->display,
+                                   s->auth_proto, s->auth_data);
+                               if (screen != NULL)
+                                       fprintf(f, "add %.*s/unix%s %s %s\n",
+                                           (int)(screen - s->display),
+                                           s->display, screen,
+                                           s->auth_proto,
+                                           s->auth_data);
+                               pclose(f);
+                       } else {
+                               fprintf(stderr, "Could not run %s\n",
+                                   cmd);
                        }
                }
                /* Get the last component of the shell name. */
@@ -1413,6 +1496,10 @@ do_child(const char *command, struct passwd * pw, const char *term,
                else
                        cp = shell;
        }
+
+       /* restore SIGPIPE for child */
+       signal(SIGPIPE,  SIG_DFL);
+
        /*
         * If we have no command, execute the shell.  In this case, the shell
         * name to be passed in argv[0] is preceded by '-' to indicate that
@@ -1426,9 +1513,10 @@ do_child(const char *command, struct passwd * pw, const char *term,
                         * Check for mail if we have a tty and it was enabled
                         * in server options.
                         */
-                       if (ttyname && options.check_mail) {
+                       if (s->ttyfd != -1 && options.check_mail) {
                                char *mailbox;
                                struct stat mailstat;
+
                                mailbox = getenv("MAIL");
                                if (mailbox != NULL) {
                                        if (stat(mailbox, &mailstat) != 0 ||
@@ -1458,6 +1546,9 @@ do_child(const char *command, struct passwd * pw, const char *term,
                        /* Launch login(1). */
 
                        execl(LOGIN_PROGRAM, "login", "-h", hostname,
+#ifdef LOGIN_NEEDS_TERM
+                            s->term? s->term : "unknown",
+#endif
                             "-p", "-f", "--", pw->pw_name, NULL);
 
                        /* Login couldn't be executed, die. */
@@ -1495,19 +1586,11 @@ session_new(void)
        for(i = 0; i < MAX_SESSIONS; i++) {
                Session *s = &sessions[i];
                if (! s->used) {
-                       s->pid = 0;
-                       s->extended = 0;
+                       memset(s, 0, sizeof(*s));
                        s->chanid = -1;
                        s->ptyfd = -1;
                        s->ttyfd = -1;
-                       s->term = NULL;
-                       s->pw = NULL;
-                       s->display = NULL;
-                       s->screen = 0;
-                       s->auth_data = NULL;
-                       s->auth_proto = NULL;
                        s->used = 1;
-                       s->pw = NULL;
                        debug("session_new: session %d", i);
                        return s;
                }
@@ -1594,7 +1677,7 @@ int
 session_pty_req(Session *s)
 {
        u_int len;
-       char *term_modes;       /* encoded terminal modes */
+       int n_bytes;
 
        if (no_pty_flag)
                return 0;
@@ -1605,8 +1688,6 @@ session_pty_req(Session *s)
        s->row = packet_get_int();
        s->xpixel = packet_get_int();
        s->ypixel = packet_get_int();
-       term_modes = packet_get_string(&len);
-       packet_done();
 
        if (strcmp(s->term, "") == 0) {
                xfree(s->term);
@@ -1619,7 +1700,6 @@ session_pty_req(Session *s)
                s->ptyfd = -1;
                s->ttyfd = -1;
                error("session_pty_req: session %d alloc failed", s->self);
-               xfree(term_modes);
                return 0;
        }
        debug("session_pty_req: session %d alloc %s", s->self, s->tty);
@@ -1632,10 +1712,12 @@ session_pty_req(Session *s)
        /* Get window size from the packet. */
        pty_change_window_size(s->ptyfd, s->row, s->col, s->xpixel, s->ypixel);
 
+       /* Get tty modes from the packet. */
+       tty_parse_modes(s->ttyfd, &n_bytes);
+       packet_done();
+
        session_proctitle(s);
 
-       /* XXX parse and set terminal modes */
-       xfree(term_modes);
        return 1;
 }
 
@@ -1653,7 +1735,8 @@ session_subsystem_req(Session *s)
        for (i = 0; i < options.num_subsystems; i++) {
                if(strcmp(subsys, options.subsystem_name[i]) == 0) {
                        debug("subsystem: exec() %s", options.subsystem_command[i]);
-                       do_exec_no_pty(s, options.subsystem_command[i], s->pw);
+                       s->is_subsystem = 1;
+                       do_exec_no_pty(s, options.subsystem_command[i]);
                        success = 1;
                }
        }
@@ -1700,7 +1783,7 @@ session_x11_req(Session *s)
        }
        xauthfile = xmalloc(MAXPATHLEN);
        strlcpy(xauthfile, "/tmp/ssh-XXXXXXXX", MAXPATHLEN);
-       temporarily_use_uid(s->pw->pw_uid);
+       temporarily_use_uid(s->pw);
        if (mkdtemp(xauthfile) == NULL) {
                restore_uid();
                error("private X11 dir: mkdtemp %s failed: %s",
@@ -1727,11 +1810,10 @@ session_shell_req(Session *s)
        /* if forced_command == NULL, the shell is execed */
        char *shell = forced_command;
        packet_done();
-       s->extended = 1;
        if (s->ttyfd == -1)
-               do_exec_no_pty(s, shell, s->pw);
+               do_exec_no_pty(s, shell);
        else
-               do_exec_pty(s, shell, s->pw);
+               do_exec_pty(s, shell);
        return 1;
 }
 
@@ -1746,11 +1828,10 @@ session_exec_req(Session *s)
                command = forced_command;
                debug("Forced command '%.500s'", forced_command);
        }
-       s->extended = 1;
        if (s->ttyfd == -1)
-               do_exec_no_pty(s, command, s->pw);
+               do_exec_no_pty(s, command);
        else
-               do_exec_pty(s, command, s->pw);
+               do_exec_pty(s, command);
        if (forced_command == NULL)
                xfree(command);
        return 1;
@@ -1797,8 +1878,8 @@ session_input_channel_req(int id, void *arg)
            s->self, id, rtype, reply);
 
        /*
-        * a session is in LARVAL state until a shell
-        * or programm is executed
+        * a session is in LARVAL state until a shell, a command
+        * or a subsystem is executed
         */
        if (c->type == SSH_CHANNEL_LARVAL) {
                if (strcmp(rtype, "shell") == 0) {
@@ -2015,21 +2096,7 @@ session_proctitle(Session *s)
 void
 do_authenticated2(Authctxt *authctxt)
 {
-       /*
-        * Cancel the alarm we set to limit the time taken for
-        * authentication.
-        */
-       alarm(0);
-       if (startup_pipe != -1) {
-               close(startup_pipe);
-               startup_pipe = -1;
-       }
-#if defined(HAVE_LOGIN_CAP) && defined(HAVE_PW_CLASS_IN_PASSWD)
-       if ((lc = login_getclass(authctxt->pw->pw_class)) == NULL) {
-               error("unable to get login class");
-               return;
-       }
-#endif
+
        server_loop2();
        if (xauthfile)
                xauthfile_cleanup_proc(NULL);
This page took 0.296977 seconds and 4 git commands to generate.