X-Git-Url: https://mattmccutchen.net/rsync/rsync-patches.git/blobdiff_plain/e9d4ab8849c465e766a494765b29e26564f284d0..cc3e685d09b2095099fc396157d19172ab3ef7c4:/fsync.diff diff --git a/fsync.diff b/fsync.diff index 7d53eda..a189255 100644 --- a/fsync.diff +++ b/fsync.diff @@ -7,9 +7,10 @@ To use this patch, run these commands for a successful build: ./configure (optional if already run) make ---- old/options.c -+++ new/options.c -@@ -45,6 +45,7 @@ int append_mode = 0; +diff --git a/options.c b/options.c +--- a/options.c ++++ b/options.c +@@ -46,6 +46,7 @@ int append_mode = 0; int keep_dirlinks = 0; int copy_dirlinks = 0; int copy_links = 0; @@ -17,23 +18,23 @@ To use this patch, run these commands for a successful build: int preserve_links = 0; int preserve_hard_links = 0; int preserve_acls = 0; -@@ -375,6 +376,7 @@ void usage(enum logcode F) +@@ -377,6 +378,7 @@ void usage(enum logcode F) rprintf(F," --partial-dir=DIR put a partially transferred file into DIR\n"); rprintf(F," --delay-updates put all updated files into place at transfer's end\n"); rprintf(F," -m, --prune-empty-dirs prune empty directory chains from the file-list\n"); + rprintf(F," --fsync fsync every written file\n"); rprintf(F," --numeric-ids don't map uid/gid values by user/group name\n"); - rprintf(F," --timeout=TIME set I/O timeout in seconds\n"); - rprintf(F," -I, --ignore-times don't skip files that match in size and mod-time\n"); -@@ -600,6 +602,7 @@ static struct poptOption long_options[] - {"no-numeric-ids", 0, POPT_ARG_VAL, &numeric_ids, 0, 0, 0 }, + rprintf(F," --timeout=SECONDS set I/O timeout in seconds\n"); + rprintf(F," --contimeout=SECONDS set daemon connection timeout in seconds\n"); +@@ -606,6 +608,7 @@ static struct poptOption long_options[] = { {"timeout", 0, POPT_ARG_INT, &io_timeout, 0, 0, 0 }, {"no-timeout", 0, POPT_ARG_VAL, &io_timeout, 0, 0, 0 }, + {"contimeout", 0, POPT_ARG_INT, &connect_timeout, 0, 0, 0 }, + {"fsync", 0, POPT_ARG_NONE, &do_fsync, 0, 0, 0 }, {"rsh", 'e', POPT_ARG_STRING, &shell_cmd, 0, 0, 0 }, {"rsync-path", 0, POPT_ARG_STRING, &rsync_path, 0, 0, 0 }, {"temp-dir", 'T', POPT_ARG_STRING, &tmpdir, 0, 0, 0 }, -@@ -1934,6 +1937,9 @@ void server_options(char **args, int *ar +@@ -1946,6 +1949,9 @@ void server_options(char **args, int *argc_p) args[ac++] = tmpdir; } @@ -43,8 +44,9 @@ To use this patch, run these commands for a successful build: if (basis_dir[0]) { /* the server only needs this option if it is not the sender, * and it may be an older version that doesn't know this ---- old/receiver.c -+++ new/receiver.c +diff --git a/receiver.c b/receiver.c +--- a/receiver.c ++++ b/receiver.c @@ -39,6 +39,7 @@ extern int relative_paths; extern int preserve_hard_links; extern int preserve_perms; @@ -53,7 +55,7 @@ To use this patch, run these commands for a successful build: extern int basis_dir_cnt; extern int make_backups; extern int cleanup_got_literal; -@@ -261,6 +262,12 @@ static int receive_data(int f_in, char * +@@ -298,6 +299,12 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, exit_cleanup(RERR_FILEIO); } @@ -66,8 +68,9 @@ To use this patch, run these commands for a successful build: sum_len = sum_end(file_sum1); if (mapbuf) ---- old/t_stub.c -+++ new/t_stub.c +diff --git a/t_stub.c b/t_stub.c +--- a/t_stub.c ++++ b/t_stub.c @@ -21,6 +21,7 @@ #include "rsync.h" @@ -76,9 +79,10 @@ To use this patch, run these commands for a successful build: int modify_window = 0; int module_id = -1; int relative_paths = 0; ---- old/util.c -+++ new/util.c -@@ -25,6 +25,7 @@ +diff --git a/util.c b/util.c +--- a/util.c ++++ b/util.c +@@ -26,6 +26,7 @@ extern int verbose; extern int dry_run; extern int module_id; @@ -86,7 +90,7 @@ To use this patch, run these commands for a successful build: extern int modify_window; extern int relative_paths; extern int human_readable; -@@ -310,6 +311,13 @@ int copy_file(const char *source, const +@@ -314,6 +315,13 @@ int copy_file(const char *source, const char *dest, int ofd, full_fname(source)); } @@ -98,5 +102,5 @@ To use this patch, run these commands for a successful build: + } + if (close(ofd) < 0) { - rsyserr(FERROR, errno, "close failed on %s", + rsyserr(FERROR_XFER, errno, "close failed on %s", full_fname(dest));