comparison mercurial/exchange.py @ 24850:6b81309d15a7 stable

bundle2: capture output issue during transaction close

We were capturing all output issue during bundle2 processing, and all output
issue during transaction rollback in case of failure. However, the output issue
during transaction commit was still roaming the land freely. It is now put back
in line.

This let the user see output from 'pretxnclose' and 'txnclose' (and related) in
the right order.

24849:aff2aca3420e

                tr = repo.transaction(source)
                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
                if r is not None:
                    parts = exc._bundle2salvagedoutput = r.salvageoutput()
                    repo.ui.pushbuffer(error=True, subproc=True)
                    def recordout(output):
                        part = bundle2.bundlepart('output', data=output,
                                                  mandatory=False)
                        parts.append(part)
                raise

24850:6b81309d15a7

                tr = repo.transaction(source)
                tr.hookargs['source'] = source
                tr.hookargs['url'] = url
                tr.hookargs['bundle2'] = '1'
                r = bundle2.processbundle(repo, cg, lambda: tr).reply
                if r is not None:
                    repo.ui.pushbuffer(error=True, subproc=True)
                    def recordout(output):
                        r.newpart('output', data=output, mandatory=False)
                tr.close()
            except Exception, exc:
                exc.duringunbundle2 = True
                if r is not None:
                    parts = exc._bundle2salvagedoutput = r.salvageoutput()
                    def recordout(output):
                        part = bundle2.bundlepart('output', data=output,
                                                  mandatory=False)
                        parts.append(part)
                raise