X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/3fef53645d0f05e126207cb49416248b6420f358..d62bcc17f303f30d1e3df1051b1390202a21cf9c:/sender.c diff --git a/sender.c b/sender.c index d103b9a2..d563df1c 100644 --- a/sender.c +++ b/sender.c @@ -110,7 +110,7 @@ void send_files(struct file_list *flist, int f_out, int f_in) { int fd = -1; struct sum_struct *s; - struct map_struct *buf = NULL; + struct map_struct *mbuf = NULL; STRUCT_STAT st; char fname[MAXPATHLEN]; int i; @@ -157,10 +157,11 @@ void send_files(struct file_list *flist, int f_out, int f_in) stats.num_transferred_files++; stats.total_transferred_size += file->length; - fname[0] = 0; if (file->basedir) { - offset = stringjoin(fname, sizeof fname, - file->basedir, "/", NULL); + /* N.B. We're sure that this fits, so offset is OK. */ + offset = strlcpy(fname, file->basedir, sizeof fname); + if (!offset || fname[offset-1] != '/') + fname[offset++] = '/'; } else offset = 0; f_name_to(file, fname + offset); @@ -200,8 +201,9 @@ void send_files(struct file_list *flist, int f_out, int f_in) full_fname(fname)); } else { io_error |= IOERR_GENERAL; - rprintf(FERROR, "send_files failed to open %s: %s\n", - full_fname(fname), strerror(errno)); + rsyserr(FERROR, errno, + "send_files failed to open %s", + full_fname(fname)); } free_sums(s); continue; @@ -210,26 +212,23 @@ void send_files(struct file_list *flist, int f_out, int f_in) /* map the local file */ if (do_fstat(fd, &st) != 0) { io_error |= IOERR_GENERAL; - rprintf(FERROR, "fstat failed: %s\n", strerror(errno)); + rsyserr(FERROR, errno, "fstat failed"); free_sums(s); close(fd); return; } - if (st.st_size > 0) { - buf = map_file(fd, st.st_size); - } else { - buf = NULL; - } + mbuf = st.st_size ? map_file(fd, st.st_size) : NULL; - if (verbose > 2) + if (verbose > 2) { rprintf(FINFO, "send_files mapped %s of size %.0f\n", fname, (double)st.st_size); + } write_int(f_out, i); if (write_batch) - write_batch_delta_file((char *)&i, sizeof(i)); + write_batch_delta_file((char *)&i, sizeof i); write_sum_head(f_out, s); } @@ -270,7 +269,7 @@ void send_files(struct file_list *flist, int f_out, int f_in) } } } /* end while */ - read_batch_delta_file( buff, MD4_SUM_LENGTH); + read_batch_delta_file(buff, MD4_SUM_LENGTH); write_buf(f_out, buff, MD4_SUM_LENGTH); } /* j=i */ @@ -280,18 +279,18 @@ void send_files(struct file_list *flist, int f_out, int f_in) continue; } } else { - match_sums(f_out, s, buf, st.st_size); + match_sums(f_out, s, mbuf, st.st_size); log_send(file, &initial_stats); } if (!read_batch) { - if (buf) { - j = unmap_file(buf); + if (mbuf) { + j = unmap_file(mbuf); if (j) { io_error |= IOERR_GENERAL; - rprintf(FERROR, - "read errors mapping %s: (%d) %s\n", - full_fname(fname), j, strerror(j)); + rsyserr(FERROR, j, + "read errors mapping %s", + full_fname(fname)); } } close(fd);