[BACK]Return to hlink.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / rsync

Diff for /embedaddon/rsync/hlink.c between versions 1.1.1.1 and 1.1.1.2

version 1.1.1.1, 2012/02/17 15:09:30 version 1.1.1.2, 2013/10/14 07:51:14
Line 4 Line 4
  * Copyright (C) 1996 Andrew Tridgell   * Copyright (C) 1996 Andrew Tridgell
  * Copyright (C) 1996 Paul Mackerras   * Copyright (C) 1996 Paul Mackerras
  * Copyright (C) 2002 Martin Pool <mbp@samba.org>   * Copyright (C) 2002 Martin Pool <mbp@samba.org>
 * Copyright (C) 2004-2009 Wayne Davison * Copyright (C) 2004-2013 Wayne Davison
  *   *
  * This program is free software; you can redistribute it and/or modify   * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by   * it under the terms of the GNU General Public License as published by
Line 21 Line 21
  */   */
   
 #include "rsync.h"  #include "rsync.h"
   #include "inums.h"
   #include "ifuncs.h"
   
 extern int verbose;  
 extern int dry_run;  extern int dry_run;
 extern int list_only;  extern int list_only;
 extern int am_sender;  extern int am_sender;
Line 31  extern int do_xfers; Line 32  extern int do_xfers;
 extern int link_dest;  extern int link_dest;
 extern int preserve_acls;  extern int preserve_acls;
 extern int preserve_xattrs;  extern int preserve_xattrs;
 extern int make_backups;  
 extern int protocol_version;  extern int protocol_version;
 extern int remove_source_files;  extern int remove_source_files;
 extern int stdout_format_has_i;  extern int stdout_format_has_i;
Line 71  struct ht_int64_node *idev_find(int64 dev, int64 ino) Line 71  struct ht_int64_node *idev_find(int64 dev, int64 ino)
         if (!dev_node || dev_node->key != dev+1) {          if (!dev_node || dev_node->key != dev+1) {
                 /* We keep a separate hash table of inodes for every device. */                  /* We keep a separate hash table of inodes for every device. */
                 dev_node = hashtable_find(dev_tbl, dev+1, 1);                  dev_node = hashtable_find(dev_tbl, dev+1, 1);
                if (!(tbl = dev_node->data))                if (!(tbl = dev_node->data)) {
                         tbl = dev_node->data = hashtable_create(512, 1);                          tbl = dev_node->data = hashtable_create(512, 1);
                           if (DEBUG_GTE(HLINK, 3)) {
                                   rprintf(FINFO,
                                       "[%s] created hashtable for dev %s\n",
                                       who_am_i(), big_num(dev));
                           }
                   }
         } else          } else
                 tbl = dev_node->data;                  tbl = dev_node->data;
   
Line 206  void match_hard_links(struct file_list *flist) Line 212  void match_hard_links(struct file_list *flist)
 }  }
   
 static int maybe_hard_link(struct file_struct *file, int ndx,  static int maybe_hard_link(struct file_struct *file, int ndx,
                           const char *fname, int statret, stat_x *sxp,                           char *fname, int statret, stat_x *sxp,
                            const char *oldname, STRUCT_STAT *old_stp,                             const char *oldname, STRUCT_STAT *old_stp,
                            const char *realname, int itemizing, enum logcode code)                             const char *realname, int itemizing, enum logcode code)
 {  {
Line 218  static int maybe_hard_link(struct file_struct *file, i Line 224  static int maybe_hard_link(struct file_struct *file, i
                                         ITEM_LOCAL_CHANGE | ITEM_XNAME_FOLLOWS,                                          ITEM_LOCAL_CHANGE | ITEM_XNAME_FOLLOWS,
                                         0, "");                                          0, "");
                         }                          }
                        if (verbose > 1 && maybe_ATTRS_REPORT)                        if (INFO_GTE(NAME, 2) && maybe_ATTRS_REPORT)
                                 rprintf(FCLIENT, "%s is uptodate\n", fname);                                  rprintf(FCLIENT, "%s is uptodate\n", fname);
                         file->flags |= FLAG_HLINK_DONE;                          file->flags |= FLAG_HLINK_DONE;
                         return 0;                          return 0;
                 }                  }
                 if (make_backups > 0) {  
                         if (!make_backup(fname))  
                                 return -1;  
                 } else if (robust_unlink(fname)) {  
                         rsyserr(FERROR_XFER, errno, "unlink %s failed",  
                                 full_fname(fname));  
                         return -1;  
                 }  
         }          }
   
        if (hard_link_one(file, fname, oldname, 0)) {        if (atomic_create(file, fname, oldname, MAKEDEV(0, 0), sxp, statret == 0 ? DEL_FOR_FILE : 0)) {
                 if (itemizing) {                  if (itemizing) {
                         itemize(fname, file, ndx, statret, sxp,                          itemize(fname, file, ndx, statret, sxp,
                                 ITEM_LOCAL_CHANGE | ITEM_XNAME_FOLLOWS, 0,                                  ITEM_LOCAL_CHANGE | ITEM_XNAME_FOLLOWS, 0,
                                 realname);                                  realname);
                 }                  }
                if (code != FNONE && verbose)                if (code != FNONE && INFO_GTE(NAME, 1))
                         rprintf(code, "%s => %s\n", fname, realname);                          rprintf(code, "%s => %s\n", fname, realname);
                 return 0;                  return 0;
         }          }
   
         return -1;          return -1;
 }  }
   
