contrib/perf.py

40557:355ae096faef

         [(b's', b'startrev', 1000, b'revision to start writing at'),
          (b'', b'stoprev', -1, b'last revision to write'),
          (b'', b'count', 3, b'last revision to write'),
          (b'', b'details', False, b'print timing for every revisions tested'),
          (b'', b'source', b'full', b'the kind of data feed in the revlog'),
         ],
         b'-c|-m|FILE')
def perfrevlogwrite(ui, repo, file_=None, startrev=1000, stoprev=-1, **opts):
    """Benchmark writing a series of revisions to a revlog.

    if startrev < 0:
        startrev = rllen + startrev
    if stoprev < 0:
        stoprev = rllen + stoprev

    source = opts['source']
    validsource = (b'full', b'parent-1', b'parent-2', b'parent-smallest',
                   b'storage')
    if source not in validsource:
        raise error.Abort('invalid source type: %s' % source)

    count = opts['count']
    if count <= 0:
        raise error.Abort('invalide run count: %d' % count)
    allresults = []
    for c in range(count):
        timing = _timeonewrite(ui, rl, source, startrev, stoprev, c + 1)
        allresults.append(timing)

    ### consolidate the results in a single list
    results = []
    for idx, (rev, t) in enumerate(allresults[0]):

class _faketr(object):
    def add(s, x, y, z=None):
        return None

def _timeonewrite(ui, orig, source, startrev, stoprev, runidx=None):
    timings = []
    tr = _faketr()
    with _temprevlog(ui, orig, startrev) as dest:
        revs = list(orig.revs(startrev, stoprev))
        total = len(revs)
        topic = 'adding'
        if runidx is not None:
            topic += ' (run #%d)' % runidx

40558:4756a33d0d31

         [(b's', b'startrev', 1000, b'revision to start writing at'),
          (b'', b'stoprev', -1, b'last revision to write'),
          (b'', b'count', 3, b'last revision to write'),
          (b'', b'details', False, b'print timing for every revisions tested'),
          (b'', b'source', b'full', b'the kind of data feed in the revlog'),
          (b'', b'lazydeltabase', True, b'try the provided delta first'),
         ],
         b'-c|-m|FILE')
def perfrevlogwrite(ui, repo, file_=None, startrev=1000, stoprev=-1, **opts):
    """Benchmark writing a series of revisions to a revlog.

    if startrev < 0:
        startrev = rllen + startrev
    if stoprev < 0:
        stoprev = rllen + stoprev

    lazydeltabase = opts['lazydeltabase']
    source = opts['source']
    validsource = (b'full', b'parent-1', b'parent-2', b'parent-smallest',
                   b'storage')
    if source not in validsource:
        raise error.Abort('invalid source type: %s' % source)

    count = opts['count']
    if count <= 0:
        raise error.Abort('invalide run count: %d' % count)
    allresults = []
    for c in range(count):
        timing = _timeonewrite(ui, rl, source, startrev, stoprev, c + 1,
                               lazydeltabase=lazydeltabase)
        allresults.append(timing)

    ### consolidate the results in a single list
    results = []
    for idx, (rev, t) in enumerate(allresults[0]):

class _faketr(object):
    def add(s, x, y, z=None):
        return None

def _timeonewrite(ui, orig, source, startrev, stoprev, runidx=None,
                  lazydeltabase=True):
    timings = []
    tr = _faketr()
    with _temprevlog(ui, orig, startrev) as dest:
        dest._lazydeltabase = lazydeltabase
        revs = list(orig.revs(startrev, stoprev))
        total = len(revs)
        topic = 'adding'
        if runidx is not None:
            topic += ' (run #%d)' % runidx