contrib/perf.py

39821:6787dc1b93a9

    pass
try:
    from mercurial import pycompat
    getargspec = pycompat.getargspec  # added to module after 4.5
    _sysstr = pycompat.sysstr         # since 4.0 (or 2219f4f82ede)
except (ImportError, AttributeError):
    import inspect
    getargspec = inspect.getargspec
    _sysstr = lambda x: x             # no py3 support

try:
    # 4.7+
    queue = pycompat.queue.Queue
except (AttributeError, ImportError):

    # experimental config: perf.parentscount
    count = getint(ui, b"perf", b"parentscount", 1000)
    if len(repo.changelog) < count:
        raise error.Abort(b"repo needs %d commits for this test" % count)
    repo = repo.unfiltered()
    nl = [repo.changelog.node(i) for i in xrange(count)]
    def d():
        for n in nl:
            repo.changelog.parents(n)
    timer(d)
    fm.end()

    maxb1 = 100000
    random.seed(0)
    randint = random.randint
    currentlines = 0
    arglist = []
    for rev in xrange(edits):
        a1 = randint(0, currentlines)
        a2 = randint(a1, min(currentlines, a1 + maxhunklines))
        b1 = randint(0, maxb1)
        b2 = randint(b1, b1 + maxhunklines)
        currentlines += (b2 - b1) - (a2 - a1)

                    mdiff.bdiff.blocks(*pair)
                else:
                    mdiff.textdiff(*pair)
    else:
        q = queue()
        for i in xrange(threads):
            q.put(None)
        ready = threading.Condition()
        done = threading.Event()
        for i in xrange(threads):
            threading.Thread(target=_bdiffworker,
                             args=(q, blocks, xdiff, ready, done)).start()
        q.join()
        def d():
            for pair in textpairs:
                q.put(pair)
            for i in xrange(threads):
                q.put(None)
            with ready:
                ready.notify_all()
            q.join()
    timer, fm = gettimer(ui, opts)
    timer(d)
    fm.end()

    if withthreads:
        done.set()
        for i in xrange(threads):
            q.put(None)
        with ready:
            ready.notify_all()

@command(b'perfunidiff', revlogopts + formatteropts + [

        if reverse:
            beginrev, endrev = endrev, beginrev
            dist = -1 * dist

        for x in xrange(beginrev, endrev, dist):
            # Old revisions don't support passing int.
            n = rl.node(x)
            rl.revision(n)

    timer, fm = gettimer(ui, opts)

     (b'', b'mixedgetfreq', 50, b'frequency of get vs set ops in mixed mode')],
    norepo=True)
def perflrucache(ui, mincost=0, maxcost=100, costlimit=0, size=4,
                 gets=10000, sets=10000, mixed=10000, mixedgetfreq=50, **opts):
    def doinit():
        for i in xrange(10000):
            util.lrucachedict(size)

    costrange = list(range(mincost, maxcost + 1))

    values = []
    for i in xrange(size):
        values.append(random.randint(0, sys.maxint))

    # Get mode fills the cache and tests raw lookup performance with no
    # eviction.
    getseq = []
    for i in xrange(gets):
        getseq.append(random.choice(values))

    def dogets():
        d = util.lrucachedict(size)
        for v in values:

                pass

    # Set mode tests insertion speed with cache eviction.
    setseq = []
    costs = []
    for i in xrange(sets):
        setseq.append(random.randint(0, sys.maxint))
        costs.append(random.choice(costrange))

    def doinserts():
        d = util.lrucachedict(size)

        for v in setseq:
            d[v] = v

    # Mixed mode randomly performs gets and sets with eviction.
    mixedops = []
    for i in xrange(mixed):
        r = random.randint(0, 100)
        if r < mixedgetfreq:
            op = 0
        else:
            op = 1

39822:86dbeb7c9a11

    pass
try:
    from mercurial import pycompat
    getargspec = pycompat.getargspec  # added to module after 4.5
    _sysstr = pycompat.sysstr         # since 4.0 (or 2219f4f82ede)
    _xrange = pycompat.xrange         # since 4.8 (or 7eba8f83129b)
except (ImportError, AttributeError):
    import inspect
    getargspec = inspect.getargspec
    _sysstr = lambda x: x             # no py3 support
    _xrange = xrange

try:
    # 4.7+
    queue = pycompat.queue.Queue
except (AttributeError, ImportError):

    # experimental config: perf.parentscount
    count = getint(ui, b"perf", b"parentscount", 1000)
    if len(repo.changelog) < count:
        raise error.Abort(b"repo needs %d commits for this test" % count)
    repo = repo.unfiltered()
    nl = [repo.changelog.node(i) for i in _xrange(count)]
    def d():
        for n in nl:
            repo.changelog.parents(n)
    timer(d)
    fm.end()

    maxb1 = 100000
    random.seed(0)
    randint = random.randint
    currentlines = 0
    arglist = []
    for rev in _xrange(edits):
        a1 = randint(0, currentlines)
        a2 = randint(a1, min(currentlines, a1 + maxhunklines))
        b1 = randint(0, maxb1)
        b2 = randint(b1, b1 + maxhunklines)
        currentlines += (b2 - b1) - (a2 - a1)

                    mdiff.bdiff.blocks(*pair)
                else:
                    mdiff.textdiff(*pair)
    else:
        q = queue()
        for i in _xrange(threads):
            q.put(None)
        ready = threading.Condition()
        done = threading.Event()
        for i in _xrange(threads):
            threading.Thread(target=_bdiffworker,
                             args=(q, blocks, xdiff, ready, done)).start()
        q.join()
        def d():
            for pair in textpairs:
                q.put(pair)
            for i in _xrange(threads):
                q.put(None)
            with ready:
                ready.notify_all()
            q.join()
    timer, fm = gettimer(ui, opts)
    timer(d)
    fm.end()

    if withthreads:
        done.set()
        for i in _xrange(threads):
            q.put(None)
        with ready:
            ready.notify_all()

@command(b'perfunidiff', revlogopts + formatteropts + [

        if reverse:
            beginrev, endrev = endrev, beginrev
            dist = -1 * dist

        for x in _xrange(beginrev, endrev, dist):
            # Old revisions don't support passing int.
            n = rl.node(x)
            rl.revision(n)

    timer, fm = gettimer(ui, opts)

     (b'', b'mixedgetfreq', 50, b'frequency of get vs set ops in mixed mode')],
    norepo=True)
def perflrucache(ui, mincost=0, maxcost=100, costlimit=0, size=4,
                 gets=10000, sets=10000, mixed=10000, mixedgetfreq=50, **opts):
    def doinit():
        for i in _xrange(10000):
            util.lrucachedict(size)

    costrange = list(range(mincost, maxcost + 1))

    values = []
    for i in _xrange(size):
        values.append(random.randint(0, sys.maxint))

    # Get mode fills the cache and tests raw lookup performance with no
    # eviction.
    getseq = []
    for i in _xrange(gets):
        getseq.append(random.choice(values))

    def dogets():
        d = util.lrucachedict(size)
        for v in values:

                pass

    # Set mode tests insertion speed with cache eviction.
    setseq = []
    costs = []
    for i in _xrange(sets):
        setseq.append(random.randint(0, sys.maxint))
        costs.append(random.choice(costrange))

    def doinserts():
        d = util.lrucachedict(size)

        for v in setseq:
            d[v] = v

    # Mixed mode randomly performs gets and sets with eviction.
    mixedops = []
    for i in _xrange(mixed):
        r = random.randint(0, 100)
        if r < mixedgetfreq:
            op = 0
        else:
            op = 1