Attachment 711660 Details for Bug 922576 – Patch against 0.6.18

[patch] Patch against 0.6.18

dup.18-corruption.patch (text/plain), 17.43 KB, created by Michael Terry on 2013-03-18 00:52:33 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Michael Terry

Created: 2013-03-18 00:52:33 UTC

Size: 17.43 KB

patch

obsolete

>=== modified file 'bin/duplicity'
>--- bin/duplicity	2012-02-29 13:35:03 +0000
>+++ bin/duplicity	2013-03-18 00:49:35 +0000
>@@ -221,7 +221,13 @@
>         # Just spin our wheels
>         while tarblock_iter.next():
>             if (tarblock_iter.previous_index == last_index):
>-                if (tarblock_iter.previous_block > last_block):
>+                # If both the previous index and this index are done, exit now
>+                # before we hit the next index, to prevent skipping its first
>+                # block.
>+                if not last_block and not tarblock_iter.previous_block:
>+                    break
>+                # Only check block number if last_block is also a number
>+                if last_block and tarblock_iter.previous_block > last_block:
>                     break
>             if tarblock_iter.previous_index > last_index:
>                 log.Warn(_("File %s complete in backup set.\n"
>@@ -923,11 +929,10 @@
>         """
>         Copy data from src_iter to file at fn
>         """
>-        block_size = 128 * 1024
>         file = open(filename, "wb")
>         while True:
>             try:
>-                data = src_iter.next(block_size).data
>+                data = src_iter.next().data
>             except StopIteration:
>                 break
>             file.write(data)
>@@ -975,9 +980,9 @@
>             def __init__(self, fileobj):
>                 self.fileobj = fileobj
> 
>-            def next(self, size):
>+            def next(self):
>                 try:
>-                    res = Block(self.fileobj.read(size))
>+                    res = Block(self.fileobj.read(self.get_read_size()))
>                 except Exception:
>                     if hasattr(self.fileobj, 'name'):
>                         name = self.fileobj.name
>@@ -991,6 +996,9 @@
>                     raise StopIteration
>                 return res
> 
>+            def get_read_size(self):
>+                return 128 * 1024
>+
>             def get_footer(self):
>                 return ""
> 
>
>=== modified file 'duplicity/diffdir.py'
>--- duplicity/diffdir.py	2011-10-05 14:27:04 +0000
>+++ duplicity/diffdir.py	2013-03-18 00:49:35 +0000
>@@ -479,14 +479,14 @@
>             filler_data = ""
>         return TarBlock(index, "%s%s%s" % (headers, file_data, filler_data))
> 
>-    def process(self, val, size):
>+    def process(self, val):
>         """
>         Turn next value of input_iter into a TarBlock
>         """
>         assert not self.process_waiting
>         XXX # Override in subclass @UndefinedVariable
> 
>-    def process_continued(self, size):
>+    def process_continued(self):
>         """
>         Get more tarblocks
> 
>@@ -496,15 +496,15 @@
>         assert self.process_waiting
>         XXX # Override in subclass @UndefinedVariable
> 
>-    def next(self, size = 1024 * 1024):
>+    def next(self):
>         """
>-        Return next block, no bigger than size, and update offset
>+        Return next block and update offset
>         """
>         if self.process_waiting:
>-            result = self.process_continued(size)
>+            result = self.process_continued()
>         else:
>             # Below a StopIteration exception will just be passed upwards
>-            result = self.process(self.input_iter.next(), size)
>+            result = self.process(self.input_iter.next())
>         block_number = self.process_next_vol_number
>         self.offset += len(result.data)
>         self.previous_index = result.index
>@@ -515,6 +515,13 @@
>             self.remember_next = False
>         return result
> 
>+    def get_read_size(self):
>+        # read size must always be the same, because if we are restarting a
>+        # backup volume where the previous volume ended in a data block, we
>+        # have to be able to assume it's length in order to continue reading
>+        # the file from the right place.
>+        return 64 * 1024
>+
>     def get_previous_index(self):
>         """
>         Return index of last tarblock, or None if no previous index
>@@ -551,7 +558,7 @@
>     """
>     TarBlockIter that does no file reading
>     """
>-    def process(self, delta_ropath, size):
>+    def process(self, delta_ropath):
>         """
>         Get a fake tarblock from delta_ropath
>         """
>@@ -575,13 +582,9 @@
>     """
>     TarBlockIter that yields blocks of a signature tar from path_iter
>     """
>-    def process(self, path, size):
>+    def process(self, path):
>         """
>         Return associated signature TarBlock from path
>-
>-        Here size is just ignored --- let's hope a signature isn't too
>-        big.  Also signatures are stored in multiple volumes so it
>-        doesn't matter.
>         """
>         ti = path.get_tarinfo()
>         if path.isreg():
>@@ -604,7 +607,7 @@
>     delta_path_iter, so the delta information has already been
>     calculated.
>     """
>-    def process(self, delta_ropath, size):
>+    def process(self, delta_ropath):
>         """
>         Get a tarblock from delta_ropath
>         """
>@@ -629,8 +632,7 @@
> 
>         # Now handle single volume block case
>         fp = delta_ropath.open("rb")
>-        # Below the 512 is the usual length of a tar header
>-        data, last_block = self.get_data_block(fp, size - 512)
>+        data, last_block = self.get_data_block(fp)
>         if stats:
>             stats.RawDeltaSize += len(data)
>         if last_block:
>@@ -652,11 +654,11 @@
>         self.process_next_vol_number = 2
>         return self.tarinfo2tarblock(index, ti, data)
> 
>-    def get_data_block(self, fp, max_size):
>+    def get_data_block(self, fp):
>         """
>         Return pair (next data block, boolean last data block)
>         """
>-        read_size = min(64*1024, max(max_size, 512))
>+        read_size = self.get_read_size()
>         buf = fp.read(read_size)
>         if len(buf) < read_size:
>             if fp.close():
>@@ -665,7 +667,7 @@
>         else:
>             return (buf, False)
> 
>-    def process_continued(self, size):
>+    def process_continued(self):
>         """
>         Return next volume in multivol diff or snapshot
>         """
>@@ -673,7 +675,7 @@
>         ropath = self.process_ropath
>         ti, index = ropath.get_tarinfo(), ropath.index
>         ti.name = "%s/%d" % (self.process_prefix, self.process_next_vol_number)
>-        data, last_block = self.get_data_block(self.process_fp, size - 512)
>+        data, last_block = self.get_data_block(self.process_fp)
>         if stats:
>             stats.RawDeltaSize += len(data)
>         if last_block:
>
>=== modified file 'duplicity/dup_temp.py'
>--- duplicity/dup_temp.py	2011-10-08 15:55:26 +0000
>+++ duplicity/dup_temp.py	2013-03-18 00:49:35 +0000
>@@ -253,9 +253,9 @@
>     def __init__(self, src):
>         self.src = src
>         self.fp = src.open("rb")
>-    def next(self, size):
>+    def next(self):
>         try:
>-            res = Block(self.fp.read(size))
>+            res = Block(self.fp.read(self.get_read_size()))
>         except Exception:
>             log.FatalError(_("Failed to read %s: %s") %
>                            (self.src.name, sys.exc_info()),
>@@ -264,5 +264,7 @@
>             self.fp.close()
>             raise StopIteration
>         return res
>+    def get_read_size(self):
>+        return 128 * 1024
>     def get_footer(self):
>         return ""
>
>=== modified file 'duplicity/gpg.py'
>--- duplicity/gpg.py	2011-10-05 14:22:43 +0000
>+++ duplicity/gpg.py	2013-03-18 00:49:35 +0000
>@@ -307,17 +307,16 @@
>     def get_current_size():
>         return os.stat(filename).st_size
> 
>-    block_size = 128 * 1024        # don't bother requesting blocks smaller, but also don't ask for bigger
>     target_size = size - 50 * 1024 # fudge factor, compensate for gpg buffering
>     data_size = target_size - max_footer_size
>     file = GPGFile(True, path.Path(filename), profile)
>     at_end_of_blockiter = 0
>     while True:
>         bytes_to_go = data_size - get_current_size()
>-        if bytes_to_go < block_size:
>+        if bytes_to_go < block_iter.get_read_size():
>             break
>         try:
>-            data = block_iter.next(min(block_size, bytes_to_go)).data
>+            data = block_iter.next().data
>         except StopIteration:
>             at_end_of_blockiter = 1
>             break
>@@ -366,10 +365,10 @@
>     at_end_of_blockiter = 0
>     while True:
>         bytes_to_go = size - file_counted.byte_count
>-        if bytes_to_go < 32 * 1024:
>+        if bytes_to_go < block_iter.get_read_size():
>             break
>         try:
>-            new_block = block_iter.next(min(128*1024, bytes_to_go))
>+            new_block = block_iter.next()
>         except StopIteration:
>             at_end_of_blockiter = 1
>             break
>
>=== modified file 'testing/gnupg/trustdb.gpg'
>Binary files testing/gnupg/trustdb.gpg	2011-11-04 12:48:04 +0000 and testing/gnupg/trustdb.gpg	2013-03-18 00:50:08 +0000 differ
>=== modified file 'testing/tests/gpgtest.py'
>--- testing/tests/gpgtest.py	2011-11-04 12:48:04 +0000
>+++ testing/tests/gpgtest.py	2013-03-18 00:49:35 +0000
>@@ -134,7 +134,7 @@
>             #print os.stat("testfiles/output/gzwrite.gz").st_size-size
>             assert size - 64 * 1024 <= os.stat("testfiles/output/gzwrite.gz").st_size <= size + 64 * 1024
>         gwfh.set_at_end()
>-        gpg.GzipWriteFile(gwfh, "testfiles/output/gzwrite.gpg", size = size)
>+        gpg.GzipWriteFile(gwfh, "testfiles/output/gzwrite.gz", size = size)
>         #print os.stat("testfiles/output/gzwrite.gz").st_size
> 
> 
>@@ -157,13 +157,18 @@
>         s2 = size - s1
>         return "a"*s1 + self.from_random_fp.read(s2)
> 
>-    def next(self, size):
>+    def next(self):
>         if self.at_end: raise StopIteration
>-        if random.randrange(2): real_size = size
>-        else: real_size = random.randrange(0, size)
>-        block_data = self.get_buffer(real_size)
>+        block_data = self.get_buffer(self.get_read_size())
>         return GPGWriteHelper2(block_data)
> 
>+    def get_read_size(self):
>+        size = 64 * 1024
>+        if random.randrange(2):
>+            return size
>+        else:
>+            return random.randrange(0, size)
>+
>     def get_footer(self):
>         return "e" * random.randrange(0, 15000)
> 
>
>=== modified file 'testing/tests/restarttest.py'
>--- testing/tests/restarttest.py	2011-12-18 12:49:41 +0000
>+++ testing/tests/restarttest.py	2013-03-18 00:49:35 +0000
>@@ -21,6 +21,7 @@
> 
> import helper
> import sys, os, unittest
>+import glob
> 
> import duplicity.backend
> from duplicity import path
>@@ -34,7 +35,6 @@
> other_args = ["-v0", "--no-print-statistics"]
> #other_args = ["--short-filenames"]
> #other_args = ["--ssh-command 'ssh -v'", "--scp-command 'scp -C'"]
>-#other_args = ['--no-encryption']
> 
> # If this is set to true, after each backup, verify contents
> verify = 1
>@@ -48,6 +48,7 @@
>     Test checkpoint/restart using duplicity binary
>     """
>     def setUp(self):
>+        self.class_args = []
>         assert not os.system("tar xzf testfiles.tar.gz > /dev/null 2>&1")
> 
>     def tearDown(self):
>@@ -64,6 +65,7 @@
>             cmd_list.append("--current-time %s" % (current_time,))
>         if other_args:
>             cmd_list.extend(other_args)
>+        cmd_list.extend(self.class_args)
>         cmd_list.extend(arglist)
>         cmdline = " ".join(cmd_list)
>         #print "Running '%s'." % cmdline
>@@ -290,5 +292,130 @@
>         self.backup("inc", "testfiles/largefiles")
>         self.verify("testfiles/largefiles")
> 
>+    def make_fake_second_volume(self, name):
>+        """
>+        Takes a successful backup and pretend that we interrupted a backup
>+        after two-volumes.  (This is because we want to be able to model
>+        restarting the second volume and duplicity deletes the last volume
>+        found because it may have not finished uploading.)
>+        """
>+        # First, confirm that we have signs of a successful backup
>+        self.assertEqual(len(glob.glob("testfiles/output/*.manifest*")), 1)
>+        self.assertEqual(len(glob.glob("testfiles/output/*.sigtar*")), 1)
>+        self.assertEqual(len(glob.glob("testfiles/cache/%s/*" % name)), 2)
>+        self.assertEqual(len(glob.glob(
>+            "testfiles/cache/%s/*.manifest*" % name)), 1)
>+        self.assertEqual(len(glob.glob(
>+            "testfiles/cache/%s/*.sigtar*" % name)), 1)
>+        # Alright, everything is in order; fake a second interrupted volume
>+        assert not os.system("rm testfiles/output/*.manifest*")
>+        assert not os.system("rm testfiles/output/*.sigtar*")
>+        assert not os.system("rm -f testfiles/output/*.vol[23456789].*")
>+        assert not os.system("rm -f testfiles/output/*.vol1[^.]+.*")
>+        self.assertEqual(len(glob.glob("testfiles/output/*.difftar*")), 1)
>+        assert not os.system("rm testfiles/cache/%s/*.sigtar*" % name)
>+        assert not os.system("cp testfiles/output/*.difftar* "
>+                             "`ls testfiles/output/*.difftar* | "
>+                             " sed 's|vol1|vol2|'`")
>+        assert not os.system("head -n6 testfiles/cache/%s/*.manifest > "
>+                             "testfiles/cache/%s/"
>+                             "`basename testfiles/cache/%s/*.manifest`"
>+                             ".part" % (name, name, name))
>+        assert not os.system("rm testfiles/cache/%s/*.manifest" % name)
>+        assert not os.system("""echo 'Volume 2:
>+    StartingPath   foo  
>+    EndingPath     bar  
>+    Hash SHA1 sha1' >> testfiles/cache/%s/*.manifest.part""" % name)
>+
>+    def test_split_after_small(self):
>+        """
>+        If we restart right after a volume that ended with a small
>+        (one-block) file, make sure we restart in the right place.
>+        """
>+        source = 'testfiles/largefiles'
>+        assert not os.system("mkdir -p %s" % source)
>+        assert not os.system("echo hello > %s/file1" % source)
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Fake an interruption
>+        self.make_fake_second_volume("backup1")
>+        # Add new small file
>+        assert not os.system("echo hello > %s/newfile" % source)
>+        # 'restart' the backup
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Confirm we actually resumed the previous backup
>+        self.assertEqual(len(os.listdir("testfiles/output")), 4)
>+        # Now make sure everything is byte-for-byte the same once restored
>+        self.restore()
>+        assert not os.system("diff -r %s testfiles/restore_out" % source)
>+
>+    def test_split_after_large(self):
>+        """
>+        If we restart right after a volume that ended with a large
>+        (multi-block) file, make sure we restart in the right place.
>+        """
>+        source = 'testfiles/largefiles'
>+        assert not os.system("mkdir -p %s" % source)
>+        assert not os.system("dd if=/dev/urandom of=%s/file1 bs=1024 count=1024 > /dev/null 2>&1" % source)
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Fake an interruption
>+        self.make_fake_second_volume("backup1")
>+        # Add new small file
>+        assert not os.system("echo hello > %s/newfile" % source)
>+        # 'restart' the backup
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Confirm we actually resumed the previous backup
>+        self.assertEqual(len(os.listdir("testfiles/output")), 4)
>+        # Now make sure everything is byte-for-byte the same once restored
>+        self.restore()
>+        assert not os.system("diff -r %s testfiles/restore_out" % source)
>+
>+    def test_split_inside_large(self):
>+        """
>+        If we restart right after a volume that ended inside of a large
>+        (multi-block) file, make sure we restart in the right place.
>+        """
>+        source = 'testfiles/largefiles'
>+        assert not os.system("mkdir -p %s" % source)
>+        assert not os.system("dd if=/dev/urandom of=%s/file1 bs=1024 count=3072 > /dev/null 2>&1" % source)
>+        self.backup("full", source, options=["--vols 1", "--name=backup1"])
>+        # Fake an interruption
>+        self.make_fake_second_volume("backup1")
>+        # 'restart' the backup
>+        self.backup("full", source, options=["--vols 1", "--name=backup1"])
>+        # Now make sure everything is byte-for-byte the same once restored
>+        self.restore()
>+        assert not os.system("diff -r %s testfiles/restore_out" % source)
>+
>+    def test_new_file(self):
>+        """
>+        If we restart right after a volume, but there are new files that would
>+        have been backed up earlier in the volume, make sure we don't wig out.
>+        (Expected result is to ignore new, ealier files, but pick up later
>+        ones.)
>+        """
>+        source = 'testfiles/largefiles'
>+        assert not os.system("mkdir -p %s" % source)
>+        assert not os.system("dd if=/dev/urandom of=%s/file1 bs=1024 count=1024 > /dev/null 2>&1" % source)
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Fake an interruption
>+        self.make_fake_second_volume("backup1")
>+        # Add new files, earlier and later in filename sort order
>+        assert not os.system("echo hello > %s/a" % source)
>+        assert not os.system("echo hello > %s/z" % source)
>+        # 'restart' the backup
>+        self.backup("full", source, options=["--name=backup1"])
>+        # Now make sure everything is the same once restored, except 'a'
>+        self.restore()
>+        assert not os.system("test ! -e testfiles/restore_out/a")
>+        assert not os.system("diff %s/file1 testfiles/restore_out/file1" % source)
>+        assert not os.system("diff %s/z testfiles/restore_out/z" % source)
>+
>+
>+# Note that this class duplicates all the tests in RestartTest
>+class RestartTestWithoutEncryption(RestartTest):
>+    def setUp(self):
>+        RestartTest.setUp(self)
>+        self.class_args.extend(["--no-encryption"])
>+
> if __name__ == "__main__":
>     unittest.main()
>

Actions: View | Diff

Attachments on bug 922576: 711658 | 711659 | 711660