Line 288  static char *check_prior(struct file_struct *file, int Line 287  static char *check_prior(struct file_struct *file, int
   
 /* Only called if FLAG_HLINKED is set and FLAG_HLINK_FIRST is not.  Returns:  /* Only called if FLAG_HLINKED is set and FLAG_HLINK_FIRST is not.  Returns:
  * 0 = process the file, 1 = skip the file, -1 = error occurred. */   * 0 = process the file, 1 = skip the file, -1 = error occurred. */
int hard_link_check(struct file_struct *file, int ndx, const char *fname,int hard_link_check(struct file_struct *file, int ndx, char *fname,
                     int statret, stat_x *sxp, int itemizing,                      int statret, stat_x *sxp, int itemizing,
                     enum logcode code)                      enum logcode code)
 {  {
Line 307  int hard_link_check(struct file_struct *file, int ndx, Line 306  int hard_link_check(struct file_struct *file, int ndx,
                 if (!flist) {                  if (!flist) {
                         /* The previous file was skipped, so this one is                          /* The previous file was skipped, so this one is
                          * treated as if it were the first in its group. */                           * treated as if it were the first in its group. */
                           if (DEBUG_GTE(HLINK, 2)) {
                                   rprintf(FINFO, "hlink for %d (%s,%d): virtual first\n",
                                           ndx, f_name(file, NULL), gnum);
                           }
                         return 0;                          return 0;
                 }                  }
   
Line 323  int hard_link_check(struct file_struct *file, int ndx, Line 326  int hard_link_check(struct file_struct *file, int ndx,
                                 F_HL_PREV(prev_file) = ndx;                                  F_HL_PREV(prev_file) = ndx;
                                 file->flags |= FLAG_FILE_SENT;                                  file->flags |= FLAG_FILE_SENT;
                                 cur_flist->in_progress++;                                  cur_flist->in_progress++;
                                   if (DEBUG_GTE(HLINK, 2)) {
                                           rprintf(FINFO, "hlink for %d (%s,%d): waiting for %d\n",
                                                   ndx, f_name(file, NULL), gnum, F_HL_PREV(file));
                                   }
                                 return 1;                                  return 1;
                         }                          }
                           if (DEBUG_GTE(HLINK, 2)) {
                                   rprintf(FINFO, "hlink for %d (%s,%d): looking for a leader\n",
                                           ndx, f_name(file, NULL), gnum);
                           }
                         return 0;                          return 0;
                 }                  }
   
Line 332  int hard_link_check(struct file_struct *file, int ndx, Line 343  int hard_link_check(struct file_struct *file, int ndx,
                 if (!(prev_file->flags & FLAG_HLINK_FIRST)) {                  if (!(prev_file->flags & FLAG_HLINK_FIRST)) {
                         /* The previous previous is FIRST when prev is not. */                          /* The previous previous is FIRST when prev is not. */
                         prev_name = realname = check_prior(prev_file, gnum, &prev_ndx, &flist);                          prev_name = realname = check_prior(prev_file, gnum, &prev_ndx, &flist);
                         assert(prev_name != NULL || flist != NULL);  
                         /* Update our previous pointer to point to the FIRST. */                          /* Update our previous pointer to point to the FIRST. */
                         F_HL_PREV(file) = prev_ndx;                          F_HL_PREV(file) = prev_ndx;
                 }                  }
Line 340  int hard_link_check(struct file_struct *file, int ndx, Line 350  int hard_link_check(struct file_struct *file, int ndx,
                 if (!prev_name) {                  if (!prev_name) {
                         int alt_dest;                          int alt_dest;
   
                           assert(flist != NULL);
                         prev_file = flist->files[prev_ndx - flist->ndx_start];                          prev_file = flist->files[prev_ndx - flist->ndx_start];
                         /* F_HL_PREV() is alt_dest value when DONE && FIRST. */                          /* F_HL_PREV() is alt_dest value when DONE && FIRST. */
                         alt_dest = F_HL_PREV(prev_file);                          alt_dest = F_HL_PREV(prev_file);
                           if (DEBUG_GTE(HLINK, 2)) {
                                   rprintf(FINFO, "hlink for %d (%s,%d): found flist match (alt %d)\n",
                                           ndx, f_name(file, NULL), gnum, alt_dest);
                           }
   
                         if (alt_dest >= 0 && dry_run) {                          if (alt_dest >= 0 && dry_run) {
                                 pathjoin(namebuf, MAXPATHLEN, basis_dir[alt_dest],                                  pathjoin(namebuf, MAXPATHLEN, basis_dir[alt_dest],
Line 356  int hard_link_check(struct file_struct *file, int ndx, Line 371  int hard_link_check(struct file_struct *file, int ndx,
                 }                  }
         }          }
   
           if (DEBUG_GTE(HLINK, 2)) {
                   rprintf(FINFO, "hlink for %d (%s,%d): leader is %d (%s)\n",
                           ndx, f_name(file, NULL), gnum, prev_ndx, prev_name);
           }
   
         if (link_stat(prev_name, &prev_st, 0) < 0) {          if (link_stat(prev_name, &prev_st, 0) < 0) {
                 if (!dry_run || errno != ENOENT) {                  if (!dry_run || errno != ENOENT) {
                         rsyserr(FERROR_XFER, errno, "stat %s failed", full_fname(prev_name));                          rsyserr(FERROR_XFER, errno, "stat %s failed", full_fname(prev_name));
Line 371  int hard_link_check(struct file_struct *file, int ndx, Line 391  int hard_link_check(struct file_struct *file, int ndx,
                 char cmpbuf[MAXPATHLEN];                  char cmpbuf[MAXPATHLEN];
                 stat_x alt_sx;                  stat_x alt_sx;
                 int j = 0;                  int j = 0;
#ifdef SUPPORT_ACLS                init_stat_x(&alt_sx);
                alt_sx.acc_acl = alt_sx.def_acl = NULL; 
#endif 
#ifdef SUPPORT_XATTRS 
                alt_sx.xattr = NULL; 
#endif 
                 do {                  do {
                         pathjoin(cmpbuf, MAXPATHLEN, basis_dir[j], fname);                          pathjoin(cmpbuf, MAXPATHLEN, basis_dir[j], fname);
                         if (link_stat(cmpbuf, &alt_sx.st, 0) < 0)                          if (link_stat(cmpbuf, &alt_sx.st, 0) < 0)
Line 387  int hard_link_check(struct file_struct *file, int ndx, Line 402  int hard_link_check(struct file_struct *file, int ndx,
                                         continue;                                          continue;
                                 statret = 1;                                  statret = 1;
                                 if (stdout_format_has_i == 0                                  if (stdout_format_has_i == 0
                                 || (verbose < 2 && stdout_format_has_i < 2)) {                                 || (!INFO_GTE(NAME, 2) && stdout_format_has_i < 2)) {
                                         itemizing = 0;                                          itemizing = 0;
                                         code = FNONE;                                          code = FNONE;
                                        if (verbose > 1 && maybe_ATTRS_REPORT)                                        if (INFO_GTE(NAME, 2) && maybe_ATTRS_REPORT)
                                                 rprintf(FCLIENT, "%s is uptodate\n", fname);                                                  rprintf(FCLIENT, "%s is uptodate\n", fname);
                                 }                                  }
                                 break;                                  break;
Line 426  int hard_link_check(struct file_struct *file, int ndx, Line 441  int hard_link_check(struct file_struct *file, int ndx,
                                 }                                  }
                         }                          }
 #endif  #endif
                } else {                } else
#ifdef SUPPORT_ACLS                        free_stat_x(&alt_sx);
                        if (preserve_acls) 
                                free_acl(&alt_sx); 
#endif 
#ifdef SUPPORT_XATTRS 
                        if (preserve_xattrs) 
                                free_xattr(&alt_sx); 
#endif 
                } 
         }          }
   
         if (maybe_hard_link(file, ndx, fname, statret, sxp, prev_name, &prev_st,          if (maybe_hard_link(file, ndx, fname, statret, sxp, prev_name, &prev_st,
Line 454  int hard_link_one(struct file_struct *file, const char Line 461  int hard_link_one(struct file_struct *file, const char
         if (do_link(oldname, fname) < 0) {          if (do_link(oldname, fname) < 0) {
                 enum logcode code;                  enum logcode code;
                 if (terse) {                  if (terse) {
                        if (!verbose)                        if (!INFO_GTE(NAME, 1))
                                 return 0;                                  return 0;
                         code = FINFO;                          code = FINFO;
                 } else                  } else
Line 481  void finish_hard_link(struct file_struct *file, const  Line 488  void finish_hard_link(struct file_struct *file, const 
         int prev_statret, ndx, prev_ndx = F_HL_PREV(file);          int prev_statret, ndx, prev_ndx = F_HL_PREV(file);
   
         if (stp == NULL && prev_ndx >= 0) {          if (stp == NULL && prev_ndx >= 0) {
                if (link_stat(fname, &st, 0) < 0) {                if (link_stat(fname, &st, 0) < 0 && !dry_run) {
                         rsyserr(FERROR_XFER, errno, "stat %s failed",                          rsyserr(FERROR_XFER, errno, "stat %s failed",
                                 full_fname(fname));                                  full_fname(fname));
                         return;                          return;
Line 499  void finish_hard_link(struct file_struct *file, const  Line 506  void finish_hard_link(struct file_struct *file, const 
         } else          } else
                 our_name = fname;                  our_name = fname;
   
#ifdef SUPPORT_ACLS        init_stat_x(&prev_sx);
        prev_sx.acc_acl = prev_sx.def_acl = NULL; 
#endif 
#ifdef SUPPORT_XATTRS 
        prev_sx.xattr = NULL; 
#endif 
   
         while ((ndx = prev_ndx) >= 0) {          while ((ndx = prev_ndx) >= 0) {
                 int val;                  int val;
Line 517  void finish_hard_link(struct file_struct *file, const  Line 519  void finish_hard_link(struct file_struct *file, const 
                 val = maybe_hard_link(file, ndx, prev_name, prev_statret, &prev_sx,                  val = maybe_hard_link(file, ndx, prev_name, prev_statret, &prev_sx,
                                       our_name, stp, fname, itemizing, code);                                        our_name, stp, fname, itemizing, code);
                 flist->in_progress--;                  flist->in_progress--;
#ifdef SUPPORT_ACLS                free_stat_x(&prev_sx);
                if (preserve_acls) 
                        free_acl(&prev_sx); 
#endif 
#ifdef SUPPORT_XATTRS 
                if (preserve_xattrs) 
                        free_xattr(&prev_sx); 
#endif 
                 if (val < 0)                  if (val < 0)
                         continue;                          continue;
                 if (remove_source_files == 1 && do_xfers)                  if (remove_source_files == 1 && do_xfers)
Removed from v.1.1.1.1  
changed lines
  Added in v.1.1.1.2

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>