X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/4bb0af79b7c58431d17add7ad6506989ab61a1cb..ef20efcbb69274e423321d7ac27bfe868bca65aa:/receiver.c diff --git a/receiver.c b/receiver.c index e0dacd83..b0a9ebd5 100644 --- a/receiver.c +++ b/receiver.c @@ -21,27 +21,26 @@ #include "rsync.h" extern int verbose; +extern int dry_run; +extern int am_daemon; +extern int am_server; +extern int do_progress; extern int log_before_transfer; -extern int delete_after; +extern int log_format_has_i; +extern int daemon_log_format_has_i; extern int csum_length; -extern struct stats stats; -extern int dry_run; extern int read_batch; extern int batch_gen_fd; -extern int am_server; extern int protocol_version; extern int relative_paths; extern int keep_dirlinks; extern int preserve_hard_links; extern int preserve_perms; extern int io_error; -extern char *tmpdir; -extern char *partial_dir; -extern char *basis_dir[]; extern int basis_dir_cnt; extern int make_backups; -extern int do_progress; extern int cleanup_got_literal; +extern int remove_sent_files; extern int module_id; extern int ignore_errors; extern int orig_umask; @@ -49,30 +48,75 @@ extern int keep_partial; extern int checksum_seed; extern int inplace; extern int delay_updates; +extern struct stats stats; extern char *log_format; +extern char *tmpdir; +extern char *partial_dir; +extern char *basis_dir[]; extern struct filter_list_struct server_filter_list; +#define SLOT_SIZE (16*1024) /* Desired size in bytes */ +#define PER_SLOT_BITS (SLOT_SIZE * 8) /* Number of bits per slot */ +#define PER_SLOT_INTS (SLOT_SIZE / 4) /* Number of int32s per slot */ -/* This deletes any files on the receiving side that are not present on the - * sending side. This is used by --delete-before and --delete-after. */ -void delete_files(struct file_list *flist) +static uint32 **delayed_bits = NULL; +static int delayed_slot_cnt = 0; + +static void init_delayed_bits(int max_ndx) { - char fbuf[MAXPATHLEN]; - int j; + delayed_slot_cnt = (max_ndx + PER_SLOT_BITS - 1) / PER_SLOT_BITS; - for (j = 0; j < flist->count; j++) { - struct file_struct *file = flist->files[j]; + if (!(delayed_bits = (uint32**)calloc(delayed_slot_cnt, sizeof (uint32*)))) + out_of_memory("set_delayed_bit"); +} - if (!(file->flags & FLAG_DEL_HERE)) - continue; +static void set_delayed_bit(int ndx) +{ + int slot = ndx / PER_SLOT_BITS; + ndx %= PER_SLOT_BITS; - f_name_to(file, fbuf); - if (verbose > 1 && file->flags & FLAG_TOP_DIR) - rprintf(FINFO, "deleting in %s\n", safe_fname(fbuf)); + if (!delayed_bits[slot]) { + if (!(delayed_bits[slot] = (uint32*)calloc(PER_SLOT_INTS, 4))) + out_of_memory("set_delayed_bit"); + } + + delayed_bits[slot][ndx/32] |= 1u << (ndx % 32); +} - delete_in_dir(flist, fbuf, file); +/* Call this with -1 to start checking from 0. Returns -1 at the end. */ +static int next_delayed_bit(int after) +{ + uint32 bits, mask; + int i, ndx = after + 1; + int slot = ndx / PER_SLOT_BITS; + ndx %= PER_SLOT_BITS; + + mask = (1u << (ndx % 32)) - 1; + for (i = ndx / 32; slot < delayed_slot_cnt; slot++, i = mask = 0) { + if (!delayed_bits[slot]) + continue; + for ( ; i < PER_SLOT_INTS; i++, mask = 0) { + if (!(bits = delayed_bits[slot][i] & ~mask)) + continue; + /* The xor magic figures out the lowest enabled bit in + * bits, and the switch quickly computes log2(bit). */ + switch (bits ^ (bits & (bits-1))) { +#define LOG2(n) case 1u << n: return slot*PER_SLOT_BITS + i*32 + n + LOG2(0); LOG2(1); LOG2(2); LOG2(3); + LOG2(4); LOG2(5); LOG2(6); LOG2(7); + LOG2(8); LOG2(9); LOG2(10); LOG2(11); + LOG2(12); LOG2(13); LOG2(14); LOG2(15); + LOG2(16); LOG2(17); LOG2(18); LOG2(19); + LOG2(20); LOG2(21); LOG2(22); LOG2(23); + LOG2(24); LOG2(25); LOG2(26); LOG2(27); + LOG2(28); LOG2(29); LOG2(30); LOG2(31); + } + return -1; /* impossible... */ + } } + + return -1; } @@ -262,17 +306,6 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, static void read_gen_name(int fd, char *dirname, char *buf) { int dlen; - int len = read_byte(fd); - - if (len & 0x80) { -#if MAXPATHLEN > 32767 - uchar lenbuf[2]; - read_buf(fd, (char *)lenbuf, 2); - len = (len & ~0x80) * 0x10000 + lenbuf[0] * 0x100 + lenbuf[1]; -#else - len = (len & ~0x80) * 0x100 + read_byte(fd); -#endif - } if (dirname) { dlen = strlcpy(buf, dirname, MAXPATHLEN); @@ -280,12 +313,7 @@ static void read_gen_name(int fd, char *dirname, char *buf) } else dlen = 0; - if (dlen + len >= MAXPATHLEN) { - rprintf(FERROR, "bogus data on generator name pipe\n"); - exit_cleanup(RERR_PROTOCOL); - } - - read_sbuf(fd, buf + dlen, len); + read_vstring(fd, buf + dlen, MAXPATHLEN - dlen); } @@ -309,12 +337,13 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, char *fname, fbuf[MAXPATHLEN]; char template[MAXPATHLEN]; char fnametmp[MAXPATHLEN]; - char *fnamecmp, *partialptr; + char *fnamecmp, *partialptr, numbuf[4]; char fnamecmpbuf[MAXPATHLEN]; - uchar *delayed_bits = NULL; struct file_struct *file; struct stats initial_stats; int save_make_backups = make_backups; + int itemizing = am_daemon ? daemon_log_format_has_i + : !am_server && log_format_has_i; int i, recv_ok, phase = 0; if (verbose > 2) @@ -325,12 +354,8 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, flist->hlink_pool = NULL; } - if (delay_updates) { - int sz = (flist->count + 7) / 8; - if (!(delayed_bits = new_array(uchar, sz))) - out_of_memory("recv_files"); - memset(delayed_bits, 0, sz); - } + if (delay_updates) + init_delayed_bits(flist->count); while (1) { cleanup_disable(); @@ -361,29 +386,19 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, continue; } - if (i < 0 || i >= flist->count) { - rprintf(FERROR,"Invalid file index %d in recv_files (count=%d)\n", - i, flist->count); - exit_cleanup(RERR_PROTOCOL); - } + iflags = read_iflags(f_in, -1, i, fnametmp); + if (iflags == ITEM_IS_NEW) /* no-op packet */ + continue; file = flist->files[i]; + fname = local_name ? local_name : f_name_to(file, fbuf); - if (protocol_version >= 29) { - iflags = read_byte(f_in); - iflags |= read_byte(f_in) << 8; - if (!(iflags & ITEM_UPDATING) || !S_ISREG(file->mode)) { - if (!dry_run || !am_server) - log_recv(file, &stats, iflags); - continue; - } - } else - iflags = ITEM_UPDATING | ITEM_MISSING_DATA; + if (verbose > 2) + rprintf(FINFO, "recv_files(%s)\n", safe_fname(fname)); - if (!S_ISREG(file->mode)) { - rprintf(FERROR, "[%s] got index of non-regular file: %d\n", - who_am_i(), i); - exit_cleanup(RERR_PROTOCOL); + if (!(iflags & ITEM_TRANSFER)) { + maybe_log_item(file, iflags, itemizing, fnametmp); + continue; } stats.current_file_index = i; @@ -391,20 +406,15 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, stats.total_transferred_size += file->length; cleanup_got_literal = 0; - fname = local_name ? local_name : f_name_to(file, fbuf); - if (server_filter_list.head && check_filter(&server_filter_list, fname, 0) < 0) { rprintf(FERROR, "attempt to hack rsync failed.\n"); exit_cleanup(RERR_PROTOCOL); } - if (verbose > 2) - rprintf(FINFO, "recv_files(%s)\n", safe_fname(fname)); - if (dry_run) { /* log the transfer */ if (!am_server && log_format) - log_recv(file, &stats, iflags); + log_item(file, &stats, iflags, NULL); continue; } @@ -548,7 +558,7 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, /* log the transfer */ if (log_before_transfer) - log_recv(file, &initial_stats, iflags); + log_item(file, &initial_stats, iflags, NULL); else if (!am_server && verbose && do_progress) rprintf(FINFO, "%s\n", safe_fname(fname)); @@ -557,7 +567,7 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, fname, fd2, file->length); if (!log_before_transfer) - log_recv(file, &initial_stats, iflags); + log_item(file, &initial_stats, iflags, NULL); if (fd1 != -1) close(fd1); @@ -577,8 +587,10 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, && handle_partial_dir(partialptr, PDIR_CREATE)) { finish_transfer(partialptr, fnametmp, file, recv_ok, !partial_dir); - if (delay_updates && recv_ok) - delayed_bits[i/8] |= 1 << (i % 8); + if (delay_updates && recv_ok) { + set_delayed_bit(i); + recv_ok = -1; + } } else { partialptr = NULL; do_unlink(fnametmp); @@ -586,9 +598,14 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, cleanup_disable(); - if (!recv_ok) { - int msgtype = csum_length == SUM_LENGTH || read_batch ? - FERROR : FINFO; + if (recv_ok > 0) { + if (remove_sent_files + || (preserve_hard_links && file->link_u.links)) { + SIVAL(numbuf, 0, i); + send_msg(MSG_SUCCESS, numbuf, 4); + } + } else if (!recv_ok) { + int msgtype = phase || read_batch ? FERROR : FINFO; if (msgtype == FERROR || verbose) { char *errstr, *redostr, *keptstr; if (!(keep_partial && partialptr) && !inplace) @@ -609,21 +626,17 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, errstr, safe_fname(fname), keptstr, redostr); } - if (csum_length != SUM_LENGTH) { - char buf[4]; - SIVAL(buf, 0, i); - send_msg(MSG_REDO, buf, 4); + if (!phase) { + SIVAL(numbuf, 0, i); + send_msg(MSG_REDO, numbuf, 4); } } } make_backups = save_make_backups; if (delay_updates) { - for (i = 0; i < flist->count; i++) { + for (i = -1; (i = next_delayed_bit(i)) >= 0; ) { struct file_struct *file = flist->files[i]; - if (!file->basename - || !(delayed_bits[i/8] & (1 << (i % 8)))) - continue; fname = local_name ? local_name : f_name(file); partialptr = partial_dir_fname(fname); if (partialptr) { @@ -640,6 +653,12 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, full_fname(fname), safe_fname(partialptr)); } else { + if (remove_sent_files + || (preserve_hard_links + && file->link_u.links)) { + SIVAL(numbuf, 0, i); + send_msg(MSG_SUCCESS,numbuf,4); + } handle_partial_dir(partialptr, PDIR_DELETE); } @@ -647,9 +666,6 @@ int recv_files(int f_in, struct file_list *flist, char *local_name, } } - if (delete_after && !local_name && flist->count > 0) - delete_files(flist); - if (verbose > 2) rprintf(FINFO,"recv_files finished\n");