X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/3591c0660c52cec9fa06e7539b56604a7499fa10..e42c9458c2f1e3a78d6d45e99741d6edb38fc0cc:/main.c diff --git a/main.c b/main.c index fc4dc60d..6dfaf396 100644 --- a/main.c +++ b/main.c @@ -19,192 +19,61 @@ #include "rsync.h" -int verbose = 0; -int always_checksum = 0; time_t starttime = 0; int64 total_size = 0; -int block_size=BLOCK_SIZE; - -char *backup_suffix = BACKUP_SUFFIX; -char *tmpdir = NULL; - -static char *rsync_path = RSYNC_NAME; - -int make_backups = 0; -int whole_file = 0; -int copy_links = 0; -int preserve_links = 0; -int preserve_hard_links = 0; -int preserve_perms = 0; -int preserve_devices = 0; -int preserve_uid = 0; -int preserve_gid = 0; -int preserve_times = 0; -int update_only = 0; -int cvs_exclude = 0; -int dry_run=0; -int local_server=0; -int ignore_times=0; -int delete_mode=0; -int one_file_system=0; -int remote_version=0; -int sparse_files=0; -int do_compression=0; -int am_root=0; -int orig_umask=0; -int relative_paths=0; -int numeric_ids = 0; -int force_delete = 0; -int io_timeout = 0; -int io_error = 0; -int read_only = 0; -int module_id = -1; - -int rsync_port = RSYNC_PORT; - -static char *shell_cmd; extern int csum_length; -int am_server = 0; -int am_sender=0; -int recurse = 0; -int am_daemon=0; - -static void usage(int fd); +extern int verbose; static void report(int f) { - int64 in,out,tsize; - time_t t = time(NULL); - - if (!verbose) return; - - if (am_server && am_sender) { - write_longint(f,read_total()); - write_longint(f,write_total()); - write_longint(f,total_size); - write_flush(f); - return; - } - - if (am_sender) { - in = read_total(); - out = write_total(); - tsize = total_size; - } else { - in = read_longint(f); - out = read_longint(f); - tsize = read_longint(f); - } - - printf("wrote %.0f bytes read %.0f bytes %.2f bytes/sec\n", - (double)out,(double)in,(in+out)/(0.5 + (t-starttime))); - printf("total size is %.0f speedup is %.2f\n", - (double)tsize,(1.0*tsize)/(in+out)); -} - - -void server_options(char **args,int *argc) -{ - int ac = *argc; - static char argstr[50]; - static char bsize[30]; - static char iotime[30]; - int i, x; - - args[ac++] = "--server"; - - if (!am_sender) - args[ac++] = "--sender"; - - x = 1; - argstr[0] = '-'; - for (i=0;i 2) - rprintf(FINFO,"server_sender starting pid=%d\n",(int)getpid()); + if (verbose > 2) + rprintf(FINFO,"server_sender starting pid=%d\n",(int)getpid()); - if (!relative_paths && chdir(dir) != 0) { - rprintf(FERROR,"chdir %s: %s (3)\n",dir,strerror(errno)); - exit_cleanup(1); - } - argc--; - argv++; + if (!relative_paths && chdir(dir) != 0) { + rprintf(FERROR,"chdir %s: %s (3)\n",dir,strerror(errno)); + exit_cleanup(1); + } + argc--; + argv++; - if (strcmp(dir,".")) { - int l = strlen(dir); - if (strcmp(dir,"/") == 0) - l = 0; - for (i=0;i 2) - rprintf(FINFO,"server_recv(%d) starting pid=%d\n",argc,(int)getpid()); - - if (am_daemon) { - char *name = lp_name(module_id); - int i, l = strlen(name); - for (i=0;i 0) { - dir = argv[0]; - argc--; - argv++; - if (!am_daemon && chdir(dir) != 0) { - rprintf(FERROR,"chdir %s : %s (4)\n", - dir,strerror(errno)); - exit_cleanup(1); - } - } + int status; + struct file_list *flist; + char *local_name=NULL; + char *dir = NULL; + extern int delete_mode; + extern int am_daemon; - if (delete_mode) - recv_exclude_list(f_in); + if (verbose > 2) + rprintf(FINFO,"server_recv(%d) starting pid=%d\n",argc,(int)getpid()); + + if (argc > 0) { + dir = argv[0]; + argc--; + argv++; + if (!am_daemon && chdir(dir) != 0) { + rprintf(FERROR,"chdir %s : %s (4)\n", + dir,strerror(errno)); + exit_cleanup(1); + } + } - flist = recv_file_list(f_in); - if (!flist || flist->count == 0) { - rprintf(FERROR,"nothing to do\n"); - exit_cleanup(1); - } + if (delete_mode) + recv_exclude_list(f_in); - if (argc > 0) { - if (strcmp(dir,".")) { - argv[0] += strlen(dir); - if (argv[0][0] == '/') argv[0]++; - } - local_name = get_local_name(flist,argv[0]); - } + flist = recv_file_list(f_in); + if (!flist || flist->count == 0) { + rprintf(FERROR,"nothing to do\n"); + exit_cleanup(1); + } + + if (argc > 0) { + if (strcmp(dir,".")) { + argv[0] += strlen(dir); + if (argv[0][0] == '/') argv[0]++; + } + local_name = get_local_name(flist,argv[0]); + } - status = do_recv(f_in,f_out,flist,local_name); - exit_cleanup(status); + status = do_recv(f_in,f_out,flist,local_name); + exit_cleanup(status); } void start_server(int f_in, int f_out, int argc, char *argv[]) { - setup_protocol(f_out, f_in); + extern int cvs_exclude; + extern int am_sender; + + setup_protocol(f_out, f_in); - if (am_sender) { - recv_exclude_list(f_in); - if (cvs_exclude) - add_cvs_excludes(); - do_server_sender(f_in, f_out, argc, argv); - } else { - do_server_recv(f_in, f_out, argc, argv); - } - exit_cleanup(0); + if (am_sender) { + recv_exclude_list(f_in); + if (cvs_exclude) + add_cvs_excludes(); + do_server_sender(f_in, f_out, argc, argv); + } else { + do_server_recv(f_in, f_out, argc, argv); + } + exit_cleanup(0); } int client_run(int f_in, int f_out, int pid, int argc, char *argv[]) @@ -469,10 +322,13 @@ int client_run(int f_in, int f_out, int pid, int argc, char *argv[]) struct file_list *flist; int status = 0, status2 = 0; char *local_name = NULL; + extern int am_sender; setup_protocol(f_out,f_in); if (am_sender) { + extern int cvs_exclude; + extern int delete_mode; if (cvs_exclude) add_cvs_excludes(); if (delete_mode) @@ -520,6 +376,9 @@ int start_client(int argc, char *argv[]) char *shell_user = NULL; int pid; int f_in,f_out; + extern int local_server; + extern int am_sender; + extern char *shell_cmd; p = strchr(argv[0],':'); @@ -600,335 +459,61 @@ int start_client(int argc, char *argv[]) } -static void usage(int F) -{ - rprintf(F,"rsync version %s Copyright Andrew Tridgell and Paul Mackerras\n\n", - VERSION); - rprintf(F,"Usage:\t%s [options] src user@host:dest\nOR",RSYNC_NAME); - rprintf(F,"\t%s [options] user@host:src dest\n\n",RSYNC_NAME); - rprintf(F,"Options:\n"); - rprintf(F,"-v, --verbose increase verbosity\n"); - rprintf(F,"-c, --checksum always checksum\n"); - rprintf(F,"-a, --archive archive mode (same as -rlptDog)\n"); - rprintf(F,"-r, --recursive recurse into directories\n"); - rprintf(F,"-R, --relative use relative path names\n"); - rprintf(F,"-b, --backup make backups (default ~ extension)\n"); - rprintf(F,"-u, --update update only (don't overwrite newer files)\n"); - rprintf(F,"-l, --links preserve soft links\n"); - rprintf(F,"-L, --copy-links treat soft links like regular files\n"); - rprintf(F,"-H, --hard-links preserve hard links\n"); - rprintf(F,"-p, --perms preserve permissions\n"); - rprintf(F,"-o, --owner preserve owner (root only)\n"); - rprintf(F,"-g, --group preserve group\n"); - rprintf(F,"-D, --devices preserve devices (root only)\n"); - rprintf(F,"-t, --times preserve times\n"); - rprintf(F,"-S, --sparse handle sparse files efficiently\n"); - rprintf(F,"-n, --dry-run show what would have been transferred\n"); - rprintf(F,"-W, --whole-file copy whole files, no incremental checks\n"); - rprintf(F,"-x, --one-file-system don't cross filesystem boundaries\n"); - rprintf(F,"-B, --block-size SIZE checksum blocking size\n"); - rprintf(F,"-e, --rsh COMMAND specify rsh replacement\n"); - rprintf(F," --rsync-path PATH specify path to rsync on the remote machine\n"); - rprintf(F,"-C, --cvs-exclude auto ignore files in the same way CVS does\n"); - rprintf(F," --delete delete files that don't exist on the sending side\n"); - rprintf(F," --force force deletion of directories even if not empty\n"); - rprintf(F," --numeric-ids don't map uid/gid values by user/group name\n"); - rprintf(F," --timeout TIME set IO timeout in seconds\n"); - rprintf(F,"-I, --ignore-times don't exclude files that match length and time\n"); - rprintf(F,"-T --temp-dir DIR create temporary files in directory DIR\n"); - rprintf(F,"-z, --compress compress file data\n"); - rprintf(F," --exclude FILE exclude file FILE\n"); - rprintf(F," --exclude-from FILE exclude files listed in FILE\n"); - rprintf(F," --suffix SUFFIX override backup suffix\n"); - rprintf(F," --version print version number\n"); - - rprintf(F,"\n"); - rprintf(F,"the backup suffix defaults to %s\n",BACKUP_SUFFIX); - rprintf(F,"the block size defaults to %d\n",BLOCK_SIZE); -} - -enum {OPT_VERSION,OPT_SUFFIX,OPT_SENDER,OPT_SERVER,OPT_EXCLUDE, - OPT_EXCLUDE_FROM,OPT_DELETE,OPT_NUMERIC_IDS,OPT_RSYNC_PATH, - OPT_FORCE,OPT_TIMEOUT,OPT_DAEMON}; - -static char *short_options = "oblLWHpguDCtcahvrRIxnSe:B:T:z"; - -static struct option long_options[] = { - {"version", 0, 0, OPT_VERSION}, - {"server", 0, 0, OPT_SERVER}, - {"sender", 0, 0, OPT_SENDER}, - {"delete", 0, 0, OPT_DELETE}, - {"force", 0, 0, OPT_FORCE}, - {"numeric-ids", 0, 0, OPT_NUMERIC_IDS}, - {"exclude", 1, 0, OPT_EXCLUDE}, - {"exclude-from",1, 0, OPT_EXCLUDE_FROM}, - {"rsync-path", 1, 0, OPT_RSYNC_PATH}, - {"one-file-system",0, 0, 'x'}, - {"ignore-times",0, 0, 'I'}, - {"help", 0, 0, 'h'}, - {"dry-run", 0, 0, 'n'}, - {"sparse", 0, 0, 'S'}, - {"cvs-exclude", 0, 0, 'C'}, - {"archive", 0, 0, 'a'}, - {"checksum", 0, 0, 'c'}, - {"backup", 0, 0, 'b'}, - {"update", 0, 0, 'u'}, - {"verbose", 0, 0, 'v'}, - {"recursive", 0, 0, 'r'}, - {"relative", 0, 0, 'R'}, - {"devices", 0, 0, 'D'}, - {"perms", 0, 0, 'p'}, - {"links", 0, 0, 'l'}, - {"copy-links", 0, 0, 'L'}, - {"whole-file", 0, 0, 'W'}, - {"hard-links", 0, 0, 'H'}, - {"owner", 0, 0, 'o'}, - {"group", 0, 0, 'g'}, - {"times", 0, 0, 't'}, - {"rsh", 1, 0, 'e'}, - {"suffix", 1, 0, OPT_SUFFIX}, - {"block-size", 1, 0, 'B'}, - {"timeout", 1, 0, OPT_TIMEOUT}, - {"temp-dir", 1, 0, 'T'}, - {"compress", 0, 0, 'z'}, - {"daemon", 0, 0, OPT_DAEMON}, - {0,0,0,0}}; - RETSIGTYPE sigusr1_handler(int val) { exit_cleanup(1); } +int main(int argc,char *argv[]) +{ + extern int am_root; + extern int orig_umask; + extern int dry_run; + extern int am_daemon; + extern int am_server; -void parse_arguments(int argc, char *argv[]) -{ - int opt; - int option_index; - - while ((opt = getopt_long(argc, argv, - short_options, long_options, &option_index)) - != -1) { - switch (opt) - { - case OPT_VERSION: - printf("rsync version %s protocol version %d\n", - VERSION,PROTOCOL_VERSION); - exit_cleanup(0); - - case OPT_SUFFIX: - backup_suffix = optarg; - break; - - case OPT_RSYNC_PATH: - rsync_path = optarg; - break; - - case 'I': - ignore_times = 1; - break; - - case 'x': - one_file_system=1; - break; - - case OPT_DELETE: - delete_mode = 1; - break; - - case OPT_FORCE: - force_delete = 1; - break; - - case OPT_NUMERIC_IDS: - numeric_ids = 1; - break; - - case OPT_EXCLUDE: - add_exclude(optarg); - break; - - case OPT_EXCLUDE_FROM: - add_exclude_file(optarg,1); - break; - - case 'h': - usage(FINFO); - exit_cleanup(0); - - case 'b': - make_backups=1; - break; - - case 'n': - dry_run=1; - break; - - case 'S': - sparse_files=1; - break; - - case 'C': - cvs_exclude=1; - break; - - case 'u': - update_only=1; - break; - - case 'l': - preserve_links=1; - break; - - case 'L': - copy_links=1; - break; - - case 'W': - whole_file=1; - break; - - case 'H': -#if SUPPORT_HARD_LINKS - preserve_hard_links=1; -#else - rprintf(FERROR,"ERROR: hard links not supported on this platform\n"); - exit_cleanup(1); -#endif - break; - - case 'p': - preserve_perms=1; - break; - - case 'o': - preserve_uid=1; - break; - - case 'g': - preserve_gid=1; - break; - - case 'D': - preserve_devices=1; - break; - - case 't': - preserve_times=1; - break; - - case 'c': - always_checksum=1; - break; + signal(SIGUSR1, sigusr1_handler); - case 'v': - verbose++; - break; + starttime = time(NULL); + am_root = (getuid() == 0); - case 'a': - recurse=1; -#if SUPPORT_LINKS - preserve_links=1; -#endif - preserve_perms=1; - preserve_times=1; - preserve_gid=1; - if (am_root) { - preserve_devices=1; - preserve_uid=1; - } - break; - - case OPT_SERVER: - am_server = 1; - break; - - case OPT_SENDER: - if (!am_server) { - usage(FERROR); - exit_cleanup(1); - } - am_sender = 1; - break; - - case 'r': - recurse = 1; - break; - - case 'R': - relative_paths = 1; - break; - - case 'e': - shell_cmd = optarg; - break; - - case 'B': - block_size = atoi(optarg); - break; - - case OPT_TIMEOUT: - io_timeout = atoi(optarg); - break; - - case 'T': - tmpdir = optarg; - break; - - case 'z': - do_compression = 1; - break; - - case OPT_DAEMON: - am_daemon = 1; - break; - - default: - /* rprintf(FERROR,"bad option -%c\n",opt); */ - exit_cleanup(1); + if (argc < 2) { + usage(FERROR); + exit(1); } - } -} -int main(int argc,char *argv[]) -{ - - signal(SIGUSR1, sigusr1_handler); + /* we set a 0 umask so that correct file permissions can be + carried across */ + orig_umask = (int)umask(0); - starttime = time(NULL); - am_root = (getuid() == 0); + parse_arguments(argc, argv); - /* we set a 0 umask so that correct file permissions can be - carried across */ - orig_umask = (int)umask(0); + argc -= optind; + argv += optind; + optind = 0; - parse_arguments(argc, argv); + signal(SIGCHLD,SIG_IGN); + signal(SIGINT,SIGNAL_CAST sig_int); + signal(SIGPIPE,SIGNAL_CAST sig_int); + signal(SIGHUP,SIGNAL_CAST sig_int); - argc -= optind; - argv += optind; - optind = 0; - - signal(SIGCHLD,SIG_IGN); - signal(SIGINT,SIGNAL_CAST sig_int); - signal(SIGPIPE,SIGNAL_CAST sig_int); - signal(SIGHUP,SIGNAL_CAST sig_int); - - if (am_daemon) { - return daemon_main(); - } + if (am_daemon) { + return daemon_main(); + } - if (dry_run) - verbose = MAX(verbose,1); + if (dry_run) + verbose = MAX(verbose,1); #ifndef SUPPORT_LINKS - if (!am_server && preserve_links) { - rprintf(FERROR,"ERROR: symbolic links not supported\n"); - exit_cleanup(1); - } + if (!am_server && preserve_links) { + rprintf(FERROR,"ERROR: symbolic links not supported\n"); + exit_cleanup(1); + } #endif - if (am_server) { - start_server(STDIN_FILENO, STDOUT_FILENO, argc, argv); - } + if (am_server) { + start_server(STDIN_FILENO, STDOUT_FILENO, argc, argv); + } - return start_client(argc, argv); + return start_client(argc, argv); }