src/usr.bin/ssh/clientloop.c - diff

Return to clientloop.c CVS log

Up to [local] / src / usr.bin / ssh

Diff for /src/usr.bin/ssh/clientloop.c between version 1.39 and 1.40

-version 1.39, 2000/10/27 07:48:22
+version 1.40, 2000/11/06 23:04:56
 Line 75
 Line 75
 Line 75
  #include "buffer.h"
  #include "bufaux.h"
+ #include <openssl/dsa.h>
+ #include <openssl/rsa.h>
+ #include "key.h"
+ #include "authfd.h"
  /* import options */
  extern Options options;
-Line 1016
+Line 1020
 Line 1016
 Line 1020
          quit_pending = 1;
  }
+ Channel *
+ client_request_forwarded_tcpip(const char *request_type, int rchan)
+ {
+         Channel* c = NULL;
+         char *listen_address, *originator_address;
+         int listen_port, originator_port;
+         int sock, newch;
+         /* Get rest of the packet */
+         listen_address = packet_get_string(NULL);
+         listen_port = packet_get_int();
+         originator_address = packet_get_string(NULL);
+         originator_port = packet_get_int();
+         packet_done();
+         debug("client_request_forwarded_tcpip: listen %s port %d, originator %s port %d",
+             listen_address, listen_port, originator_address, originator_port);
+         sock = channel_connect_by_listen_adress(listen_port);
+         if (sock >= 0) {
+                 newch = channel_new("forwarded-tcpip",
+                     SSH_CHANNEL_OPEN, sock, sock, -1,
+                     CHAN_TCP_WINDOW_DEFAULT, CHAN_TCP_WINDOW_DEFAULT, 0,
+                     xstrdup(originator_address), 1);
+                 c = channel_lookup(newch);
+         }
+         xfree(originator_address);
+         xfree(listen_address);
+         return c;
+ }
+ Channel*
+ client_request_x11(const char *request_type, int rchan)
+ {
+         Channel *c = NULL;
+         char *originator;
+         int originator_port;
+         int sock, newch;
+         if (!options.forward_x11) {
+                 error("Warning: ssh server tried X11 forwarding.");
+                 error("Warning: this is probably a break in attempt by a malicious server.");
+                 return NULL;
+         }
+         originator = packet_get_string(NULL);
+         if (datafellows & SSH_BUG_X11FWD) {
+                 debug2("buggy server: x11 request w/o originator_port");
+                 originator_port = 0;
+         } else {
+                 originator_port = packet_get_int();
+         }
+         packet_done();
+         /* XXX check permission */
+         sock = x11_connect_display();
+         if (sock >= 0) {
+                 newch = channel_new("x11",
+                     SSH_CHANNEL_X11_OPEN, sock, sock, -1,
+                     CHAN_TCP_WINDOW_DEFAULT, CHAN_X11_PACKET_DEFAULT, 0,
+                     xstrdup("x11"), 1);
+                 c = channel_lookup(newch);
+         }
+         xfree(originator);
+         return c;
+ }
+ Channel*
+ client_request_agent(const char *request_type, int rchan)
+ {
+         Channel *c = NULL;
+         int sock, newch;
+         if (!options.forward_agent) {
+                 error("Warning: ssh server tried agent forwarding.");
+                 error("Warning: this is probably a break in attempt by a malicious server.");
+                 return NULL;
+         }
+         sock =  ssh_get_authentication_socket();
+         if (sock >= 0) {
+                 newch = channel_new("authentication agent connection",
+                     SSH_CHANNEL_OPEN, sock, sock, -1,
+                     CHAN_X11_WINDOW_DEFAULT, CHAN_TCP_WINDOW_DEFAULT, 0,
+                     xstrdup("authentication agent connection"), 1);
+                 c = channel_lookup(newch);
+         }
+         return c;
+ }
  /* XXXX move to generic input handler */
  void
  client_input_channel_open(int type, int plen, void *ctxt)
  {
          Channel *c = NULL;
          char *ctype;
-         int id;
          unsigned int len;
          int rchan;
          int rmaxpack;
-Line 1036
+Line 1126
 Line 1036
 Line 1126
          debug("client_input_channel_open: ctype %s rchan %d win %d max %d",
              ctype, rchan, rwindow, rmaxpack);
-         if (strcmp(ctype, "x11") == 0 && options.forward_x11) {
+         if (strcmp(ctype, "forwarded-tcpip") == 0) {
-                 int sock;
+                 c = client_request_forwarded_tcpip(ctype, rchan);
-                 char *originator;
+         } else if (strcmp(ctype, "x11") == 0) {
-                 int originator_port;
+                 c = client_request_x11(ctype, rchan);
-                 originator = packet_get_string(NULL);
+         } else if (strcmp(ctype, "auth-agent@openssh.com") == 0) {
-                 if (datafellows & SSH_BUG_X11FWD) {
+                 c = client_request_agent(ctype, rchan);
-                         debug2("buggy server: x11 request w/o originator_port");
-                         originator_port = 0;
-                 } else {
-                         originator_port = packet_get_int();
-                 }
-                 packet_done();
-                 /* XXX check permission */
-                 xfree(originator);
-                 /* XXX move to channels.c */
-                 sock = x11_connect_display();
-                 if (sock >= 0) {
-                         id = channel_new("x11", SSH_CHANNEL_X11_OPEN,
-                             sock, sock, -1, CHAN_X11_WINDOW_DEFAULT,
-                             CHAN_X11_PACKET_DEFAULT, 0, xstrdup("x11"), 1);
-                         c = channel_lookup(id);
-                 }
          }
  /* XXX duplicate : */
          if (c != NULL) {