X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/6c495e0da4b74a43adb9344f77efbb41908401a1..2b1366635dc416420ed2617260aafe17d259ae0f:/sender.c diff --git a/sender.c b/sender.c index 80b7096c..a964e086 100644 --- a/sender.c +++ b/sender.c @@ -27,7 +27,9 @@ extern int dry_run; extern int am_server; extern int am_daemon; extern int protocol_version; +extern int updating_basis_file; extern int make_backups; +extern int inplace; extern struct stats stats; @@ -38,22 +40,6 @@ extern struct stats stats; * and transmits them to the receiver. The sender process runs on the * machine holding the source files. **/ -void read_sum_head(int f, struct sum_struct *sum) -{ - sum->count = read_int(f); - sum->blength = read_int(f); - if (protocol_version < 27) { - sum->s2length = csum_length; - } else { - sum->s2length = read_int(f); - if (sum->s2length > MD4_SUM_LENGTH) { - rprintf(FERROR, "Invalid checksum length %ld\n", - (long)sum->s2length); - exit_cleanup(RERR_PROTOCOL); - } - } - sum->remainder = read_int(f); -} /** * Receive the checksums for a buffer @@ -152,15 +138,21 @@ void send_files(struct file_list *flist, int f_out, int f_in) exit_cleanup(RERR_PROTOCOL); } + if (inplace && protocol_version >= 29) { + uchar fnamecmp_type = read_byte(f_in); + updating_basis_file = fnamecmp_type == FNAMECMP_FNAME; + } else + updating_basis_file = inplace && !make_backups; + file = flist->files[i]; stats.current_file_index = i; stats.num_transferred_files++; stats.total_transferred_size += file->length; - if (file->basedir) { + if (file->dir.root) { /* N.B. We're sure that this fits, so offset is OK. */ - offset = strlcpy(fname, file->basedir, sizeof fname); + offset = strlcpy(fname, file->dir.root, sizeof fname); if (!offset || fname[offset-1] != '/') fname[offset++] = '/'; } else @@ -214,8 +206,8 @@ void send_files(struct file_list *flist, int f_out, int f_in) } if (st.st_size) { - OFF_T map_size = MAX((OFF_T)s->blength * 3, MAX_MAP_SIZE); - mbuf = map_file(fd, st.st_size, map_size, s->blength); + int32 read_size = MAX(s->blength * 3, MAX_MAP_SIZE); + mbuf = map_file(fd, st.st_size, read_size, s->blength); } else mbuf = NULL;