diff options
Diffstat (limited to 'rdiff-backup/rdiff_backup/backup.py')
-rw-r--r-- | rdiff-backup/rdiff_backup/backup.py | 20 |
1 files changed, 17 insertions, 3 deletions
diff --git a/rdiff-backup/rdiff_backup/backup.py b/rdiff-backup/rdiff_backup/backup.py index 0c66ca0..c905cfe 100644 --- a/rdiff-backup/rdiff_backup/backup.py +++ b/rdiff-backup/rdiff_backup/backup.py @@ -149,7 +149,7 @@ class DestinationStruct: dest_iter = cls.get_dest_select(baserp, for_increment) collated = rorpiter.Collate2Iters(source_iter, dest_iter) cls.CCPP = CacheCollatedPostProcess( - collated, Globals.pipeline_max_length*4) + collated, Globals.pipeline_max_length*4, baserp) # pipeline len adds some leeway over just*3 (to and from and back) def get_sigs(cls, dest_base_rpath): @@ -232,7 +232,7 @@ static.MakeClass(DestinationStruct) class CacheCollatedPostProcess: - """Cache a collated iter of (source_rorp, dest_rp) pairs + """Cache a collated iter of (source_rorp, dest_rorp) pairs This is necessary for two reasons: @@ -254,10 +254,12 @@ class CacheCollatedPostProcess: metadata for it. """ - def __init__(self, collated_iter, cache_size): + def __init__(self, collated_iter, cache_size, dest_root_rp): """Initialize new CCWP.""" self.iter = collated_iter # generates (source_rorp, dest_rorp) pairs self.cache_size = cache_size + self.dest_root_rp = dest_root_rp + self.statfileobj = statistics.init_statfileobj() if Globals.file_statistics: statistics.FileStats.init() metadata.MetadataFile.open_file() @@ -302,6 +304,10 @@ class CacheCollatedPostProcess: """ if source_rorp: Hardlink.add_rorp(source_rorp, source = 1) if dest_rorp: Hardlink.add_rorp(dest_rorp, source = 0) + if (dest_rorp and dest_rorp.isdir() and Globals.process_uid != 0 and + dest_rorp.getperms() % 01000 < 0700): + dest_rp = self.dest_root_rp.new_index(dest_rorp.index) + dest_rp.chmod(0700 | dest_rorp.getperms()) def shorten_cache(self): """Remove one element from cache, possibly adding it to metadata""" @@ -346,6 +352,13 @@ class CacheCollatedPostProcess: if Globals.file_statistics: statistics.FileStats.update(source_rorp, dest_rorp, changed, inc) + # Update permissions of unreadable directory + if (source_rorp and source_rorp.isdir() and Globals.process_uid != 0 + and success and source_rorp.getperms() % 01000 < 0700): + dest_rp = self.dest_root_rp.new_index(source_rorp.index) + assert dest_rp.isdir(), dest_rp + dest_rp.chmod(source_rorp.getperms()) + def in_cache(self, index): """Return true if given index is cached""" return self.cache_dict.has_key(index) @@ -596,3 +609,4 @@ class IncrementITRB(PatchITRB): self.CCPP.set_inc(index, inc) self.CCPP.flag_success(index) + |