[BACK]Return to ssh.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / ssh

Diff for /src/usr.bin/ssh/ssh.c between version 1.116.2.3 and 1.116.2.4

version 1.116.2.3, 2001/11/15 22:51:15 version 1.116.2.4, 2002/03/09 00:20:45
Line 472 
Line 472 
                                     fwd_host_port);                                      fwd_host_port);
                         else if (opt == 'R')                          else if (opt == 'R')
                                 add_remote_forward(&options, fwd_port, buf,                                  add_remote_forward(&options, fwd_port, buf,
                                      fwd_host_port);                                      fwd_host_port);
                         break;                          break;
   
                 case 'D':                  case 'D':
Line 767 
Line 767 
 }  }
   
 static void  static void
 x11_get_proto(char *proto, int proto_len, char *data, int data_len)  x11_get_proto(char **_proto, char **_data)
 {  {
         char line[512];          char line[512];
           static char proto[512], data[512];
         FILE *f;          FILE *f;
         int got_data = 0, i;          int got_data = 0, i;
           char *display;
   
         if (options.xauth_location) {          *_proto = proto;
           *_data = data;
           proto[0] = data[0] = '\0';
           if (options.xauth_location && (display = getenv("DISPLAY"))) {
                 /* Try to get Xauthority information for the display. */                  /* Try to get Xauthority information for the display. */
                 snprintf(line, sizeof line, "%.100s list %.200s 2>" _PATH_DEVNULL,                  if (strncmp(display, "localhost:", 10) == 0)
                     options.xauth_location, getenv("DISPLAY"));                          /*
                            * Handle FamilyLocal case where $DISPLAY does
                            * not match an authorization entry.  For this we
                            * just try "xauth list unix:displaynum.screennum".
                            * XXX: "localhost" match to determine FamilyLocal
                            *      is not perfect.
                            */
                           snprintf(line, sizeof line, "%.100s list unix:%s 2>"
                               _PATH_DEVNULL, options.xauth_location, display+10);
                   else
                           snprintf(line, sizeof line, "%.100s list %.200s 2>"
                               _PATH_DEVNULL, options.xauth_location, display);
                   debug2("x11_get_proto %s", line);
                 f = popen(line, "r");                  f = popen(line, "r");
                 if (f && fgets(line, sizeof(line), f) &&                  if (f && fgets(line, sizeof(line), f) &&
                     sscanf(line, "%*s %s %s", proto, data) == 2)                      sscanf(line, "%*s %511s %511s", proto, data) == 2)
                         got_data = 1;                          got_data = 1;
                 if (f)                  if (f)
                         pclose(f);                          pclose(f);
Line 795 
Line 812 
         if (!got_data) {          if (!got_data) {
                 u_int32_t rand = 0;                  u_int32_t rand = 0;
   
                 strlcpy(proto, "MIT-MAGIC-COOKIE-1", proto_len);                  strlcpy(proto, "MIT-MAGIC-COOKIE-1", sizeof proto);
                 for (i = 0; i < 16; i++) {                  for (i = 0; i < 16; i++) {
                         if (i % 4 == 0)                          if (i % 4 == 0)
                                 rand = arc4random();                                  rand = arc4random();
                         snprintf(data + 2 * i, data_len - 2 * i, "%02x", rand & 0xff);                          snprintf(data + 2 * i, sizeof data - 2 * i, "%02x", rand & 0xff);
                         rand >>= 8;                          rand >>= 8;
                 }                  }
         }          }
Line 817 
Line 834 
                     options.local_forwards[i].port,                      options.local_forwards[i].port,
                     options.local_forwards[i].host,                      options.local_forwards[i].host,
                     options.local_forwards[i].host_port);                      options.local_forwards[i].host_port);
                 success += channel_request_local_forwarding(                  success += channel_setup_local_fwd_listener(
                     options.local_forwards[i].port,                      options.local_forwards[i].port,
                     options.local_forwards[i].host,                      options.local_forwards[i].host,
                     options.local_forwards[i].host_port,                      options.local_forwards[i].host_port,
Line 856 
Line 873 
 ssh_session(void)  ssh_session(void)
 {  {
         int type;          int type;
         int plen;  
         int interactive = 0;          int interactive = 0;
         int have_tty = 0;          int have_tty = 0;
         struct winsize ws;          struct winsize ws;
Line 874 
Line 890 
                 packet_put_int(options.compression_level);                  packet_put_int(options.compression_level);
                 packet_send();                  packet_send();
                 packet_write_wait();                  packet_write_wait();
                 type = packet_read(&plen);                  type = packet_read();
                 if (type == SSH_SMSG_SUCCESS)                  if (type == SSH_SMSG_SUCCESS)
                         packet_start_compression(options.compression_level);                          packet_start_compression(options.compression_level);
                 else if (type == SSH_SMSG_FAILURE)                  else if (type == SSH_SMSG_FAILURE)
Line 912 
Line 928 
                 packet_write_wait();                  packet_write_wait();
   
                 /* Read response from the server. */                  /* Read response from the server. */
                 type = packet_read(&plen);                  type = packet_read();
                 if (type == SSH_SMSG_SUCCESS) {                  if (type == SSH_SMSG_SUCCESS) {
                         interactive = 1;                          interactive = 1;
                         have_tty = 1;                          have_tty = 1;
Line 923 
Line 939 
         }          }
         /* Request X11 forwarding if enabled and DISPLAY is set. */          /* Request X11 forwarding if enabled and DISPLAY is set. */
         if (options.forward_x11 && getenv("DISPLAY") != NULL) {          if (options.forward_x11 && getenv("DISPLAY") != NULL) {
                 char proto[512], data[512];                  char *proto, *data;
                 /* Get reasonable local authentication information. */                  /* Get reasonable local authentication information. */
                 x11_get_proto(proto, sizeof proto, data, sizeof data);                  x11_get_proto(&proto, &data);
                 /* Request forwarding with authentication spoofing. */                  /* Request forwarding with authentication spoofing. */
                 debug("Requesting X11 forwarding with authentication spoofing.");                  debug("Requesting X11 forwarding with authentication spoofing.");
                 x11_request_forwarding_with_spoofing(0, proto, data);                  x11_request_forwarding_with_spoofing(0, proto, data);
   
                 /* Read response from the server. */                  /* Read response from the server. */
                 type = packet_read(&plen);                  type = packet_read();
                 if (type == SSH_SMSG_SUCCESS) {                  if (type == SSH_SMSG_SUCCESS) {
                         interactive = 1;                          interactive = 1;
                 } else if (type == SSH_SMSG_FAILURE) {                  } else if (type == SSH_SMSG_FAILURE) {
Line 951 
Line 967 
                 auth_request_forwarding();                  auth_request_forwarding();
   
                 /* Read response from the server. */                  /* Read response from the server. */
                 type = packet_read(&plen);                  type = packet_read();
                 packet_integrity_check(plen, 0, type);                  packet_check_eom();
                 if (type != SSH_SMSG_SUCCESS)                  if (type != SSH_SMSG_SUCCESS)
                         log("Warning: Remote host denied authentication agent forwarding.");                          log("Warning: Remote host denied authentication agent forwarding.");
         }          }
Line 973 
Line 989 
                 int len = buffer_len(&command);                  int len = buffer_len(&command);
                 if (len > 900)                  if (len > 900)
                         len = 900;                          len = 900;
                 debug("Sending command: %.*s", len, buffer_ptr(&command));                  debug("Sending command: %.*s", len, (u_char *)buffer_ptr(&command));
                 packet_start(SSH_CMSG_EXEC_CMD);                  packet_start(SSH_CMSG_EXEC_CMD);
                 packet_put_string(buffer_ptr(&command), buffer_len(&command));                  packet_put_string(buffer_ptr(&command), buffer_len(&command));
                 packet_send();                  packet_send();
Line 991 
Line 1007 
 }  }
   
 static void  static void
 client_subsystem_reply(int type, int plen, void *ctxt)  client_subsystem_reply(int type, u_int32_t seq, void *ctxt)
 {  {
         int id, len;          int id, len;
   
Line 999 
Line 1015 
         len = buffer_len(&command);          len = buffer_len(&command);
         if (len > 900)          if (len > 900)
                 len = 900;                  len = 900;
         packet_done();          packet_check_eom();
         if (type == SSH2_MSG_CHANNEL_FAILURE)          if (type == SSH2_MSG_CHANNEL_FAILURE)
                 fatal("Request for subsystem '%.*s' failed on channel %d",                  fatal("Request for subsystem '%.*s' failed on channel %d",
                     len, buffer_ptr(&command), id);                      len, (u_char *)buffer_ptr(&command), id);
 }  }
   
 /* request pty/x11/agent/tcpfwd/shell for channel */  /* request pty/x11/agent/tcpfwd/shell for channel */
Line 1039 
Line 1055 
         }          }
         if (options.forward_x11 &&          if (options.forward_x11 &&
             getenv("DISPLAY") != NULL) {              getenv("DISPLAY") != NULL) {
                 char proto[512], data[512];                  char *proto, *data;
                 /* Get reasonable local authentication information. */                  /* Get reasonable local authentication information. */
                 x11_get_proto(proto, sizeof proto, data, sizeof data);                  x11_get_proto(&proto, &data);
                 /* Request forwarding with authentication spoofing. */                  /* Request forwarding with authentication spoofing. */
                 debug("Requesting X11 forwarding with authentication spoofing.");                  debug("Requesting X11 forwarding with authentication spoofing.");
                 x11_request_forwarding_with_spoofing(id, proto, data);                  x11_request_forwarding_with_spoofing(id, proto, data);
Line 1061 
Line 1077 
                 if (len > 900)                  if (len > 900)
                         len = 900;                          len = 900;
                 if (subsystem_flag) {                  if (subsystem_flag) {
                         debug("Sending subsystem: %.*s", len, buffer_ptr(&command));                          debug("Sending subsystem: %.*s", len, (u_char *)buffer_ptr(&command));
                         channel_request_start(id, "subsystem", /*want reply*/ 1);                          channel_request_start(id, "subsystem", /*want reply*/ 1);
                         /* register callback for reply */                          /* register callback for reply */
                         /* XXX we asume that client_loop has already been called */                          /* XXX we asume that client_loop has already been called */
                         dispatch_set(SSH2_MSG_CHANNEL_FAILURE, &client_subsystem_reply);                          dispatch_set(SSH2_MSG_CHANNEL_FAILURE, &client_subsystem_reply);
                         dispatch_set(SSH2_MSG_CHANNEL_SUCCESS, &client_subsystem_reply);                          dispatch_set(SSH2_MSG_CHANNEL_SUCCESS, &client_subsystem_reply);
                 } else {                  } else {
                         debug("Sending command: %.*s", len, buffer_ptr(&command));                          debug("Sending command: %.*s", len, (u_char *)buffer_ptr(&command));
                         channel_request_start(id, "exec", 0);                          channel_request_start(id, "exec", 0);
                 }                  }
                 packet_put_string(buffer_ptr(&command), buffer_len(&command));                  packet_put_string(buffer_ptr(&command), buffer_len(&command));
                 packet_send();                  packet_send();
         } else {          } else {
                 channel_request(id, "shell", 0);                  channel_request_start(id, "shell", 0);
                   packet_send();
         }          }
         /* channel_callback(id, SSH2_MSG_OPEN_CONFIGMATION, client_init, 0); */  
   
         /* register different callback, etc. XXX */  
         packet_set_interactive(interactive);          packet_set_interactive(interactive);
 }  }
   
Line 1110 
Line 1125 
   
         window = CHAN_SES_WINDOW_DEFAULT;          window = CHAN_SES_WINDOW_DEFAULT;
         packetmax = CHAN_SES_PACKET_DEFAULT;          packetmax = CHAN_SES_PACKET_DEFAULT;
         if (!tty_flag) {          if (tty_flag) {
                 window *= 2;                  window >>= 1;
                 packetmax *=2;                  packetmax >>= 1;
         }          }
         c = channel_new(          c = channel_new(
             "session", SSH_CHANNEL_OPENING, in, out, err,              "session", SSH_CHANNEL_OPENING, in, out, err,
             window, packetmax, CHAN_EXTENDED_WRITE,              window, packetmax, CHAN_EXTENDED_WRITE,
             xstrdup("client-session"), /*nonblock*/0);              xstrdup("client-session"), /*nonblock*/0);
         if (c == NULL)  
                 fatal("ssh_session2_open: channel_new failed");  
   
         debug3("ssh_session2_open: channel_new: %d", c->self);          debug3("ssh_session2_open: channel_new: %d", c->self);
   
         channel_send_open(c->self);          channel_send_open(c->self);
         if (!no_shell_flag)          if (!no_shell_flag)
                 channel_register_callback(c->self,                  channel_register_confirm(c->self, ssh_session2_setup);
                      SSH2_MSG_CHANNEL_OPEN_CONFIRMATION,  
                      ssh_session2_setup, (void *)0);  
   
         return c->self;          return c->self;
 }  }
Legend:
Removed from v.1.116.2.3  
changed lines
  Added in v.1.116.2.4