X-Git-Url: https://mattmccutchen.net/rsync/rsync-patches.git/blobdiff_plain/5214a41bbae94607b196b199b483710e1babf292..c1ff70aa47e11c5b37634479a0facee775a7b6d9:/checksum-updating.diff diff --git a/checksum-updating.diff b/checksum-updating.diff index a68de7b..3d1f1cc 100644 --- a/checksum-updating.diff +++ b/checksum-updating.diff @@ -17,7 +17,7 @@ TODO: - Fix the code that removes .rsyncsums files when a dir becomes empty. -based-on: patch/checksum-reading +based-on: patch/master/checksum-reading diff --git a/flist.c b/flist.c --- a/flist.c +++ b/flist.c @@ -29,7 +29,7 @@ diff --git a/flist.c b/flist.c extern int am_root; extern int am_server; extern int am_daemon; -@@ -106,6 +107,9 @@ extern iconv_t ic_send, ic_recv; +@@ -108,6 +109,9 @@ extern iconv_t ic_send, ic_recv; #define PTR_SIZE (sizeof (struct file_struct *)) @@ -39,7 +39,7 @@ diff --git a/flist.c b/flist.c int io_error; int checksum_len; dev_t filesystem_dev; /* used to implement -x */ -@@ -145,8 +149,13 @@ static char tmp_sum[MAX_DIGEST_LEN]; +@@ -147,8 +151,13 @@ static char tmp_sum[MAX_DIGEST_LEN]; static char empty_sum[MAX_DIGEST_LEN]; static int flist_count_offset; /* for --delete --progress */ @@ -53,7 +53,7 @@ diff --git a/flist.c b/flist.c } *csum_cache = NULL; static void flist_sort_and_clean(struct file_list *flist, int flags); -@@ -364,7 +373,79 @@ static void flist_done_allocating(struct file_list *flist) +@@ -366,7 +375,79 @@ static void flist_done_allocating(struct file_list *flist) flist->pool_boundary = ptr; } @@ -134,7 +134,7 @@ diff --git a/flist.c b/flist.c { int slot, slots = am_sender ? 1 : basis_dir_cnt + 1; -@@ -378,6 +459,9 @@ void reset_checksum_cache() +@@ -380,6 +461,9 @@ void reset_checksum_cache() struct file_list *flist = csum_cache[slot].flist; if (flist) { @@ -144,7 +144,7 @@ diff --git a/flist.c b/flist.c /* Reset the pool memory and empty the file-list array. */ pool_free_old(flist->file_pool, pool_boundary(flist->file_pool, 0)); -@@ -388,6 +472,10 @@ void reset_checksum_cache() +@@ -390,6 +474,10 @@ void reset_checksum_cache() flist->low = 0; flist->high = -1; flist->next = NULL; @@ -155,7 +155,7 @@ diff --git a/flist.c b/flist.c } } -@@ -395,7 +483,7 @@ void reset_checksum_cache() +@@ -397,7 +485,7 @@ void reset_checksum_cache() static int add_checksum(struct file_list *flist, const char *dirname, const char *basename, int basename_len, OFF_T file_length, time_t mtime, uint32 ctime, uint32 inode, @@ -164,7 +164,7 @@ diff --git a/flist.c b/flist.c { struct file_struct *file; int alloc_len, extra_len; -@@ -412,7 +500,7 @@ static int add_checksum(struct file_list *flist, const char *dirname, +@@ -414,7 +502,7 @@ static int add_checksum(struct file_list *flist, const char *dirname, if (extra_len & (EXTRA_ROUNDING * EXTRA_LEN)) extra_len = (extra_len | (EXTRA_ROUNDING * EXTRA_LEN)) + EXTRA_LEN; #endif @@ -173,7 +173,7 @@ diff --git a/flist.c b/flist.c bp = pool_alloc(flist->file_pool, alloc_len, "add_checksum"); memset(bp, 0, extra_len + FILE_STRUCT_LEN); -@@ -421,7 +509,14 @@ static int add_checksum(struct file_list *flist, const char *dirname, +@@ -423,7 +511,14 @@ static int add_checksum(struct file_list *flist, const char *dirname, bp += FILE_STRUCT_LEN; memcpy(bp, basename, basename_len); @@ -188,7 +188,7 @@ diff --git a/flist.c b/flist.c file->mode = S_IFREG; file->modtime = mtime; file->len32 = (uint32)file_length; -@@ -450,10 +545,11 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam +@@ -452,10 +547,11 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam char line[MAXPATHLEN+1024], fbuf[MAXPATHLEN], sum[MAX_DIGEST_LEN]; FILE *fp; char *cp; @@ -201,7 +201,7 @@ diff --git a/flist.c b/flist.c int dlen = dirname ? strlcpy(fbuf, dirname, sizeof fbuf) : 0; if (dlen >= (int)(sizeof fbuf - 1 - RSYNCSUMS_LEN)) -@@ -474,7 +570,7 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam +@@ -476,7 +572,7 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam while (fgets(line, sizeof line, fp)) { cp = line; if (protocol_version >= 30) { @@ -210,7 +210,7 @@ diff --git a/flist.c b/flist.c if (*cp == '=') while (*++cp == '=') {} else -@@ -485,7 +581,14 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam +@@ -487,7 +583,14 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam } if (*cp == '=') { @@ -226,7 +226,7 @@ diff --git a/flist.c b/flist.c } else { for (i = 0; i < checksum_len*2; i++, cp++) { int x; -@@ -503,13 +606,14 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam +@@ -505,13 +608,14 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam else sum[i/2] = x << 4; } @@ -242,7 +242,7 @@ diff --git a/flist.c b/flist.c if (*cp == '=') while (*++cp == '=') {} else -@@ -559,24 +663,112 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam +@@ -561,24 +665,112 @@ static void read_checksums(int slot, struct file_list *flist, const char *dirnam continue; strlcpy(fbuf+dlen, cp, sizeof fbuf - dlen); @@ -357,7 +357,7 @@ diff --git a/flist.c b/flist.c read_checksums(slot, flist, file->dirname); } -@@ -588,12 +780,31 @@ void get_cached_checksum(int slot, const char *fname, struct file_struct *file, +@@ -590,12 +782,31 @@ void get_cached_checksum(int slot, const char *fname, struct file_struct *file, && (checksum_files & CSF_LAX || (F_CTIME(fp) == (uint32)stp->st_ctime && F_INODE(fp) == (uint32)stp->st_ino))) { @@ -390,7 +390,7 @@ diff --git a/flist.c b/flist.c } /* Call this with EITHER (1) "file, NULL, 0" to chdir() to the file's -@@ -1488,6 +1699,8 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, +@@ -1490,6 +1701,8 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, if (is_excluded(thisname, S_ISDIR(st.st_mode) != 0, filter_level)) { if (ignore_perishable) non_perishable_cnt++; @@ -399,7 +399,7 @@ diff --git a/flist.c b/flist.c return NULL; } -@@ -1534,13 +1747,13 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, +@@ -1536,13 +1749,13 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, lastdir[len] = '\0'; lastdir_len = len; if (checksum_files && am_sender && flist) @@ -415,7 +415,7 @@ diff --git a/flist.c b/flist.c } } basename_len = strlen(basename) + 1; /* count the '\0' */ -@@ -1646,7 +1859,7 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, +@@ -1648,7 +1861,7 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, if (always_checksum && am_sender && S_ISREG(st.st_mode)) { if (flist && checksum_files) @@ -424,7 +424,7 @@ diff --git a/flist.c b/flist.c else file_checksum(thisname, st.st_size, tmp_sum); if (sender_keeps_checksum) -@@ -2019,6 +2232,9 @@ static void send_directory(int f, struct file_list *flist, char *fbuf, int len, +@@ -2021,6 +2234,9 @@ static void send_directory(int f, struct file_list *flist, char *fbuf, int len, closedir(d); @@ -434,7 +434,7 @@ diff --git a/flist.c b/flist.c if (f >= 0 && recurse && !divert_dirs) { int i, end = flist->used - 1; /* send_if_directory() bumps flist->used, so use "end". */ -@@ -2652,6 +2868,9 @@ struct file_list *send_file_list(int f, int argc, char *argv[]) +@@ -2671,6 +2887,9 @@ struct file_list *send_file_list(int f, int argc, char *argv[]) rprintf(FINFO, "[%s] flist_eof=1\n", who_am_i()); } @@ -447,7 +447,7 @@ diff --git a/flist.c b/flist.c diff --git a/generator.c b/generator.c --- a/generator.c +++ b/generator.c -@@ -111,6 +111,7 @@ static int dir_tweaking; +@@ -110,6 +110,7 @@ static int dir_tweaking; static int symlink_timeset_failed_flags; static int need_retouch_dir_times; static int need_retouch_dir_perms; @@ -455,7 +455,7 @@ diff --git a/generator.c b/generator.c static const char *solo_file = NULL; enum nonregtype { -@@ -533,7 +534,7 @@ int unchanged_file(char *fn, struct file_struct *file, STRUCT_STAT *st, int slot +@@ -532,7 +533,7 @@ int unchanged_file(char *fn, struct file_struct *file, STRUCT_STAT *st, int slot if (always_checksum > 0 && S_ISREG(st->st_mode)) { char sum[MAX_DIGEST_LEN]; if (checksum_files && slot >= 0) @@ -464,7 +464,7 @@ diff --git a/generator.c b/generator.c else file_checksum(fn, st->st_size, sum); return memcmp(sum, F_SUM(file), checksum_len) == 0; -@@ -1184,7 +1185,8 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, +@@ -1183,7 +1184,8 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, fuzzy_dirlist = get_dirlist(fnamecmpbuf, -1, 1); } if (checksum_files) { @@ -474,7 +474,7 @@ diff --git a/generator.c b/generator.c } need_new_dirscan = 0; } -@@ -1342,6 +1344,7 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, +@@ -1341,6 +1343,7 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, else change_local_filter_dir(fname, strlen(fname), F_DEPTH(file)); } @@ -482,7 +482,7 @@ diff --git a/generator.c b/generator.c goto cleanup; } -@@ -1615,6 +1618,8 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, +@@ -1614,6 +1617,8 @@ static void recv_generator(char *fname, struct file_struct *file, int ndx, handle_partial_dir(partialptr, PDIR_DELETE); } set_file_attrs(fname, file, &sx, NULL, maybe_ATTRS_REPORT); @@ -491,7 +491,7 @@ diff --git a/generator.c b/generator.c if (itemizing) itemize(fnamecmp, file, ndx, statret, &sx, 0, 0, NULL); #ifdef SUPPORT_HARD_LINKS -@@ -2122,6 +2127,7 @@ void generate_files(int f_out, const char *local_name) +@@ -2115,6 +2120,7 @@ void generate_files(int f_out, const char *local_name) } else change_local_filter_dir(fbuf, strlen(fbuf), F_DEPTH(fp)); } @@ -499,7 +499,7 @@ diff --git a/generator.c b/generator.c } for (i = cur_flist->low; i <= cur_flist->high; i++) { struct file_struct *file = cur_flist->sorted[i]; -@@ -2216,6 +2222,9 @@ void generate_files(int f_out, const char *local_name) +@@ -2209,6 +2215,9 @@ void generate_files(int f_out, const char *local_name) wait_for_receiver(); } @@ -520,7 +520,7 @@ diff --git a/io.c b/io.c extern int protocol_version; extern int remove_source_files; extern int preserve_hard_links; -@@ -987,6 +988,9 @@ static void got_flist_entry_status(enum festatus status, int ndx) +@@ -1025,6 +1026,9 @@ static void got_flist_entry_status(enum festatus status, int ndx) flist_ndx_push(&hlink_list, ndx); flist->in_progress++; } @@ -547,7 +547,7 @@ diff --git a/loadparm.c b/loadparm.c diff --git a/options.c b/options.c --- a/options.c +++ b/options.c -@@ -1656,7 +1656,15 @@ int parse_arguments(int *argc_p, const char ***argv_p) +@@ -1657,7 +1657,15 @@ int parse_arguments(int *argc_p, const char ***argv_p) case OPT_SUMFILES: arg = poptGetOptArg(pc);