mercurial/dagop.py

35284:b4b328ea6175

        if foundnew and pdepth < stopdepth:
            for prev in pfunc(currev):
                if prev != node.nullrev:
                    heapq.heappush(pendingheap, (heapsign * prev, pdepth))

def filectxancestors(fctx, followfirst=False):
    """Like filectx.ancestors(), but includes the given fctx itself"""
    visit = {}
    def addvisit(fctx):
        rev = fctx.rev()
        if rev not in visit:
            visit[rev] = set()

    if followfirst:
        cut = 1
    else:
        cut = None

    addvisit(fctx)
    while visit:
        rev = max(visit)
        c = visit[rev].pop()
        if not visit[rev]:
            del visit[rev]

35285:205c3c6c1a51

        if foundnew and pdepth < stopdepth:
            for prev in pfunc(currev):
                if prev != node.nullrev:
                    heapq.heappush(pendingheap, (heapsign * prev, pdepth))

def filectxancestors(fctxs, followfirst=False):
    """Like filectx.ancestors(), but can walk from multiple files/revisions,
    and includes the given fctxs themselves"""
    visit = {}
    def addvisit(fctx):
        rev = fctx.rev()
        if rev not in visit:
            visit[rev] = set()

    if followfirst:
        cut = 1
    else:
        cut = None

    for c in fctxs:
        addvisit(c)
    while visit:
        rev = max(visit)
        c = visit[rev].pop()
        if not visit[rev]:
            del visit[rev]