X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/55e50d890b6bfab9e75f2d72fe877dabd721cf49..e51094b7210fc31fa67cc218c1bd30de841a426e:/receiver.c diff --git a/receiver.c b/receiver.c index acc5da85..5d191482 100644 --- a/receiver.c +++ b/receiver.c @@ -46,21 +46,23 @@ extern int module_id; extern int ignore_errors; extern int orig_umask; extern int keep_partial; +extern int checksum_seed; static void delete_one(char *fn, int is_dir) { if (!is_dir) { if (robust_unlink(fn) != 0) { - rprintf(FERROR, "delete_one: unlink %s failed: %s\n", - full_fname(fn), strerror(errno)); + rsyserr(FERROR, errno, "delete_one: unlink %s failed", + full_fname(fn)); } else if (verbose) { rprintf(FINFO, "deleting %s\n", fn); } } else { if (do_rmdir(fn) != 0) { if (errno != ENOTEMPTY && errno != EEXIST) { - rprintf(FERROR, "delete_one: rmdir %s failed: %s\n", - full_fname(fn), strerror(errno)); + rsyserr(FERROR, errno, + "delete_one: rmdir %s failed", + full_fname(fn)); } } else if (verbose) { rprintf(FINFO, "deleting directory %s\n", fn); @@ -205,7 +207,7 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, read_sum_head(f_in, &sum); - sum_init(); + sum_init(checksum_seed); while ((i = recv_token(f_in, &data)) != 0) { if (do_progress) @@ -223,8 +225,8 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, sum_update(data,i); if (fd != -1 && write_file(fd,data,i) != i) { - rprintf(FERROR, "write failed on %s: %s\n", - full_fname(fname), strerror(errno)); + rsyserr(FERROR, errno, "write failed on %s", + full_fname(fname)); exit_cleanup(RERR_FILEIO); } offset += i; @@ -251,8 +253,8 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, } if (fd != -1 && write_file(fd,map,len) != (int) len) { - rprintf(FERROR, "write failed on %s: %s\n", - full_fname(fname), strerror(errno)); + rsyserr(FERROR, errno, "write failed on %s", + full_fname(fname)); exit_cleanup(RERR_FILEIO); } offset += len; @@ -264,8 +266,8 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, end_progress(total_size); if (fd != -1 && offset > 0 && sparse_end(fd) != 0) { - rprintf(FERROR, "write failed on %s: %s\n", - full_fname(fname), strerror(errno)); + rsyserr(FERROR, errno, "write failed on %s", + full_fname(fname)); exit_cleanup(RERR_FILEIO); } @@ -371,8 +373,8 @@ int recv_files(int f_in,struct file_list *flist,char *local_name) } if (fd1 != -1 && do_fstat(fd1,&st) != 0) { - rprintf(FERROR, "fstat %s failed: %s\n", - full_fname(fnamecmp), strerror(errno)); + rsyserr(FERROR, errno, "fstat %s failed", + full_fname(fnamecmp)); receive_data(f_in,NULL,-1,NULL,file->length); close(fd1); continue; @@ -436,8 +438,8 @@ int recv_files(int f_in,struct file_list *flist,char *local_name) fd2 = do_mkstemp(fnametmp, file->mode & INITACCESSPERMS); } if (fd2 == -1) { - rprintf(FERROR, "mkstemp %s failed: %s\n", - full_fname(fnametmp), strerror(errno)); + rsyserr(FERROR, errno, "mkstemp %s failed", + full_fname(fnametmp)); receive_data(f_in,mapbuf,-1,NULL,file->length); if (mapbuf) unmap_file(mapbuf); if (fd1 != -1) close(fd1); @@ -460,8 +462,8 @@ int recv_files(int f_in,struct file_list *flist,char *local_name) close(fd1); } if (close(fd2) < 0) { - rprintf(FERROR, "close failed on %s: %s\n", - full_fname(fnametmp), strerror(errno)); + rsyserr(FERROR, errno, "close failed on %s", + full_fname(fnametmp)); exit_cleanup(RERR_FILEIO); }