From 044ccbaacf2bd1bd502c58b802e33d95c08dbff6 Mon Sep 17 00:00:00 2001 From: Wayne Davison Date: Fri, 30 Jun 2006 15:42:32 +0000 Subject: [PATCH] The remove_sent_files var was renamed to remove_sender_files. --- io.c | 8 ++++---- main.c | 7 ++++--- receiver.c | 6 +++--- sender.c | 7 ++----- 4 files changed, 13 insertions(+), 15 deletions(-) diff --git a/io.c b/io.c index 5b87be6f..09a74589 100644 --- a/io.c +++ b/io.c @@ -46,7 +46,7 @@ extern int read_batch; extern int csum_length; extern int checksum_seed; extern int protocol_version; -extern int remove_sent_files; +extern int remove_sender_files; extern int preserve_hard_links; extern char *filesfrom_host; extern struct stats stats; @@ -257,7 +257,7 @@ static void read_msg_fd(void) exit_cleanup(RERR_STREAMIO); } read_loop(fd, buf, 4); - if (remove_sent_files) + if (remove_sender_files) decrement_active_files(IVAL(buf,0)); flist_ndx_push(&redo_list, IVAL(buf,0)); break; @@ -275,7 +275,7 @@ static void read_msg_fd(void) exit_cleanup(RERR_STREAMIO); } read_loop(fd, buf, len); - if (remove_sent_files) { + if (remove_sender_files) { decrement_active_files(IVAL(buf,0)); send_msg(MSG_SUCCESS, buf, len); } @@ -311,7 +311,7 @@ static void read_msg_fd(void) } /* This is used by the generator to limit how many file transfers can - * be active at once when --remove-sent-files is specified. Without + * be active at once when --remove-sender-files is specified. Without * this, sender-side deletions were mostly happening at the end. */ void increment_active_files(int ndx, int itemizing, enum logcode code) { diff --git a/main.c b/main.c index 676dc5e6..0a241a36 100644 --- a/main.c +++ b/main.c @@ -35,7 +35,7 @@ extern int am_sender; extern int am_generator; extern int am_daemon; extern int blocking_io; -extern int remove_sent_files; +extern int remove_sender_files; extern int daemon_over_rsh; extern int need_messages_from_generator; extern int kluge_around_eof; @@ -614,9 +614,10 @@ static void do_server_sender(int f_in, int f_out, int argc, char *argv[]) exit_cleanup(RERR_SYNTAX); return; } - if (am_daemon && lp_read_only(module_id) && remove_sent_files) { + if (am_daemon && lp_read_only(module_id) && remove_sender_files) { rprintf(FERROR, - "ERROR: --remove-sent-files cannot be used with a read-only module\n"); + "ERROR: --remove-%s-files cannot be used with a read-only module\n", + remove_sender_files == 1 ? "sender" : "sent"); exit_cleanup(RERR_SYNTAX); return; } diff --git a/receiver.c b/receiver.c index 07fe3f4d..c0326399 100644 --- a/receiver.c +++ b/receiver.c @@ -40,7 +40,7 @@ extern int preserve_perms; extern int basis_dir_cnt; extern int make_backups; extern int cleanup_got_literal; -extern int remove_sent_files; +extern int remove_sender_files; extern int append_mode; extern int sparse_files; extern int keep_partial; @@ -296,7 +296,7 @@ static void handle_delayed_updates(struct file_list *flist, char *local_name) "rename failed for %s (from %s)", full_fname(fname), partialptr); } else { - if (remove_sent_files + if (remove_sender_files || (preserve_hard_links && file->link_u.links)) { SIVAL(numbuf, 0, i); @@ -644,7 +644,7 @@ int recv_files(int f_in, struct file_list *flist, char *local_name) cleanup_disable(); if (recv_ok > 0) { - if (remove_sent_files + if (remove_sender_files || (preserve_hard_links && file->link_u.links)) { SIVAL(numbuf, 0, i); send_msg(MSG_SUCCESS, numbuf, 4); diff --git a/sender.c b/sender.c index 9608ec96..4afdf5f4 100644 --- a/sender.c +++ b/sender.c @@ -34,7 +34,7 @@ extern int append_mode; extern int io_error; extern int allowed_lull; extern int protocol_version; -extern int remove_sent_files; +extern int remove_sender_files; extern int updating_basis_file; extern int make_backups; extern int do_progress; @@ -128,16 +128,13 @@ void successful_send(int ndx) return; file = the_file_list->files[ndx]; - /* The generator might tell us about symlinks we didn't send. */ - if (!(file->flags & FLAG_SENT) && !S_ISLNK(file->mode)) - return; if (file->dir.root) { offset = stringjoin(fname, sizeof fname, file->dir.root, "/", NULL); } else offset = 0; f_name(file, fname + offset); - if (remove_sent_files && do_unlink(fname) == 0 && verbose > 1) + if (remove_sender_files && do_unlink(fname) == 0 && verbose > 1) rprintf(FINFO, "sender removed %s\n", fname + offset); } -- 2.34.1