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

Diff for /src/usr.bin/ssh/sftp.c between version 1.21.2.4 and 1.22

version 1.21.2.4, 2002/10/11 14:53:07 version 1.22, 2001/12/19 07:18:56
Line 1 
Line 1 
 /*  /*
  * Copyright (c) 2001,2002 Damien Miller.  All rights reserved.   * Copyright (c) 2001 Damien Miller.  All rights reserved.
  *   *
  * Redistribution and use in source and binary forms, with or without   * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions   * modification, are permitted provided that the following conditions
Line 26 
Line 26 
   
 RCSID("$OpenBSD$");  RCSID("$OpenBSD$");
   
   /* XXX: commandline mode */
 /* XXX: short-form remote directory listings (like 'ls -C') */  /* XXX: short-form remote directory listings (like 'ls -C') */
   
 #include "buffer.h"  #include "buffer.h"
Line 39 
Line 40 
 #include "sftp-client.h"  #include "sftp-client.h"
 #include "sftp-int.h"  #include "sftp-int.h"
   
   char *ssh_program = _PATH_SSH_PROGRAM;
 FILE* infile;  FILE* infile;
 size_t copy_buffer_len = 32768;  
 size_t num_requests = 16;  
   
 static void  static void
 connect_to_server(char *path, char **args, int *in, int *out, pid_t *sshpid)  connect_to_server(char **args, int *in, int *out, pid_t *sshpid)
 {  {
         int c_in, c_out;          int c_in, c_out;
   
 #ifdef USE_PIPES  #ifdef USE_PIPES
         int pin[2], pout[2];          int pin[2], pout[2];
   
         if ((pipe(pin) == -1) || (pipe(pout) == -1))          if ((pipe(pin) == -1) || (pipe(pout) == -1))
                 fatal("pipe: %s", strerror(errno));                  fatal("pipe: %s", strerror(errno));
         *in = pin[0];          *in = pin[0];
Line 59 
Line 57 
         c_out = pin[1];          c_out = pin[1];
 #else /* USE_PIPES */  #else /* USE_PIPES */
         int inout[2];          int inout[2];
   
         if (socketpair(AF_UNIX, SOCK_STREAM, 0, inout) == -1)          if (socketpair(AF_UNIX, SOCK_STREAM, 0, inout) == -1)
                 fatal("socketpair: %s", strerror(errno));                  fatal("socketpair: %s", strerror(errno));
         *in = *out = inout[0];          *in = *out = inout[0];
Line 78 
Line 75 
                 close(*out);                  close(*out);
                 close(c_in);                  close(c_in);
                 close(c_out);                  close(c_out);
                 execv(path, args);                  execv(ssh_program, args);
                 fprintf(stderr, "exec: %s: %s\n", path, strerror(errno));                  fprintf(stderr, "exec: %s: %s\n", ssh_program, strerror(errno));
                 exit(1);                  exit(1);
         }          }
   
Line 90 
Line 87 
 static void  static void
 usage(void)  usage(void)
 {  {
         extern char *__progname;  
   
         fprintf(stderr,          fprintf(stderr,
             "usage: %s [-vC1] [-b batchfile] [-o option] [-s subsystem|path] [-B buffer_size]\n"              "usage: sftp [-1Cv] [-b batchfile] [-F config] [-o option] [-s subsystem|path]\n"
             "            [-F config] [-P direct server path] [-S program]\n"              "            [-S program] [user@]host[:file [file]]\n");
             "            [user@]host[:file [file]]\n", __progname);  
         exit(1);          exit(1);
 }  }
   
Line 107 
Line 101 
         char *host, *userhost, *cp, *file2;          char *host, *userhost, *cp, *file2;
         int debug_level = 0, sshver = 2;          int debug_level = 0, sshver = 2;
         char *file1 = NULL, *sftp_server = NULL;          char *file1 = NULL, *sftp_server = NULL;
         char *ssh_program = _PATH_SSH_PROGRAM, *sftp_direct = NULL;  
         LogLevel ll = SYSLOG_LEVEL_INFO;          LogLevel ll = SYSLOG_LEVEL_INFO;
         arglist args;          arglist args;
         extern int optind;          extern int optind;
