X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/abdcb21a7aa725cbf7a5a9e37f93484a133b69d1..9decb4d2ef51599425f12a68dbeba2b4f3a2d908:/flist.c diff --git a/flist.c b/flist.c index e6a80853..bac097b3 100644 --- a/flist.c +++ b/flist.c @@ -7,7 +7,7 @@ * Copyright (C) 2002-2007 Wayne Davison * * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License version 2 as + * it under the terms of the GNU General Public License version 3 as * published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, @@ -16,8 +16,7 @@ * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street - Fifth Floor, Boston, MA 02110-1301, USA. + * with this program; if not, visit the http://fsf.org website. */ #include "rsync.h" @@ -50,8 +49,8 @@ extern int preserve_links; extern int preserve_hard_links; extern int preserve_devices; extern int preserve_specials; -extern int preserve_uid; -extern int preserve_gid; +extern int uid_ndx; +extern int gid_ndx; extern int relative_paths; extern int implied_dirs; extern int file_extra_cnt; @@ -145,7 +144,7 @@ static void finish_filelist_progress(const struct file_list *flist) if (do_progress) { /* This overwrites the progress line */ rprintf(FINFO, "%d file%sto consider\n", - flist->count, flist->count == 1 ? " " : "s "); + flist->used, flist->used == 1 ? " " : "s "); } else rprintf(FINFO, "done\n"); } @@ -272,12 +271,12 @@ static const char *pathname, *orig_dir; static int pathname_len; -/* Make sure flist can hold at least flist->count + extra entries. */ +/* Make sure flist can hold at least flist->used + extra entries. */ static void flist_expand(struct file_list *flist, int extra) { struct file_struct **new_ptr; - if (flist->count + extra <= flist->malloced) + if (flist->used + extra <= flist->malloced) return; if (flist->malloced < FLIST_START) @@ -289,8 +288,8 @@ static void flist_expand(struct file_list *flist, int extra) /* In case count jumped or we are starting the list * with a known size just set it. */ - if (flist->malloced < flist->count + extra) - flist->malloced = flist->count + extra; + if (flist->malloced < flist->used + extra) + flist->malloced = flist->used + extra; new_ptr = realloc_array(flist->files, struct file_struct *, flist->malloced); @@ -414,24 +413,24 @@ static void send_file_entry(int f, struct file_struct *file, int ndx) } } else if (protocol_version < 28) rdev = MAKEDEV(0, 0); - if (preserve_uid) { + if (uid_ndx) { if ((uid_t)F_OWNER(file) == uid && *lastname) flags |= XMIT_SAME_UID; else { uid = F_OWNER(file); - if (preserve_uid && !numeric_ids) { + if (uid_ndx && !numeric_ids) { user_name = add_uid(uid); if (inc_recurse && user_name) flags |= XMIT_USER_NAME_FOLLOWS; } } } - if (preserve_gid) { + if (gid_ndx) { if ((gid_t)F_GROUP(file) == gid && *lastname) flags |= XMIT_SAME_GID; else { gid = F_GROUP(file); - if (preserve_gid && !numeric_ids) { + if (gid_ndx && !numeric_ids) { group_name = add_gid(gid); if (inc_recurse && group_name) flags |= XMIT_GROUP_NAME_FOLLOWS; @@ -513,7 +512,7 @@ static void send_file_entry(int f, struct file_struct *file, int ndx) } if (!(flags & XMIT_SAME_MODE)) write_int(f, to_wire_mode(mode)); - if (preserve_uid && !(flags & XMIT_SAME_UID)) { + if (uid_ndx && !(flags & XMIT_SAME_UID)) { if (protocol_version < 30) write_int(f, uid); else { @@ -525,7 +524,7 @@ static void send_file_entry(int f, struct file_struct *file, int ndx) } } } - if (preserve_gid && !(flags & XMIT_SAME_GID)) { + if (gid_ndx && !(flags & XMIT_SAME_GID)) { if (protocol_version < 30) write_int(f, gid); else { @@ -691,19 +690,19 @@ static struct file_struct *recv_file_entry(struct file_list *flist, && BITS_SETnUNSET(xflags, XMIT_HLINKED, XMIT_HLINK_FIRST)) { struct file_struct *first; first_hlink_ndx = read_varint30(f); - if (first_hlink_ndx < 0 || first_hlink_ndx >= flist->count) { + if (first_hlink_ndx < 0 || first_hlink_ndx >= flist->used) { rprintf(FERROR, "hard-link reference out of range: %d (%d)\n", - first_hlink_ndx, flist->count); + first_hlink_ndx, flist->used); exit_cleanup(RERR_PROTOCOL); } first = flist->files[first_hlink_ndx]; file_length = F_LENGTH(first); modtime = first->modtime; mode = first->mode; - if (preserve_uid) + if (uid_ndx) uid = F_OWNER(first); - if (preserve_gid) + if (gid_ndx) gid = F_GROUP(first); if ((preserve_devices && IS_DEVICE(mode)) || (preserve_specials && IS_SPECIAL(mode))) { @@ -739,7 +738,7 @@ static struct file_struct *recv_file_entry(struct file_list *flist, if (chmod_modes && !S_ISLNK(mode)) mode = tweak_mode(mode, chmod_modes); - if (preserve_uid && !(xflags & XMIT_SAME_UID)) { + if (uid_ndx && !(xflags & XMIT_SAME_UID)) { if (protocol_version < 30) uid = (uid_t)read_int(f); else { @@ -750,7 +749,7 @@ static struct file_struct *recv_file_entry(struct file_list *flist, uid = match_uid(uid); } } - if (preserve_gid && !(xflags & XMIT_SAME_GID)) { + if (gid_ndx && !(xflags & XMIT_SAME_GID)) { if (protocol_version < 30) gid = (gid_t)read_int(f); else { @@ -857,15 +856,15 @@ static struct file_struct *recv_file_entry(struct file_list *flist, OPT_EXTRA(file, 0)->unum = (uint32)(file_length >> 32); } file->mode = mode; - if (preserve_uid) + if (uid_ndx) F_OWNER(file) = uid; - if (preserve_gid) { + if (gid_ndx) { F_GROUP(file) = gid; file->flags |= gid_flags; } #ifdef ICONV_OPTION if (ic_ndx) - F_NDX(file) = flist->count + flist->ndx_start; + F_NDX(file) = flist->used + flist->ndx_start; #endif if (basename != thisname) { @@ -919,7 +918,7 @@ static struct file_struct *recv_file_entry(struct file_list *flist, if (preserve_hard_links && xflags & XMIT_HLINKED) { if (protocol_version >= 30) { F_HL_GNUM(file) = xflags & XMIT_HLINK_FIRST - ? flist->count : first_hlink_ndx; + ? flist->used : first_hlink_ndx; } else { static int32 cnt = 0; struct idev_node *np; @@ -1003,8 +1002,7 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, alloc_pool_t *pool; char *bp; - if (strlcpy(thisname, fname, sizeof thisname) - >= sizeof thisname - pathname_len) { + if (strlcpy(thisname, fname, sizeof thisname) >= sizeof thisname) { rprintf(FINFO, "skipping overly long name: %s\n", fname); return NULL; } @@ -1178,9 +1176,9 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, OPT_EXTRA(file, 0)->unum = (uint32)(st.st_size >> 32); } file->mode = st.st_mode; - if (preserve_uid) + if (uid_ndx) F_OWNER(file) = st.st_uid; - if (preserve_gid) + if (gid_ndx) F_GROUP(file) = st.st_gid; if (basename != thisname) @@ -1209,9 +1207,9 @@ struct file_struct *make_file(const char *fname, struct file_list *flist, file->modtime = st2.st_mtime; file->len32 = 0; file->mode = st2.st_mode; - if (preserve_uid) + if (uid_ndx) F_OWNER(file) = st2.st_uid; - if (preserve_gid) + if (gid_ndx) F_GROUP(file) = st2.st_gid; } else file->mode = save_mode; @@ -1271,12 +1269,12 @@ static struct file_struct *send_file_name(int f, struct file_list *flist, } #endif - maybe_emit_filelist_progress(flist->count + flist_count_offset); + maybe_emit_filelist_progress(flist->used + flist_count_offset); flist_expand(flist, 1); - flist->files[flist->count++] = file; + flist->files[flist->used++] = file; if (f >= 0) { - send_file_entry(f, file, flist->count - 1); + send_file_entry(f, file, flist->used - 1); #ifdef SUPPORT_ACLS if (preserve_acls && !S_ISLNK(file->mode)) { send_acl(&sx, f); @@ -1406,7 +1404,7 @@ static void add_dirs_to_tree(int parent_ndx, struct file_list *from_flist, if (!S_ISDIR(file->mode)) continue; - dir_flist->files[dir_flist->count++] = file; + dir_flist->files[dir_flist->used++] = file; dir_cnt--; if (!(file->flags & FLAG_XFER_DIR) @@ -1414,11 +1412,11 @@ static void add_dirs_to_tree(int parent_ndx, struct file_list *from_flist, continue; if (dp) - DIR_NEXT_SIBLING(dp) = dir_flist->count - 1; + DIR_NEXT_SIBLING(dp) = dir_flist->used - 1; else if (parent_dp) - DIR_FIRST_CHILD(parent_dp) = dir_flist->count - 1; + DIR_FIRST_CHILD(parent_dp) = dir_flist->used - 1; else - send_dir_ndx = dir_flist->count - 1; + send_dir_ndx = dir_flist->used - 1; dp = F_DIRNODE_P(file); DIR_PARENT(dp) = parent_ndx; @@ -1441,7 +1439,7 @@ static void send_directory(int f, struct file_list *flist, char *fbuf, int len, char *p; DIR *d; int divert_dirs = (flags & FLAG_DIVERT_DIRS) != 0; - int start = flist->count; + int start = flist->used; int filter_flags = f == -2 ? SERVER_FILTERS : ALL_FILTERS; assert(flist != NULL); @@ -1484,8 +1482,8 @@ static void send_directory(int f, struct file_list *flist, char *fbuf, int len, closedir(d); if (f >= 0 && recurse && !divert_dirs) { - int i, end = flist->count - 1; - /* send_if_directory() bumps flist->count, so use "end". */ + int i, end = flist->used - 1; + /* send_if_directory() bumps flist->used, so use "end". */ for (i = start; i <= end; i++) send_if_directory(f, flist, flist->files[i], fbuf, len, flags); } @@ -1522,7 +1520,7 @@ void send_extra_file_list(int f, int at_least) * files in the upcoming file-lists. */ if (cur_flist->next) { flist = first_flist->prev; /* the newest flist */ - future_cnt = flist->count + flist->ndx_start + future_cnt = flist->used + flist->ndx_start - cur_flist->next->ndx_start; } else future_cnt = 0; @@ -1560,10 +1558,10 @@ void send_extra_file_list(int f, int at_least) #ifdef ICONV_OPTION if (need_unsorted_flist) { - if (!(flist->sorted = new_array(struct file_struct *, flist->count))) + if (!(flist->sorted = new_array(struct file_struct *, flist->used))) out_of_memory("send_extra_file_list"); memcpy(flist->sorted, flist->files, - flist->count * sizeof (struct file_struct*)); + flist->used * sizeof (struct file_struct*)); } else #endif flist->sorted = flist->files; @@ -1573,10 +1571,10 @@ void send_extra_file_list(int f, int at_least) add_dirs_to_tree(send_dir_ndx, flist, dir_count - dstart); flist_done_allocating(flist); - file_total += flist->count; - future_cnt += flist->count; + file_total += flist->used; + future_cnt += flist->used; stats.flist_size += stats.total_written - start_write; - stats.num_files += flist->count; + stats.num_files += flist->used; if (verbose > 3) output_flist(flist); @@ -1867,20 +1865,23 @@ struct file_list *send_file_list(int f, int argc, char *argv[]) #ifdef ICONV_OPTION if (need_unsorted_flist) { if (inc_recurse) { - if (!(flist->sorted = new_array(struct file_struct *, flist->count))) + if (!(flist->sorted = new_array(struct file_struct *, flist->used))) out_of_memory("send_file_list"); memcpy(flist->sorted, flist->files, - flist->count * sizeof (struct file_struct*)); + flist->used * sizeof (struct file_struct*)); clean_flist(flist, 0); - } else + } else { flist->sorted = flist->files; + flist->low = 0; + flist->high = flist->used - 1; + } } else #endif { flist->sorted = flist->files; clean_flist(flist, 0); } - file_total += flist->count; + file_total += flist->used; if (!numeric_ids && !inc_recurse) send_id_list(f); @@ -1895,7 +1896,7 @@ struct file_list *send_file_list(int f, int argc, char *argv[]) io_end_buffering_out(); stats.flist_size = stats.total_written - start_write; - stats.num_files = flist->count; + stats.num_files = flist->used; if (verbose > 3) output_flist(flist); @@ -1946,7 +1947,7 @@ struct file_list *recv_file_list(int f) if (inc_recurse) { if (flist->ndx_start == 0) dir_flist = flist_new(FLIST_TEMP, "recv_file_list"); - dstart = dir_flist->count; + dstart = dir_flist->used; } else { dir_flist = flist; dstart = 0; @@ -1963,22 +1964,22 @@ struct file_list *recv_file_list(int f) if (inc_recurse && S_ISDIR(file->mode)) { flist_expand(dir_flist, 1); - dir_flist->files[dir_flist->count++] = file; + dir_flist->files[dir_flist->used++] = file; } - flist->files[flist->count++] = file; + flist->files[flist->used++] = file; - maybe_emit_filelist_progress(flist->count); + maybe_emit_filelist_progress(flist->used); if (verbose > 2) { rprintf(FINFO, "recv_file_name(%s)\n", f_name(file, NULL)); } } - file_total += flist->count; + file_total += flist->used; if (verbose > 2) - rprintf(FINFO, "received %d names\n", flist->count); + rprintf(FINFO, "received %d names\n", flist->used); if (show_filelist_p()) finish_filelist_progress(flist); @@ -1990,25 +1991,25 @@ struct file_list *recv_file_list(int f) * order and for calling flist_find()). We keep the "files" * list unsorted for our exchange of index numbers with the * other side (since their names may not sort the same). */ - if (!(flist->sorted = new_array(struct file_struct *, flist->count))) + if (!(flist->sorted = new_array(struct file_struct *, flist->used))) out_of_memory("recv_file_list"); memcpy(flist->sorted, flist->files, - flist->count * sizeof (struct file_struct*)); - if (inc_recurse && dir_flist->count > dstart) { + flist->used * sizeof (struct file_struct*)); + if (inc_recurse && dir_flist->used > dstart) { dir_flist->sorted = realloc_array(dir_flist->sorted, struct file_struct *, - dir_flist->count); + dir_flist->used); memcpy(dir_flist->sorted + dstart, dir_flist->files + dstart, - (dir_flist->count - dstart) * sizeof (struct file_struct*)); - fsort(dir_flist->sorted + dstart, dir_flist->count - dstart); + (dir_flist->used - dstart) * sizeof (struct file_struct*)); + fsort(dir_flist->sorted + dstart, dir_flist->used - dstart); } } else #endif { flist->sorted = flist->files; - if (inc_recurse && dir_flist->count > dstart) { + if (inc_recurse && dir_flist->used > dstart) { dir_flist->sorted = dir_flist->files; - fsort(dir_flist->sorted + dstart, dir_flist->count - dstart); + fsort(dir_flist->sorted + dstart, dir_flist->used - dstart); } } @@ -2032,7 +2033,7 @@ struct file_list *recv_file_list(int f) if (list_only) { int i; - for (i = 0; i < flist->count; i++) + for (i = flist->low; i <= flist->high; i++) list_file_entry(flist->files[i]); } @@ -2040,7 +2041,7 @@ struct file_list *recv_file_list(int f) rprintf(FINFO, "recv_file_list done\n"); stats.flist_size += stats.total_read - start_read; - stats.num_files += flist->count; + stats.num_files += flist->used; return flist; } @@ -2056,12 +2057,12 @@ void recv_additional_file_list(int f) change_local_filter_dir(NULL, 0, 0); } else { ndx = NDX_FLIST_OFFSET - ndx; - if (ndx < 0 || ndx >= dir_flist->count) { + if (ndx < 0 || ndx >= dir_flist->used) { ndx = NDX_FLIST_OFFSET - ndx; rprintf(FERROR, "[%s] Invalid dir index: %d (%d - %d)\n", who_am_i(), ndx, NDX_FLIST_OFFSET, - NDX_FLIST_OFFSET - dir_flist->count + 1); + NDX_FLIST_OFFSET - dir_flist->used + 1); exit_cleanup(RERR_PROTOCOL); } if (verbose > 3) { @@ -2168,7 +2169,7 @@ struct file_list *flist_new(int flags, char *msg) flist->file_pool = first_flist->file_pool; flist->ndx_start = first_flist->prev->ndx_start - + first_flist->prev->count; + + first_flist->prev->used; flist->prev = first_flist->prev; flist->prev->next = first_flist->prev = flist; @@ -2200,7 +2201,7 @@ void flist_free(struct file_list *flist) flist->next = first_flist; } flist->next->prev = flist->prev; - file_total -= flist->count; + file_total -= flist->used; flist_cnt--; } @@ -2224,15 +2225,16 @@ static void clean_flist(struct file_list *flist, int strip_root) if (!flist) return; - if (flist->count == 0) { + if (flist->used == 0) { flist->high = -1; + flist->low = 0; return; } - fsort(flist->sorted, flist->count); + fsort(flist->sorted, flist->used); if (!am_sender || inc_recurse) { - for (i = prev_i = 0; i < flist->count; i++) { + for (i = prev_i = 0; i < flist->used; i++) { if (F_IS_ACTIVE(flist->sorted[i])) { prev_i = i; break; @@ -2240,11 +2242,11 @@ static void clean_flist(struct file_list *flist, int strip_root) } flist->low = prev_i; } else { - i = prev_i = flist->count - 1; + i = prev_i = flist->used - 1; flist->low = 0; } - while (++i < flist->count) { + while (++i < flist->used) { int j; struct file_struct *file = flist->sorted[i]; @@ -2397,15 +2399,15 @@ static void output_flist(struct file_list *flist) int i; rprintf(FINFO, "[%s] flist start=%d, count=%d, low=%d, high=%d\n", - who, flist->ndx_start, flist->count, flist->low, flist->high); - for (i = 0; i < flist->count; i++) { + who, flist->ndx_start, flist->used, flist->low, flist->high); + for (i = 0; i < flist->used; i++) { file = flist->sorted[i]; - if ((am_root || am_sender) && preserve_uid) { + if ((am_root || am_sender) && uid_ndx) { snprintf(uidbuf, sizeof uidbuf, " uid=%u", F_OWNER(file)); } else *uidbuf = '\0'; - if (preserve_gid) { + if (gid_ndx) { static char parens[] = "(\0)\0\0\0"; char *pp = parens + (file->flags & FLAG_SKIP_GROUP ? 0 : 3); snprintf(gidbuf, sizeof gidbuf, " gid=%s%u%s", @@ -2629,7 +2631,7 @@ struct file_list *get_dirlist(char *dirname, int dlen, int ignore_filter_rules) xfer_dirs = save_xfer_dirs; recurse = save_recurse; if (do_progress) - flist_count_offset += dirlist->count; + flist_count_offset += dirlist->used; dirlist->sorted = dirlist->files; clean_flist(dirlist, 0);