X-Git-Url: https://mattmccutchen.net/rsync/rsync-patches.git/blobdiff_plain/03019e41fc3299020c8acdda06cf57a1e2c57a25..8e65e95897d45f2f9912349580c977c6e0a5cfc7:/fsync.diff diff --git a/fsync.diff b/fsync.diff index 42f85a4..0424fde 100644 --- a/fsync.diff +++ b/fsync.diff @@ -9,15 +9,15 @@ To use this patch, run these commands for a successful build: --- old/options.c +++ new/options.c -@@ -45,6 +45,7 @@ int append_mode = 0; +@@ -44,6 +44,7 @@ int append_mode = 0; int keep_dirlinks = 0; int copy_dirlinks = 0; int copy_links = 0; +int do_fsync = 0; int preserve_links = 0; int preserve_hard_links = 0; - int preserve_perms = 0; -@@ -339,6 +340,7 @@ void usage(enum logcode F) + int preserve_acls = 0; +@@ -367,6 +368,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"); @@ -25,35 +25,35 @@ To use this patch, run these commands for a successful build: 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"); -@@ -525,6 +527,7 @@ static struct poptOption long_options[] - {"only-write-batch", 0, POPT_ARG_STRING, &batch_name, OPT_ONLY_WRITE_BATCH, 0, 0 }, +@@ -580,6 +582,7 @@ static struct poptOption long_options[] {"files-from", 0, POPT_ARG_STRING, &files_from, 0, 0, 0 }, - {"from0", '0', POPT_ARG_NONE, &eol_nulls, 0, 0, 0}, + {"from0", '0', POPT_ARG_VAL, &eol_nulls, 1, 0, 0}, + {"no-from0", 0, POPT_ARG_VAL, &eol_nulls, 0, 0, 0}, + {"fsync", 0, POPT_ARG_NONE, &do_fsync, 0, 0, 0 }, - {"numeric-ids", 0, POPT_ARG_NONE, &numeric_ids, 0, 0, 0 }, + {"numeric-ids", 0, POPT_ARG_VAL, &numeric_ids, 1, 0, 0 }, + {"no-numeric-ids", 0, POPT_ARG_VAL, &numeric_ids, 0, 0, 0 }, {"timeout", 0, POPT_ARG_INT, &io_timeout, 0, 0, 0 }, - {"rsh", 'e', POPT_ARG_STRING, &shell_cmd, 0, 0, 0 }, -@@ -1727,6 +1730,9 @@ void server_options(char **args,int *arg - args[ac++] = tmpdir; - } +@@ -1885,6 +1888,9 @@ void server_options(char **args,int *arg + args[ac++] = tmpdir; + } -+ if (do_fsync && am_sender) -+ args[ac++] = "--fsync"; ++ if (do_fsync) ++ args[ac++] = "--fsync"; + - if (basis_dir[0] && am_sender) { - /* the server only needs this option if it is not the sender, - * and it may be an older version that doesn't know this + 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 -@@ -37,6 +37,7 @@ extern int protocol_version; - extern int relative_paths; +@@ -39,6 +39,7 @@ extern int relative_paths; extern int preserve_hard_links; extern int preserve_perms; + extern int preserve_xattrs; +extern int do_fsync; extern int basis_dir_cnt; extern int make_backups; extern int cleanup_got_literal; -@@ -258,6 +259,12 @@ static int receive_data(int f_in, char * +@@ -259,6 +260,12 @@ static int receive_data(int f_in, char * exit_cleanup(RERR_FILEIO); } @@ -63,12 +63,12 @@ To use this patch, run these commands for a successful build: + exit_cleanup(RERR_FILEIO); + } + - sum_end(file_sum1); + sum_len = sum_end(file_sum1); if (mapbuf) --- old/t_stub.c +++ new/t_stub.c -@@ -22,6 +22,7 @@ +@@ -21,6 +21,7 @@ #include "rsync.h" @@ -78,7 +78,7 @@ To use this patch, run these commands for a successful build: int relative_paths = 0; --- old/util.c +++ new/util.c -@@ -26,6 +26,7 @@ +@@ -25,6 +25,7 @@ extern int verbose; extern int dry_run; extern int module_id; @@ -86,16 +86,17 @@ To use this patch, run these commands for a successful build: extern int modify_window; extern int relative_paths; extern int human_readable; -@@ -314,6 +315,12 @@ int copy_file(const char *source, const - return -1; +@@ -309,6 +310,13 @@ int copy_file(const char *source, const + full_fname(source)); } + if (do_fsync && fsync(ofd) < 0) { + rsyserr(FERROR, errno, "fsync failed on %s", + full_fname(dest)); ++ close(ofd); + return -1; + } + - return 0; - } - + if (close(ofd) < 0) { + rsyserr(FERROR, errno, "close failed on %s", + full_fname(dest));