int delete_mode=0;
int one_file_system=0;
int remote_version=0;
-int csum_length=SUM_LENGTH;
+extern int csum_length;
int am_server = 0;
static int sender = 0;
if (S_ISDIR(st.st_mode)) {
if (chdir(name) != 0) {
fprintf(stderr,"chdir %s : %s\n",name,strerror(errno));
- exit(1);
+ exit_cleanup(1);
}
return NULL;
}
if (flist->count > 1) {
fprintf(stderr,"ERROR: destination must be a directory when copying more than 1 file\n");
- exit(1);
+ exit_cleanup(1);
}
return name;
}
if (mkdir(name,0777) != 0) {
fprintf(stderr,"mkdir %s : %s\n",name,strerror(errno));
- exit(1);
+ exit_cleanup(1);
} else {
fprintf(am_server?stderr:stdout,"created directory %s\n",name);
}
if (chdir(name) != 0) {
fprintf(stderr,"chdir %s : %s\n",name,strerror(errno));
- exit(1);
+ exit_cleanup(1);
}
return NULL;
if (chdir(dir) != 0) {
fprintf(stderr,"chdir %s: %s\n",dir,strerror(errno));
- exit(1);
+ exit_cleanup(1);
}
argc--;
argv++;
flist = send_file_list(STDOUT_FILENO,recurse,argc,argv);
send_files(flist,STDOUT_FILENO,STDIN_FILENO);
report(STDOUT_FILENO);
- exit(0);
+ exit_cleanup(0);
}
argv++;
if (chdir(dir) != 0) {
fprintf(stderr,"chdir %s : %s\n",dir,strerror(errno));
- exit(1);
+ exit_cleanup(1);
}
}
flist = recv_file_list(STDIN_FILENO);
if (!flist || flist->count == 0) {
fprintf(stderr,"nothing to do\n");
- exit(1);
+ exit_cleanup(1);
}
if (argc > 0) {
recv_files(STDIN_FILENO,flist,local_name);
if (verbose > 2)
fprintf(stderr,"receiver read %d\n",read_total());
- exit(0);
+ exit_cleanup(0);
}
generate_files(STDOUT_FILENO,flist,local_name);
waitpid(pid, &status, 0);
- exit(status);
+ exit_cleanup(status);
}
starttime = time(NULL);
+ checksum_init();
+
while ((opt = getopt_long(argc, argv,
short_options, long_options, &option_index))
!= -1) {
case OPT_VERSION:
printf("rsync version %s protocol version %d\n",
VERSION,PROTOCOL_VERSION);
- exit(0);
+ exit_cleanup(0);
case OPT_SUFFIX:
backup_suffix = optarg;
case 'h':
usage(stdout);
- exit(0);
+ exit_cleanup(0);
case 'b':
make_backups=1;
preserve_uid=1;
} else {
fprintf(stderr,"-o only allowed for root\n");
- exit(1);
+ exit_cleanup(1);
}
break;
preserve_devices=1;
} else {
fprintf(stderr,"-D only allowed for root\n");
- exit(1);
+ exit_cleanup(1);
}
break;
case OPT_SENDER:
if (!am_server) {
usage(stderr);
- exit(1);
+ exit_cleanup(1);
}
sender = 1;
break;
default:
fprintf(stderr,"bad option -%c\n",opt);
- exit(1);
+ exit_cleanup(1);
}
}
if (am_server) {
remote_version = read_int(STDIN_FILENO);
- if (remote_version < MIN_PROTOCOL_VERSION) {
- fprintf(stderr,"protocol version mismatch %d %d\n",
- remote_version,PROTOCOL_VERSION);
- exit(1);
+ if (remote_version < MIN_PROTOCOL_VERSION ||
+ remote_version > MAX_PROTOCOL_VERSION) {
+ fprintf(stderr,"protocol version mismatch - is your shell clean?\n");
+ exit_cleanup(1);
}
write_int(STDOUT_FILENO,PROTOCOL_VERSION);
write_flush(STDOUT_FILENO);
} else {
do_server_recv(argc,argv);
}
- exit(0);
+ exit_cleanup(0);
}
if (argc < 2) {
usage(stderr);
- exit(1);
+ exit_cleanup(1);
}
p = strchr(argv[0],':');
if (!sender && argc != 1) {
usage(stderr);
- exit(1);
+ exit_cleanup(1);
}
pid = do_cmd(shell_cmd,shell_machine,shell_user,shell_path,&f_in,&f_out);
write_flush(f_out);
{
remote_version = read_int(f_in);
- if (remote_version < MIN_PROTOCOL_VERSION) {
- fprintf(stderr,"protocol version mismatch\n");
- exit(1);
+ if (remote_version < MIN_PROTOCOL_VERSION ||
+ remote_version > MAX_PROTOCOL_VERSION) {
+ fprintf(stderr,"protocol version mismatch - is your shell clean?\n");
+ exit_cleanup(1);
}
}
fprintf(stderr,"waiting on %d\n",pid);
waitpid(pid, &status, 0);
report(-1);
- exit(status);
+ exit_cleanup(status);
}
send_exclude_list(f_out);
flist = recv_file_list(f_in);
if (!flist || flist->count == 0) {
fprintf(stderr,"nothing to do\n");
- exit(0);
+ exit_cleanup(0);
}
local_name = get_local_name(flist,argv[0]);
recv_files(f_in,flist,local_name);
if (verbose > 1)
fprintf(stderr,"receiver read %d\n",read_total());
- exit(0);
+ exit_cleanup(0);
}
generate_files(f_out,flist,local_name);