comparison mercurial/commands.py @ 32844:76bb53f8d374

unbundle: use context manager for transaction

32843:a470bbb4e3af

    with repo.lock():
        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.applybundle(repo, gen, tr, source='unbundle',
                                             url='bundle:' + fname)
                    tr.close()
                except error.BundleUnknownFeatureError as exc:
                    raise error.Abort(_('%s: unknown bundle feature, %s')
                                      % (fname, exc),
                                      hint=_("see https://mercurial-scm.org/"
                                             "wiki/BundleFeature for more "
                                             "information"))
                finally:
                    if tr:
                        tr.release()
                changes = [r.get('return', 0)
                           for r in op.records['changegroup']]
                modheads = changegroup.combineresults(changes)
            elif isinstance(gen, streamclone.streamcloneapplier):
                raise error.Abort(

32844:76bb53f8d374

    with repo.lock():
        for fname in fnames:
            f = hg.openpath(ui, fname)
            gen = exchange.readbundle(ui, f, fname)
            if isinstance(gen, bundle2.unbundle20):
                with repo.transaction('unbundle') as tr:
                    try:
                        op = bundle2.applybundle(repo, gen, tr,
                                                 source='unbundle',
                                                 url='bundle:' + fname)
                    except error.BundleUnknownFeatureError as exc:
                        raise error.Abort(
                            _('%s: unknown bundle feature, %s') % (fname, exc),
                            hint=_("see https://mercurial-scm.org/"
                                   "wiki/BundleFeature for more "
                                   "information"))
                changes = [r.get('return', 0)
                           for r in op.records['changegroup']]
                modheads = changegroup.combineresults(changes)
            elif isinstance(gen, streamclone.streamcloneapplier):
                raise error.Abort(