351 if url is not None and 'url' not in tr.hookargs: |
351 if url is not None and 'url' not in tr.hookargs: |
352 tr.hookargs['url'] = url |
352 tr.hookargs['url'] = url |
353 return processbundle(repo, unbundler, lambda: tr, source=source) |
353 return processbundle(repo, unbundler, lambda: tr, source=source) |
354 else: |
354 else: |
355 # the transactiongetter won't be used, but we might as well set it |
355 # the transactiongetter won't be used, but we might as well set it |
356 op = bundleoperation(repo, lambda: tr) |
356 op = bundleoperation(repo, lambda: tr, source=source) |
357 _processchangegroup(op, unbundler, tr, source, url, **kwargs) |
357 _processchangegroup(op, unbundler, tr, source, url, **kwargs) |
358 return op |
358 return op |
359 |
359 |
360 class partiterator(object): |
360 class partiterator(object): |
361 def __init__(self, repo, op, unbundler): |
361 def __init__(self, repo, op, unbundler): |
439 reworked and this ability will probably go away in the process. |
439 reworked and this ability will probably go away in the process. |
440 """ |
440 """ |
441 if op is None: |
441 if op is None: |
442 if transactiongetter is None: |
442 if transactiongetter is None: |
443 transactiongetter = _notransaction |
443 transactiongetter = _notransaction |
444 op = bundleoperation(repo, transactiongetter) |
444 op = bundleoperation(repo, transactiongetter, source=source) |
445 # todo: |
445 # todo: |
446 # - replace this is a init function soon. |
446 # - replace this is a init function soon. |
447 # - exception catching |
447 # - exception catching |
448 unbundler.params |
448 unbundler.params |
449 if repo.ui.debugflag: |
449 if repo.ui.debugflag: |