mercurial/utils/storageutil.py

40010:631c6f5058b9

    bin,
    nullid,
    nullrev,
)
from .. import (
    error,
    mdiff,
    pycompat,
)

                if plinkrev >= minlinkrev:
                    futurelargelinkrevs.add(plinkrev)

    return strippoint, brokenrevs

def emitrevisions(store, revs, resultcls, deltaparentfn=None, candeltafn=None,
                  rawsizefn=None, revdifffn=None, flagsfn=None,
                  sendfulltext=False,
                  revisiondata=False, assumehaveparentrevisions=False,
                  deltaprevious=False):
    """Generic implementation of ifiledata.emitrevisions().

    encapsulate all the logic for doing so in a backend-agnostic way.

    ``store``
       Object conforming to ``ifilestorage`` interface.

    ``revs``
       List of integer revision numbers whose data to emit.

    ``resultcls``
       A type implementing the ``irevisiondelta`` interface that will be
       constructed and returned.

       value for it. If not defined, flags value will be 0.

    ``sendfulltext``
       Whether to send fulltext revisions instead of deltas, if allowed.

    ``revisiondata``
    ``assumehaveparentrevisions``
    ``deltaprevious``
       See ``ifiledata.emitrevisions()`` interface documentation.
    """

    fnode = store.node

    prevrev = None

    if deltaprevious or assumehaveparentrevisions:
        prevrev = store.parentrevs(revs[0])[0]

40011:f5d819d84461

    bin,
    nullid,
    nullrev,
)
from .. import (
    dagop,
    error,
    mdiff,
    pycompat,
)

                if plinkrev >= minlinkrev:
                    futurelargelinkrevs.add(plinkrev)

    return strippoint, brokenrevs

def emitrevisions(store, nodes, nodesorder, resultcls, deltaparentfn=None,
                  candeltafn=None, rawsizefn=None, revdifffn=None, flagsfn=None,
                  sendfulltext=False,
                  revisiondata=False, assumehaveparentrevisions=False,
                  deltaprevious=False):
    """Generic implementation of ifiledata.emitrevisions().

    encapsulate all the logic for doing so in a backend-agnostic way.

    ``store``
       Object conforming to ``ifilestorage`` interface.

    ``nodes``
       List of revision nodes whose data to emit.

    ``resultcls``
       A type implementing the ``irevisiondelta`` interface that will be
       constructed and returned.

       value for it. If not defined, flags value will be 0.

    ``sendfulltext``
       Whether to send fulltext revisions instead of deltas, if allowed.

    ``nodesorder``
    ``revisiondata``
    ``assumehaveparentrevisions``
    ``deltaprevious``
       See ``ifiledata.emitrevisions()`` interface documentation.
    """

    fnode = store.node
    frev = store.rev

    if nodesorder == 'nodes':
        revs = [frev(n) for n in nodes]
    elif nodesorder == 'storage':
        revs = sorted(frev(n) for n in nodes)
    else:
        revs = set(frev(n) for n in nodes)
        revs = dagop.linearize(revs, store.parentrevs)

    prevrev = None

    if deltaprevious or assumehaveparentrevisions:
        prevrev = store.parentrevs(revs[0])[0]