Line 115 
Line 108 
   
         args.list = NULL;          args.list = NULL;
         addargs(&args, "ssh");          /* overwritten with ssh_program */          addargs(&args, "ssh");          /* overwritten with ssh_program */
           addargs(&args, "-oFallBackToRsh no");
         addargs(&args, "-oForwardX11 no");          addargs(&args, "-oForwardX11 no");
         addargs(&args, "-oForwardAgent no");          addargs(&args, "-oForwardAgent no");
         addargs(&args, "-oClearAllForwardings yes");          addargs(&args, "-oClearAllForwardings yes");
         ll = SYSLOG_LEVEL_INFO;          ll = SYSLOG_LEVEL_INFO;
         infile = stdin;         /* Read from STDIN unless changed by -b */          infile = stdin;         /* Read from STDIN unless changed by -b */
   
         while ((ch = getopt(argc, argv, "1hvCo:s:S:b:B:F:P:R:")) != -1) {          while ((ch = getopt(argc, argv, "1hvCo:s:S:b:F:")) != -1) {
                 switch (ch) {                  switch (ch) {
                 case 'C':                  case 'C':
                         addargs(&args, "-C");                          addargs(&args, "-C");
Line 156 
Line 150 
                         } else                          } else
                                 fatal("Filename already specified.");                                  fatal("Filename already specified.");
                         break;                          break;
                 case 'P':  
                         sftp_direct = optarg;  
                         break;  
                 case 'B':  
                         copy_buffer_len = strtol(optarg, &cp, 10);  
                         if (copy_buffer_len == 0 || *cp != '\0')  
                                 fatal("Invalid buffer size \"%s\"", optarg);  
                         break;  
                 case 'R':  
                         num_requests = strtol(optarg, &cp, 10);  
                         if (num_requests == 0 || *cp != '\0')  
                                 fatal("Invalid number of requests \"%s\"",  
                                     optarg);  
                         break;  
                 case 'h':                  case 'h':
                 default:                  default:
                         usage();                          usage();
                 }                  }
         }          }
   
         log_init(argv[0], ll, SYSLOG_FACILITY_USER, 1);          if (optind == argc || argc > (optind + 2))
                   usage();
   
         if (sftp_direct == NULL) {          userhost = xstrdup(argv[optind]);
                 if (optind == argc || argc > (optind + 2))          file2 = argv[optind+1];
                         usage();  
   
                 userhost = xstrdup(argv[optind]);          if ((cp = colon(userhost)) != NULL) {
                 file2 = argv[optind+1];                  *cp++ = '\0';
                   file1 = cp;
           }
   
                 if ((cp = colon(userhost)) != NULL) {          if ((host = strchr(userhost, '@')) == NULL)
                         *cp++ = '\0';                  host = userhost;
                         file1 = cp;          else {
                 }                  *host++ = '\0';
                   if (!userhost[0]) {
                 if ((host = strchr(userhost, '@')) == NULL)                          fprintf(stderr, "Missing username\n");
                         host = userhost;  
                 else {  
                         *host++ = '\0';  
                         if (!userhost[0]) {  
                                 fprintf(stderr, "Missing username\n");  
                                 usage();  
                         }  
                         addargs(&args, "-l%s",userhost);  
                 }  
   
                 host = cleanhostname(host);  
                 if (!*host) {  
                         fprintf(stderr, "Missing hostname\n");  
                         usage();                          usage();
                 }                  }
                   addargs(&args, "-l%s",userhost);
           }
   
                 addargs(&args, "-oProtocol %d", sshver);          host = cleanhostname(host);
           if (!*host) {
                   fprintf(stderr, "Missing hostname\n");
                   usage();
           }
   
                 /* no subsystem if the server-spec contains a '/' */          log_init(argv[0], ll, SYSLOG_FACILITY_USER, 1);
                 if (sftp_server == NULL || strchr(sftp_server, '/') == NULL)          addargs(&args, "-oProtocol %d", sshver);
                         addargs(&args, "-s");  
   
                 addargs(&args, "%s", host);          /* no subsystem if the server-spec contains a '/' */
                 addargs(&args, "%s", (sftp_server != NULL ?          if (sftp_server == NULL || strchr(sftp_server, '/') == NULL)
                     sftp_server : "sftp"));                  addargs(&args, "-s");
                 args.list[0] = ssh_program;  
   
                 fprintf(stderr, "Connecting to %s...\n", host);          addargs(&args, "%s", host);
                 connect_to_server(ssh_program, args.list, &in, &out,          addargs(&args, "%s", (sftp_server != NULL ? sftp_server : "sftp"));
                     &sshpid);          args.list[0] = ssh_program;
         } else {  
                 args.list = NULL;  
                 addargs(&args, "sftp-server");  
   
                 fprintf(stderr, "Attaching to %s...\n", sftp_direct);          fprintf(stderr, "Connecting to %s...\n", host);
                 connect_to_server(sftp_direct, args.list, &in, &out,  
                     &sshpid);  
         }  
   
           connect_to_server(args.list, &in, &out, &sshpid);
   
         interactive_loop(in, out, file1, file2);          interactive_loop(in, out, file1, file2);
   
         close(in);          close(in);
Line 237 
Line 206 
         if (infile != stdin)          if (infile != stdin)
                 fclose(infile);                  fclose(infile);
   
         while (waitpid(sshpid, NULL, 0) == -1)          if (waitpid(sshpid, NULL, 0) == -1)
                 if (errno != EINTR)                  fatal("Couldn't wait for ssh process: %s", strerror(errno));
                         fatal("Couldn't wait for ssh process: %s",  
                             strerror(errno));  
   
         exit(0);          exit(0);
 }  }
Legend:
Removed from v.1.21.2.4  
changed lines
  Added in v.1.22