comparison mercurial/revlogutils/deltas.py @ 49768:bcae90c53def

delta-find: add a delta-reuse policy that blindly accepts incoming deltas

When this policy is set, incoming deltas are blindly accepted without regard
for the validity of the chain they build.

49767:f1887500f3ec

from .constants import (
    COMP_MODE_DEFAULT,
    COMP_MODE_INLINE,
    COMP_MODE_PLAIN,
    DELTA_BASE_REUSE_NO,
    KIND_CHANGELOG,
    KIND_FILELOG,
    KIND_MANIFESTLOG,
    REVIDX_ISCENSORED,

    """Returns True if the given delta is good. Good means that it is within
    the disk span, disk size, and chain length bounds that we know to be
    performant."""
    if deltainfo is None:
        return False

    # - 'deltainfo.distance' is the distance from the base revision --
    #   bounding it limits the amount of I/O we need to do.
    # - 'deltainfo.compresseddeltalen' is the sum of the total size of
    #   deltas we need to apply -- bounding it limits the amount of CPU

            if rev == nullrev:
                continue
            # filter out revision we tested already
            if rev in tested:
                continue
            # an higher authority deamed the base unworthy (e.g. censored)
            if excluded_bases is not None and rev in excluded_bases:
                tested.add(rev)
                continue
            # We are in some recomputation cases and that rev is too high in

49768:bcae90c53def

from .constants import (
    COMP_MODE_DEFAULT,
    COMP_MODE_INLINE,
    COMP_MODE_PLAIN,
    DELTA_BASE_REUSE_FORCE,
    DELTA_BASE_REUSE_NO,
    KIND_CHANGELOG,
    KIND_FILELOG,
    KIND_MANIFESTLOG,
    REVIDX_ISCENSORED,

    """Returns True if the given delta is good. Good means that it is within
    the disk span, disk size, and chain length bounds that we know to be
    performant."""
    if deltainfo is None:
        return False

    if (
        revinfo.cachedelta is not None
        and deltainfo.base == revinfo.cachedelta[0]
        and revinfo.cachedelta[2] == DELTA_BASE_REUSE_FORCE
    ):
        return True

    # - 'deltainfo.distance' is the distance from the base revision --
    #   bounding it limits the amount of I/O we need to do.
    # - 'deltainfo.compresseddeltalen' is the sum of the total size of
    #   deltas we need to apply -- bounding it limits the amount of CPU

            if rev == nullrev:
                continue
            # filter out revision we tested already
            if rev in tested:
                continue

            if (
                cachedelta is not None
                and rev == cachedelta[0]
                and cachedelta[2] == DELTA_BASE_REUSE_FORCE
            ):
                # instructions are to forcibly consider/use this delta base
                group.append(rev)
                continue

            # an higher authority deamed the base unworthy (e.g. censored)
            if excluded_bases is not None and rev in excluded_bases:
                tested.add(rev)
                continue
            # We are in some recomputation cases and that rev is too high in