| indygreg |
| hg-reviewers |
As part of moving the part iterator logic to a separate class, let's move the
part counting logic and the output for it.
| Lint Skipped |
| Unit Tests Skipped |
| return processbundle(repo, unbundler, lambda: tr) | return processbundle(repo, unbundler, lambda: tr) | ||||
| else: | else: | ||||
| # the transactiongetter won't be used, but we might as well set it | # the transactiongetter won't be used, but we might as well set it | ||||
| op = bundleoperation(repo, lambda: tr) | op = bundleoperation(repo, lambda: tr) | ||||
| _processchangegroup(op, unbundler, tr, source, url, **kwargs) | _processchangegroup(op, unbundler, tr, source, url, **kwargs) | ||||
| return op | return op | ||||
| class partiterator(object): | class partiterator(object): | ||||
| def __init__(self, unbundler): | def __init__(self, repo, unbundler): | ||||
| self.repo = repo | |||||
| self.unbundler = unbundler | self.unbundler = unbundler | ||||
| self.iterator = None | |||||
| self.count = 0 | |||||
| def __enter__(self): | def __enter__(self): | ||||
| return enumerate(self.unbundler.iterparts()) | def func(): | ||||
| itr = enumerate(self.unbundler.iterparts()) | |||||
| for count, p in itr: | |||||
| self.count = count | |||||
| yield p | |||||
| self.iterator = func() | |||||
| return self.iterator | |||||
| def __exit__(self, type, value, tb): | def __exit__(self, type, value, tb): | ||||
| pass | if not self.iterator: | ||||
| return | |||||
| self.repo.ui.debug('bundle2-input-bundle: %i parts total\n' % | |||||
| self.count) | |||||
| def processbundle(repo, unbundler, transactiongetter=None, op=None): | def processbundle(repo, unbundler, transactiongetter=None, op=None): | ||||
| """This function process a bundle, apply effect to/from a repo | """This function process a bundle, apply effect to/from a repo | ||||
| It iterates over each part then searches for and uses the proper handling | It iterates over each part then searches for and uses the proper handling | ||||
| code to process the part. Parts are processed in order. | code to process the part. Parts are processed in order. | ||||
| Unknown Mandatory part will abort the process. | Unknown Mandatory part will abort the process. | ||||
| msg.append(' %i params' % len(unbundler.params)) | msg.append(' %i params' % len(unbundler.params)) | ||||
| if op._gettransaction is None or op._gettransaction is _notransaction: | if op._gettransaction is None or op._gettransaction is _notransaction: | ||||
| msg.append(' no-transaction') | msg.append(' no-transaction') | ||||
| else: | else: | ||||
| msg.append(' with-transaction') | msg.append(' with-transaction') | ||||
| msg.append('\n') | msg.append('\n') | ||||
| repo.ui.debug(''.join(msg)) | repo.ui.debug(''.join(msg)) | ||||
| with partiterator(unbundler) as parts: | with partiterator(repo, unbundler) as parts: | ||||
| part = None | part = None | ||||
| nbpart = 0 | |||||
| try: | try: | ||||
| for nbpart, part in parts: | for part in parts: | ||||
| _processpart(op, part) | _processpart(op, part) | ||||
| except Exception as exc: | except Exception as exc: | ||||
| # Any exceptions seeking to the end of the bundle at this point are | # Any exceptions seeking to the end of the bundle at this point are | ||||
| # almost certainly related to the underlying stream being bad. | # almost certainly related to the underlying stream being bad. | ||||
| # And, chances are that the exception we're handling is related to | # And, chances are that the exception we're handling is related to | ||||
| # getting in that bad state. So, we swallow the seeking error and | # getting in that bad state. So, we swallow the seeking error and | ||||
| # re-raise the original error. | # re-raise the original error. | ||||
| seekerror = False | seekerror = False | ||||
| try: | try: | ||||
| for nbpart, part in parts: | for part in parts: | ||||
| # consume the bundle content | # consume the bundle content | ||||
| part.seek(0, 2) | part.seek(0, 2) | ||||
| except Exception: | except Exception: | ||||
| seekerror = True | seekerror = True | ||||
| # Small hack to let caller code distinguish exceptions from bundle2 | # Small hack to let caller code distinguish exceptions from bundle2 | ||||
| # processing from processing the old format. This is mostly needed | # processing from processing the old format. This is mostly needed | ||||
| # to handle different return codes to unbundle according to the type | # to handle different return codes to unbundle according to the type | ||||
| exc._bundle2salvagedoutput = salvaged | exc._bundle2salvagedoutput = salvaged | ||||
| # Re-raising from a variable loses the original stack. So only use | # Re-raising from a variable loses the original stack. So only use | ||||
| # that form if we need to. | # that form if we need to. | ||||
| if seekerror: | if seekerror: | ||||
| raise exc | raise exc | ||||
| else: | else: | ||||
| raise | raise | ||||
| finally: | |||||
| repo.ui.debug('bundle2-input-bundle: %i parts total\n' % nbpart) | |||||
| return op | return op | ||||
| def _processchangegroup(op, cg, tr, source, url, **kwargs): | def _processchangegroup(op, cg, tr, source, url, **kwargs): | ||||
| ret = cg.apply(op.repo, tr, source, url, **kwargs) | ret = cg.apply(op.repo, tr, source, url, **kwargs) | ||||
| op.records.add('changegroup', { | op.records.add('changegroup', { | ||||
| 'return': ret, | 'return': ret, | ||||
| }) | }) | ||||