##// END OF EJS Templates
delta-chain: extract some debugdeltachain logic is object...
marmoute -
r51964:793a058f default
parent child Browse files
Show More
@@ -712,21 +712,17 b' def debug_revlog_stats('
712 712 fm.plain(b'\n')
713 713
714 714
715 def debug_delta_chain(revlog):
716 r = revlog
717 index = r.index
718 start = r.start
719 length = r.length
720 generaldelta = r.delta_config.general_delta
721 withsparseread = r.data_config.with_sparse_read
715 class DeltaChainAuditor:
716 def __init__(self, revlog):
717 self._revlog = revlog
718 self._index = self._revlog.index
719 self._generaldelta = revlog.delta_config.general_delta
720 self._chain_size_cache = {}
721 # security to avoid crash on corrupted revlogs
722 self._total_revs = len(self._index)
722 723
723 # security to avoid crash on corrupted revlogs
724 total_revs = len(index)
725
726 chain_size_cache = {}
727
728 def revinfo(rev):
729 e = index[rev]
724 def revinfo(self, rev):
725 e = self._index[rev]
730 726 compsize = e[constants.ENTRY_DATA_COMPRESSED_LENGTH]
731 727 uncompsize = e[constants.ENTRY_DATA_UNCOMPRESSED_LENGTH]
732 728
@@ -742,33 +738,33 b' def debug_delta_chain(revlog):'
742 738 # However we need to detect that as a special case for delta-type, that
743 739 # is not simply "other".
744 740 p1_base = p1
745 if p1 != nodemod.nullrev and p1 < total_revs:
746 e1 = index[p1]
741 if p1 != nodemod.nullrev and p1 < self._total_revs:
742 e1 = self._index[p1]
747 743 while e1[constants.ENTRY_DATA_COMPRESSED_LENGTH] == 0:
748 744 new_base = e1[constants.ENTRY_DELTA_BASE]
749 745 if (
750 746 new_base == p1_base
751 747 or new_base == nodemod.nullrev
752 or new_base >= total_revs
748 or new_base >= self._total_revs
753 749 ):
754 750 break
755 751 p1_base = new_base
756 e1 = index[p1_base]
752 e1 = self._index[p1_base]
757 753 p2_base = p2
758 if p2 != nodemod.nullrev and p2 < total_revs:
759 e2 = index[p2]
754 if p2 != nodemod.nullrev and p2 < self._total_revs:
755 e2 = self._index[p2]
760 756 while e2[constants.ENTRY_DATA_COMPRESSED_LENGTH] == 0:
761 757 new_base = e2[constants.ENTRY_DELTA_BASE]
762 758 if (
763 759 new_base == p2_base
764 760 or new_base == nodemod.nullrev
765 or new_base >= total_revs
761 or new_base >= self._total_revs
766 762 ):
767 763 break
768 764 p2_base = new_base
769 e2 = index[p2_base]
765 e2 = self._index[p2_base]
770 766
771 if generaldelta:
767 if self._generaldelta:
772 768 if base == p1:
773 769 deltatype = b'p1'
774 770 elif base == p2:
@@ -779,7 +775,7 b' def debug_delta_chain(revlog):'
779 775 deltatype = b'skip1'
780 776 elif base == p2_base:
781 777 deltatype = b'skip2'
782 elif r.issnapshot(rev):
778 elif self._revlog.issnapshot(rev):
783 779 deltatype = b'snap'
784 780 elif base == rev - 1:
785 781 deltatype = b'prev'
@@ -791,19 +787,27 b' def debug_delta_chain(revlog):'
791 787 else:
792 788 deltatype = b'prev'
793 789
794 chain = r._deltachain(rev)[0]
790 chain = self._revlog._deltachain(rev)[0]
795 791 chain_size = 0
796 792 for iter_rev in reversed(chain):
797 cached = chain_size_cache.get(iter_rev)
793 cached = self._chain_size_cache.get(iter_rev)
798 794 if cached is not None:
799 795 chain_size += cached
800 796 break
801 e = index[iter_rev]
797 e = self._index[iter_rev]
802 798 chain_size += e[constants.ENTRY_DATA_COMPRESSED_LENGTH]
803 chain_size_cache[rev] = chain_size
799 self._chain_size_cache[rev] = chain_size
804 800
805 801 return p1, p2, compsize, uncompsize, deltatype, chain, chain_size
806 802
803
804 def debug_delta_chain(revlog):
805 auditor = DeltaChainAuditor(revlog)
806 r = revlog
807 start = r.start
808 length = r.length
809 withsparseread = revlog.data_config.with_sparse_read
810
807 811 header = (
808 812 b' rev p1 p2 chain# chainlen prev delta '
809 813 b'size rawsize chainsize ratio lindist extradist '
@@ -816,7 +820,7 b' def debug_delta_chain(revlog):'
816 820
817 821 chainbases = {}
818 822 for rev in r:
819 p1, p2, comp, uncomp, deltatype, chain, chainsize = revinfo(rev)
823 p1, p2, comp, uncomp, deltatype, chain, chainsize = auditor.revinfo(rev)
820 824 chainbase = chain[0]
821 825 chainid = chainbases.setdefault(chainbase, len(chainbases) + 1)
822 826 basestart = start(chainbase)
General Comments 0
You need to be logged in to leave comments. Login now