verifier: correct a bug introduced in changeset [5106] that caused us to only verify...
authordavid-sarah <david-sarah@jacaranda.org>
Tue, 2 Aug 2011 17:24:37 +0000 (10:24 -0700)
committerdavid-sarah <david-sarah@jacaranda.org>
Tue, 2 Aug 2011 17:24:37 +0000 (10:24 -0700)
src/allmydata/immutable/checker.py

index 6731e94cbfb2b623cedb44423c86e06fbcf7129c..ad7931b9a865885578771a5ad45052b6c20911d5 100644 (file)
@@ -615,18 +615,21 @@ class Checker(log.PrefixingLogMixin):
             assert isinstance(r, str), r
             # to free up the RAM
             return None
+
         def _get_blocks(vrbp):
             def _get_block(ign, blocknum):
                 db = vrbp.get_block(blocknum)
                 db.addCallback(_discard_result)
                 return db
+
             dbs = defer.succeed(None)
             for blocknum in range(veup.num_segments):
                 dbs.addCallback(_get_block, blocknum)
-                # The Deferred we return will fire after every block of this
-                # share has been downloaded and verified successfully, or else it
-                # will errback as soon as the first error is observed.
-                return dbs
+
+            # The Deferred we return will fire after every block of this
+            # share has been downloaded and verified successfully, or else it
+            # will errback as soon as the first error is observed.
+            return dbs
 
         d.addCallback(_get_blocks)