X-Git-Url: https://mattmccutchen.net/rsync/rsync-patches.git/blobdiff_plain/4c15e80040f6ac2fc79d599d1722cf209cc30536..0ef5abcbbb95298fa9faf1d3eb275a9e76e1d951:/link-by-hash.diff diff --git a/link-by-hash.diff b/link-by-hash.diff index 423c9a2..ca447b4 100644 --- a/link-by-hash.diff +++ b/link-by-hash.diff @@ -27,7 +27,7 @@ diff --git a/Makefile.in b/Makefile.in diff --git a/flist.c b/flist.c --- a/flist.c +++ b/flist.c -@@ -68,6 +68,7 @@ extern int need_unsorted_flist; +@@ -71,6 +71,7 @@ extern int sender_symlink_iconv; extern int unsort_ndx; extern struct stats stats; extern char *filesfrom_host; @@ -35,15 +35,15 @@ diff --git a/flist.c b/flist.c extern char curr_dir[MAXPATHLEN]; -@@ -822,7 +823,7 @@ static struct file_struct *recv_file_entry(struct file_list *flist, - extra_len += (S_ISDIR(mode) ? 2 : 1) * EXTRA_LEN; +@@ -844,7 +845,7 @@ static struct file_struct *recv_file_entry(struct file_list *flist, + extra_len += EXTRA_LEN; #endif - if (always_checksum && S_ISREG(mode)) + if ((always_checksum || link_by_hash_dir) && S_ISREG(mode)) extra_len += SUM_EXTRA_CNT * EXTRA_LEN; - if (file_length > 0xFFFFFFFFu && S_ISREG(mode)) + #if SIZEOF_INT64 >= 8 diff --git a/hashlink.c b/hashlink.c new file mode 100644 --- /dev/null @@ -388,7 +388,7 @@ new file mode 100644 diff --git a/options.c b/options.c --- a/options.c +++ b/options.c -@@ -156,6 +156,7 @@ char *backup_suffix = NULL; +@@ -157,6 +157,7 @@ char *backup_suffix = NULL; char *tmpdir = NULL; char *partial_dir = NULL; char *basis_dir[MAX_BASIS_DIRS+1]; @@ -396,7 +396,7 @@ diff --git a/options.c b/options.c char *config_file = NULL; char *shell_cmd = NULL; char *logfile_name = NULL; -@@ -389,6 +390,7 @@ void usage(enum logcode F) +@@ -395,6 +396,7 @@ void usage(enum logcode F) rprintf(F," --compare-dest=DIR also compare destination files relative to DIR\n"); rprintf(F," --copy-dest=DIR ... and include copies of unchanged files\n"); rprintf(F," --link-dest=DIR hardlink to files in DIR when unchanged\n"); @@ -404,24 +404,24 @@ diff --git a/options.c b/options.c rprintf(F," -z, --compress compress file data during the transfer\n"); rprintf(F," --compress-level=NUM explicitly set compression level\n"); rprintf(F," --skip-compress=LIST skip compressing files with a suffix in LIST\n"); -@@ -441,7 +443,7 @@ enum {OPT_VERSION = 1000, OPT_DAEMON, OPT_SENDER, OPT_EXCLUDE, OPT_EXCLUDE_FROM, +@@ -447,7 +449,7 @@ enum {OPT_VERSION = 1000, OPT_DAEMON, OPT_SENDER, OPT_EXCLUDE, OPT_EXCLUDE_FROM, OPT_FILTER, OPT_COMPARE_DEST, OPT_COPY_DEST, OPT_LINK_DEST, OPT_HELP, OPT_INCLUDE, OPT_INCLUDE_FROM, OPT_MODIFY_WINDOW, OPT_MIN_SIZE, OPT_CHMOD, OPT_READ_BATCH, OPT_WRITE_BATCH, OPT_ONLY_WRITE_BATCH, OPT_MAX_SIZE, -- OPT_NO_D, OPT_APPEND, -+ OPT_NO_D, OPT_APPEND, OPT_LINK_BY_HASH, +- OPT_NO_D, OPT_APPEND, OPT_NO_ICONV, ++ OPT_NO_D, OPT_APPEND, OPT_NO_ICONV, OPT_LINK_BY_HASH, OPT_SERVER, OPT_REFUSED_BASE = 9000}; static struct poptOption long_options[] = { -@@ -564,6 +566,7 @@ static struct poptOption long_options[] = { +@@ -579,6 +581,7 @@ static struct poptOption long_options[] = { {"compare-dest", 0, POPT_ARG_STRING, 0, OPT_COMPARE_DEST, 0, 0 }, {"copy-dest", 0, POPT_ARG_STRING, 0, OPT_COPY_DEST, 0, 0 }, {"link-dest", 0, POPT_ARG_STRING, 0, OPT_LINK_DEST, 0, 0 }, + {"link-by-hash", 0, POPT_ARG_STRING, 0, OPT_LINK_BY_HASH, 0, 0}, - {"fuzzy", 'y', POPT_ARG_NONE, &fuzzy_basis, 0, 0, 0 }, - {"compress", 'z', POPT_ARG_NONE, 0, 'z', 0, 0 }, - {"no-compress", 0, POPT_ARG_VAL, &do_compression, 0, 0, 0 }, -@@ -1226,6 +1229,21 @@ int parse_arguments(int *argc_p, const char ***argv_p, int frommain) + {"fuzzy", 'y', POPT_ARG_VAL, &fuzzy_basis, 1, 0, 0 }, + {"no-fuzzy", 0, POPT_ARG_VAL, &fuzzy_basis, 0, 0, 0 }, + {"no-y", 0, POPT_ARG_VAL, &fuzzy_basis, 0, 0, 0 }, +@@ -1261,6 +1264,21 @@ int parse_arguments(int *argc_p, const char ***argv_p) return 0; #endif @@ -429,7 +429,7 @@ diff --git a/options.c b/options.c +#ifdef HAVE_LINK + arg = poptGetOptArg(pc); + if (sanitize_paths) -+ arg = sanitize_path(NULL, arg, NULL, 0, NULL); ++ arg = sanitize_path(NULL, arg, NULL, 0, SP_DEFAULT); + link_by_hash_dir = (char *)arg; + break; +#else @@ -443,7 +443,7 @@ diff --git a/options.c b/options.c default: /* A large opt value means that set_refuse_options() * turned this option off. */ -@@ -1974,6 +1992,11 @@ void server_options(char **args, int *argc_p) +@@ -2038,6 +2056,11 @@ void server_options(char **args, int *argc_p) } else if (inplace) args[ac++] = "--inplace"; @@ -458,7 +458,7 @@ diff --git a/options.c b/options.c diff --git a/receiver.c b/receiver.c --- a/receiver.c +++ b/receiver.c -@@ -162,12 +162,14 @@ int open_tmpfile(char *fnametmp, const char *fname, struct file_struct *file) +@@ -163,12 +163,14 @@ int open_tmpfile(char *fnametmp, const char *fname, struct file_struct *file) } static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, @@ -474,7 +474,7 @@ diff --git a/receiver.c b/receiver.c int32 len, sum_len; OFF_T offset = 0; OFF_T offset2; -@@ -187,6 +189,9 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, +@@ -188,6 +190,9 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, } else mapbuf = NULL; @@ -484,7 +484,7 @@ diff --git a/receiver.c b/receiver.c sum_init(checksum_seed); if (append_mode > 0) { -@@ -231,6 +236,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, +@@ -232,6 +237,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, cleanup_got_literal = 1; sum_update(data, i); @@ -493,7 +493,7 @@ diff --git a/receiver.c b/receiver.c if (fd != -1 && write_file(fd,data,i) != i) goto report_write_error; -@@ -257,6 +264,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, +@@ -258,6 +265,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, see_token(map, len); sum_update(map, len); @@ -502,7 +502,7 @@ diff --git a/receiver.c b/receiver.c } if (updating_basis_or_equiv) { -@@ -299,6 +308,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, +@@ -303,6 +312,8 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, } sum_len = sum_end(file_sum1); @@ -511,7 +511,7 @@ diff --git a/receiver.c b/receiver.c if (mapbuf) unmap_file(mapbuf); -@@ -314,7 +325,7 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, +@@ -318,7 +329,7 @@ static int receive_data(int f_in, char *fname_r, int fd_r, OFF_T size_r, static void discard_receive_data(int f_in, OFF_T length) { @@ -520,7 +520,7 @@ diff --git a/receiver.c b/receiver.c } static void handle_delayed_updates(char *local_name) -@@ -675,7 +686,7 @@ int recv_files(int f_in, char *local_name) +@@ -708,7 +719,7 @@ int recv_files(int f_in, char *local_name) /* recv file data */ recv_ok = receive_data(f_in, fnamecmp, fd1, st.st_size, @@ -540,7 +540,7 @@ diff --git a/rsync.c b/rsync.c extern struct file_list *cur_flist, *first_flist, *dir_flist; extern struct chmod_mode_struct *daemon_chmod_modes; #ifdef ICONV_OPTION -@@ -533,8 +534,15 @@ int finish_transfer(const char *fname, const char *fnametmp, +@@ -578,8 +579,15 @@ int finish_transfer(const char *fname, const char *fnametmp, /* move tmp file over real file */ if (verbose > 2) rprintf(FINFO, "renaming %s to %s\n", fnametmp, fname); @@ -561,7 +561,7 @@ diff --git a/rsync.c b/rsync.c diff --git a/rsync.h b/rsync.h --- a/rsync.h +++ b/rsync.h -@@ -816,6 +816,14 @@ struct stats { +@@ -830,6 +830,14 @@ struct stats { int num_transferred_files; }; @@ -575,11 +575,11 @@ diff --git a/rsync.h b/rsync.h + struct chmod_mode_struct; - #define EMPTY_ITEM_LIST {NULL, 0, 0} + struct flist_ndx_item { diff --git a/rsync.yo b/rsync.yo --- a/rsync.yo +++ b/rsync.yo -@@ -388,6 +388,7 @@ to the detailed description below for a complete description. verb( +@@ -392,6 +392,7 @@ to the detailed description below for a complete description. verb( --compare-dest=DIR also compare received files relative to DIR --copy-dest=DIR ... and include copies of unchanged files --link-dest=DIR hardlink to files in DIR when unchanged