X-Git-Url: https://mattmccutchen.net/rsync/rsync-patches.git/blobdiff_plain/dc8e6f704cdcdc461948f779dfbf3b5a36aa4bba..982426b8a364eae49577cb0906e84f0ff83499dc:/remove-sent-files.diff diff --git a/remove-sent-files.diff b/remove-sent-files.diff index e0abd3f..5bd4061 100644 --- a/remove-sent-files.diff +++ b/remove-sent-files.diff @@ -4,7 +4,7 @@ command before "make": make proto ---- orig/io.c 2004-07-21 23:59:35 +--- orig/io.c 2004-07-24 16:52:09 +++ io.c 2004-07-03 20:17:10 @@ -240,6 +240,14 @@ static void read_msg_fd(void) read_loop(fd, buf, 4); @@ -38,7 +38,7 @@ command before "make": case MSG_INFO: case MSG_ERROR: if (remaining >= sizeof line) { ---- orig/main.c 2004-07-21 23:59:35 +--- orig/main.c 2004-07-24 16:52:09 +++ main.c 2004-07-22 03:06:20 @@ -42,6 +42,7 @@ extern int list_only; extern int local_server; @@ -48,7 +48,7 @@ command before "make": extern int orig_umask; extern int keep_dirlinks; extern int preserve_hard_links; -@@ -610,6 +611,8 @@ void start_server(int f_in, int f_out, i +@@ -611,6 +612,8 @@ void start_server(int f_in, int f_out, i if (am_sender) { keep_dirlinks = 0; /* Must be disabled on the sender. */ @@ -57,7 +57,7 @@ command before "make": recv_exclude_list(f_in); if (cvs_exclude) -@@ -681,6 +684,9 @@ int client_run(int f_in, int f_out, pid_ +@@ -682,6 +685,9 @@ int client_run(int f_in, int f_out, pid_ exit_cleanup(status); } @@ -67,7 +67,7 @@ command before "make": if (argc == 0) list_only = 1; ---- orig/options.c 2004-07-21 23:59:35 +--- orig/options.c 2004-07-23 17:16:13 +++ options.c 2004-07-16 20:09:54 @@ -87,8 +87,10 @@ int size_only = 0; int bwlimit = 0; @@ -80,7 +80,7 @@ command before "make": int max_delete = 0; int ignore_errors = 0; int modify_window = 0; -@@ -264,6 +266,7 @@ void usage(enum logcode F) +@@ -265,6 +267,7 @@ void usage(enum logcode F) rprintf(F," --delete delete files that don't exist on the sending side\n"); rprintf(F," --delete-excluded also delete excluded files on the receiving side\n"); rprintf(F," --delete-after receiver deletes after transferring, not before\n"); @@ -88,7 +88,7 @@ command before "make": rprintf(F," --ignore-errors delete even if there are I/O errors\n"); rprintf(F," --max-delete=NUM don't delete more than NUM files\n"); rprintf(F," --partial keep partially transferred files\n"); -@@ -314,8 +317,8 @@ void usage(enum logcode F) +@@ -315,8 +318,8 @@ void usage(enum logcode F) } enum {OPT_VERSION = 1000, OPT_SENDER, OPT_EXCLUDE, OPT_EXCLUDE_FROM, @@ -99,7 +99,7 @@ command before "make": OPT_READ_BATCH, OPT_WRITE_BATCH, OPT_TIMEOUT, OPT_REFUSED_BASE = 9000}; -@@ -334,6 +337,7 @@ static struct poptOption long_options[] +@@ -335,6 +338,7 @@ static struct poptOption long_options[] {"ignore-existing", 0, POPT_ARG_NONE, &opt_ignore_existing, 0, 0, 0 }, {"delete-after", 0, POPT_ARG_NONE, 0, OPT_DELETE_AFTER, 0, 0 }, {"delete-excluded", 0, POPT_ARG_NONE, 0, OPT_DELETE_EXCLUDED, 0, 0 }, @@ -107,7 +107,7 @@ command before "make": {"force", 0, POPT_ARG_NONE, &force_delete, 0, 0, 0 }, {"numeric-ids", 0, POPT_ARG_NONE, &numeric_ids, 0, 0, 0 }, {"exclude", 0, POPT_ARG_STRING, 0, OPT_EXCLUDE, 0, 0 }, -@@ -520,6 +524,11 @@ int parse_arguments(int *argc, const cha +@@ -521,6 +525,11 @@ int parse_arguments(int *argc, const cha delete_mode = 1; break; @@ -119,7 +119,7 @@ command before "make": case OPT_EXCLUDE: if (am_server || sanitize_paths) return 0; /* Impossible... */ -@@ -1024,6 +1033,9 @@ void server_options(char **args,int *arg +@@ -1025,6 +1034,9 @@ void server_options(char **args,int *arg } } @@ -129,8 +129,8 @@ command before "make": *argc = ac; return; ---- orig/receiver.c 2004-07-22 02:58:15 -+++ receiver.c 2004-07-16 20:09:48 +--- orig/receiver.c 2004-07-26 16:20:00 ++++ receiver.c 2004-07-26 06:21:43 @@ -45,6 +45,7 @@ extern char *backup_dir; extern char *backup_suffix; extern int backup_suffix_len; @@ -139,7 +139,7 @@ command before "make": extern int module_id; extern int ignore_errors; extern int orig_umask; -@@ -338,7 +339,7 @@ int recv_files(int f_in, struct file_lis +@@ -342,7 +343,7 @@ int recv_files(int f_in, struct file_lis char *fname, fbuf[MAXPATHLEN]; char template[MAXPATHLEN]; char fnametmp[MAXPATHLEN]; @@ -148,7 +148,7 @@ command before "make": char fnamecmpbuf[MAXPATHLEN]; struct file_struct *file; struct stats initial_stats; -@@ -551,16 +552,20 @@ int recv_files(int f_in, struct file_lis +@@ -555,7 +556,12 @@ int recv_files(int f_in, struct file_lis cleanup_disable(); @@ -159,13 +159,14 @@ command before "make": + send_msg(MSG_SUCCESS, numbuf, 4); + } + } else { - if (csum_length == SUM_LENGTH) { - rprintf(FERROR,"ERROR: file corruption in %s. File changed during transfer?\n", - full_fname(fname)); - } else { + int msgtype = csum_length == SUM_LENGTH || read_batch ? + FERROR : FINFO; + if (msgtype == FERROR || verbose) { +@@ -575,9 +581,8 @@ int recv_files(int f_in, struct file_lis + keptstr, redostr); + } + if (csum_length != SUM_LENGTH) { - char buf[4]; - if (verbose > 1) - rprintf(FINFO,"redoing %s(%d)\n",fname,i); - SIVAL(buf, 0, i); - send_msg(MSG_REDO, buf, 4); + SIVAL(numbuf, 0, i); @@ -173,7 +174,7 @@ command before "make": } } } ---- orig/rsync.h 2004-07-20 21:36:08 +--- orig/rsync.h 2004-07-23 17:16:13 +++ rsync.h 2004-07-03 20:17:10 @@ -60,6 +60,7 @@ #define FLAG_TOP_DIR (1<<0) @@ -191,7 +192,7 @@ command before "make": MSG_DONE=5, /* current phase is done */ MSG_REDO=4, /* reprocess indicated flist index */ MSG_ERROR=FERROR, MSG_INFO=FINFO, MSG_LOG=FLOG, /* remote logging */ ---- orig/rsync.yo 2004-07-20 21:36:08 +--- orig/rsync.yo 2004-07-24 16:52:10 +++ rsync.yo 2004-07-03 20:17:10 @@ -314,6 +314,7 @@ verb( --delete delete files that don't exist on sender @@ -213,8 +214,8 @@ command before "make": dit(bf(--ignore-errors)) Tells --delete to go ahead and delete files even when there are I/O errors. ---- orig/sender.c 2004-07-20 21:36:08 -+++ sender.c 2004-07-16 20:10:19 +--- orig/sender.c 2004-07-26 16:27:00 ++++ sender.c 2004-07-26 16:49:19 @@ -26,6 +26,7 @@ extern int io_error; extern int dry_run; extern int am_server; @@ -262,10 +263,10 @@ command before "make": while (1) { unsigned int offset; -@@ -246,6 +271,9 @@ void send_files(struct file_list *flist, - - if (verbose > 2) - rprintf(FINFO, "sender finished %s\n", fname); +@@ -248,6 +273,9 @@ void send_files(struct file_list *flist, + rprintf(FINFO, "sender finished %s\n", + safe_fname(fname)); + } + + /* Flag that we actually sent this entry. */ + file->flags |= FLAG_SENT;