comparison mercurial/exchange.py @ 24697:52ff737c63d2

bundle2: drop the experimental hooks

The series at e9ede9b4c2f8::8e13cc0825f1 introduced generic transaction level
hooking. This makes the experimental bundle2 specific hooks redundant, we drop
them.

24696:553dc2b094d9

        return self._tr

    def close(self):
        """close transaction if created"""
        if self._tr is not None:
            repo = self.repo
            p = lambda: self._tr.writepending() and repo.root or ""
            repo.hook('b2x-pretransactionclose', throw=True, pending=p,
                      **self._tr.hookargs)
            hookargs = dict(self._tr.hookargs)
            def runhooks():
                repo.hook('b2x-transactionclose', **hookargs)
            self._tr.addpostclose('b2x-hook-transactionclose',
                                  lambda tr: repo._afterlock(runhooks))
            self._tr.close()

    def release(self):
        """release transaction if created"""
        if self._tr is not None:

                tr = repo.transaction('unbundle')
                tr.hookargs['source'] = source
                tr.hookargs['url'] = url
                tr.hookargs['bundle2'] = '1'
                r = bundle2.processbundle(repo, cg, lambda: tr).reply
                p = lambda: tr.writepending() and repo.root or ""
                repo.hook('b2x-pretransactionclose', throw=True, pending=p,
                          **tr.hookargs)
                hookargs = dict(tr.hookargs)
                def runhooks():
                    repo.hook('b2x-transactionclose', **hookargs)
                tr.addpostclose('b2x-hook-transactionclose',
                                lambda tr: repo._afterlock(runhooks))
                tr.close()
            except Exception, exc:
                exc.duringunbundle2 = True
                raise
        else:

24697:52ff737c63d2

        return self._tr

    def close(self):
        """close transaction if created"""
        if self._tr is not None:
            self._tr.close()

    def release(self):
        """release transaction if created"""
        if self._tr is not None:

                tr = repo.transaction('unbundle')
                tr.hookargs['source'] = source
                tr.hookargs['url'] = url
                tr.hookargs['bundle2'] = '1'
                r = bundle2.processbundle(repo, cg, lambda: tr).reply
                tr.close()
            except Exception, exc:
                exc.duringunbundle2 = True
                raise
        else: