@@ -399,11 +399,7 @@ def check_integrity(self, target_size=-1):
399399class TopdownDeltaChunkList (DeltaChunkList ):
400400 """Represents a list which is generated by feeding its ancestor streams one by
401401 one"""
402- __slots__ = ('frozen' , ) # if True, the list is frozen and can reproduce all data
403- # Will only be set in lists which where processed top-down
404-
405- def __init__ (self ):
406- self .frozen = False
402+ __slots__ = tuple ()
407403
408404 def connect_with_next_base (self , bdcl ):
409405 """Connect this chain with the next level of our base delta chunklist.
@@ -413,17 +409,10 @@ def connect_with_next_base(self, bdcl):
413409 :param bdcl: data chunk list being one of our bases. They must be fed in
414410 consequtively and in order, towards the earliest ancestor delta
415411 :return: True if processing was done. Use it to abort processing of
416- remaining streams"""
417- assert self is not bdcl
418- if self .frozen == 1 :
419- # Can that ever be hit ?
420- return False
421- # END early abort
422-
412+ remaining streams if False is returned"""
423413 nfc = 0 # number of frozen chunks
424414 dci = 0 # delta chunk index
425415 slen = len (self ) # len of self
426- sold = slen
427416 while dci < slen :
428417 dc = self [dci ]
429418 dci += 1
@@ -456,9 +445,6 @@ def connect_with_next_base(self, bdcl):
456445 cdc .to += ofs
457446 # END update target bounds
458447
459-
460- assert dc .to == ccl .lbound () and dc .rbound () == cdc .rbound ()
461-
462448 if len (ccl ) == 1 :
463449 self [dci - 1 ] = ccl [0 ]
464450 else :
@@ -476,14 +462,11 @@ def connect_with_next_base(self, bdcl):
476462 dci += len (ccl )- 1 # deleted dc, added rest
477463
478464 # END handle chunk replacement
479-
480465 # END for each chunk
481466
482467 if nfc == slen :
483- self .frozen = True
484468 return False
485469 # END handle completeness
486-
487470 return True
488471
489472
0 commit comments