mercurial/commands.py

23890:7817059917d0

    lock = repo.lock()
    try:
        for fname in fnames:
            f = hg.openpath(ui, fname)
            gen = exchange.readbundle(ui, f, fname)
            modheads = changegroup.addchangegroup(repo, gen, 'unbundle',
                                                  'bundle:' + fname)
    finally:
        lock.release()

    return postincoming(ui, repo, modheads, opts.get('update'), None)

23891:5827ad0b849e

    lock = repo.lock()
    try:
        for fname in fnames:
            f = hg.openpath(ui, fname)
            gen = exchange.readbundle(ui, f, fname)
            if isinstance(gen, bundle2.unbundle20):
                tr = repo.transaction('unbundle')
                try:
                    op = bundle2.processbundle(repo, gen, lambda: tr)
                    tr.close()
                finally:
                    if tr:
                        tr.release()
                changes = [r.get('result', 0)
                           for r in op.records['changegroup']]
                modheads = changegroup.combineresults(changes)
            else:
                modheads = changegroup.addchangegroup(repo, gen, 'unbundle',
                                                      'bundle:' + fname)
    finally:
        lock.release()

    return postincoming(ui, repo, modheads, opts.get('update'), None)