X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/76076c4bbd066f56b35e1e08c8b88605b4edc615..dd04a03440be7c04ec7c3005d5fd92ec03311358:/main.c diff --git a/main.c b/main.c index ec408185..33496cc3 100644 --- a/main.c +++ b/main.c @@ -22,7 +22,7 @@ int verbose = 0; int always_checksum = 0; time_t starttime; -off_t total_size = 0; +int64 total_size = 0; int block_size=BLOCK_SIZE; char *backup_suffix = BACKUP_SUFFIX; @@ -54,6 +54,9 @@ 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; extern int csum_length; @@ -65,7 +68,7 @@ static void usage(FILE *f); static void report(int f) { - off_t in,out,tsize; + int64 in,out,tsize; time_t t = time(NULL); if (!verbose) return; @@ -107,6 +110,7 @@ static 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"; @@ -167,6 +171,11 @@ static void server_options(char **args,int *argc) args[ac++] = bsize; } + if (io_timeout) { + sprintf(iotime,"--timeout=%d",io_timeout); + args[ac++] = iotime; + } + if (strcmp(backup_suffix, BACKUP_SUFFIX)) { args[ac++] = "--suffix"; args[ac++] = backup_suffix; @@ -175,6 +184,9 @@ static void server_options(char **args,int *argc) if (delete_mode) args[ac++] = "--delete"; + if (force_delete) + args[ac++] = "--force"; + if (numeric_ids) args[ac++] = "--numeric-ids"; @@ -192,7 +204,7 @@ static int do_cmd(char *cmd,char *machine,char *user,char *path,int *f_in,int *f { char *args[100]; int i,argc=0, ret; - char *tok,*p,*dir=NULL; + char *tok,*dir=NULL; if (!local_server) { if (!cmd) @@ -235,10 +247,10 @@ static int do_cmd(char *cmd,char *machine,char *user,char *path,int *f_in,int *f args[argc] = NULL; if (verbose > 3) { - fprintf(FERROR,"cmd="); + fprintf(FINFO,"cmd="); for (i=0;i 2) - fprintf(FERROR,"server_sender starting pid=%d\n",(int)getpid()); + fprintf(FINFO,"server_sender starting pid=%d\n",(int)getpid()); if (!relative_paths && chdir(dir) != 0) { fprintf(FERROR,"chdir %s: %s (3)\n",dir,strerror(errno)); @@ -353,7 +365,7 @@ static int do_recv(int f_in,int f_out,struct file_list *flist,char *local_name) if ((pid=do_fork()) == 0) { recv_files(f_in,flist,local_name,recv_pipe[1]); if (verbose > 2) - fprintf(FERROR,"receiver read %ld\n",(long)read_total()); + fprintf(FINFO,"receiver read %ld\n",(long)read_total()); exit_cleanup(0); } @@ -373,7 +385,7 @@ void do_server_recv(int argc,char *argv[]) char *dir = NULL; if (verbose > 2) - fprintf(FERROR,"server_recv(%d) starting pid=%d\n",argc,(int)getpid()); + fprintf(FINFO,"server_recv(%d) starting pid=%d\n",argc,(int)getpid()); if (argc > 0) { dir = argv[0]; @@ -439,7 +451,9 @@ static void usage(FILE *f) fprintf(f," --rsync-path PATH specify path to rsync on the remote machine\n"); fprintf(f,"-C, --cvs-exclude auto ignore files in the same way CVS does\n"); fprintf(f," --delete delete files that don't exist on the sending side\n"); + fprintf(f," --force force deletion of directories even if not empty\n"); fprintf(f," --numeric-ids don't map uid/gid values by user/group name\n"); + fprintf(f," --timeout TIME set IO timeout in seconds\n"); fprintf(f,"-I, --ignore-times don't exclude files that match length and time\n"); fprintf(f,"-T --temp-dir DIR create temporary files in directory DIR\n"); fprintf(f,"-z, --compress compress file data\n"); @@ -454,7 +468,8 @@ static void usage(FILE *f) } enum {OPT_VERSION,OPT_SUFFIX,OPT_SENDER,OPT_SERVER,OPT_EXCLUDE, - OPT_EXCLUDE_FROM,OPT_DELETE,OPT_NUMERIC_IDS,OPT_RSYNC_PATH}; + OPT_EXCLUDE_FROM,OPT_DELETE,OPT_NUMERIC_IDS,OPT_RSYNC_PATH, + OPT_FORCE,OPT_TIMEOUT}; static char *short_options = "oblLWHpguDCtcahvrRIxnSe:B:T:z"; @@ -463,6 +478,7 @@ static struct option long_options[] = { {"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}, @@ -492,6 +508,7 @@ static struct option long_options[] = { {"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'}, {0,0,0,0}}; @@ -553,6 +570,10 @@ int main(int argc,char *argv[]) delete_mode = 1; break; + case OPT_FORCE: + force_delete = 1; + break; + case OPT_NUMERIC_IDS: numeric_ids = 1; break; @@ -680,6 +701,10 @@ int main(int argc,char *argv[]) block_size = atoi(optarg); break; + case OPT_TIMEOUT: + io_timeout = atoi(optarg); + break; + case 'T': tmpdir = optarg; break; @@ -771,7 +796,7 @@ int main(int argc,char *argv[]) } if (verbose > 3) { - fprintf(FERROR,"cmd=%s machine=%s user=%s path=%s\n", + fprintf(FINFO,"cmd=%s machine=%s user=%s path=%s\n", shell_cmd?shell_cmd:"", shell_machine?shell_machine:"", shell_user?shell_user:"", @@ -793,7 +818,7 @@ int main(int argc,char *argv[]) #endif if (verbose > 3) - fprintf(FERROR,"parent=%d child=%d sender=%d recurse=%d\n", + fprintf(FINFO,"parent=%d child=%d sender=%d recurse=%d\n", (int)getpid(),pid,sender,recurse); if (sender) { @@ -803,10 +828,10 @@ int main(int argc,char *argv[]) send_exclude_list(f_out); flist = send_file_list(f_out,argc,argv); if (verbose > 3) - fprintf(FERROR,"file list sent\n"); + fprintf(FINFO,"file list sent\n"); send_files(flist,f_out,f_in); if (verbose > 3) - fprintf(FERROR,"waiting on %d\n",pid); + fprintf(FINFO,"waiting on %d\n",pid); waitpid(pid, &status, 0); report(-1); exit_cleanup(status); @@ -816,7 +841,7 @@ int main(int argc,char *argv[]) flist = recv_file_list(f_in); if (!flist || flist->count == 0) { - fprintf(FERROR,"nothing to do\n"); + fprintf(FINFO,"nothing to do\n"); exit_cleanup(0); }