445 else: |
445 else: |
446 msg.append(' with-transaction') |
446 msg.append(' with-transaction') |
447 msg.append('\n') |
447 msg.append('\n') |
448 repo.ui.debug(''.join(msg)) |
448 repo.ui.debug(''.join(msg)) |
449 |
449 |
|
450 processparts(repo, op, unbundler) |
|
451 |
|
452 return op |
|
453 |
|
454 def processparts(repo, op, unbundler): |
450 with partiterator(repo, op, unbundler) as parts: |
455 with partiterator(repo, op, unbundler) as parts: |
451 for part in parts: |
456 for part in parts: |
452 _processpart(op, part) |
457 _processpart(op, part) |
453 |
|
454 return op |
|
455 |
458 |
456 def _processchangegroup(op, cg, tr, source, url, **kwargs): |
459 def _processchangegroup(op, cg, tr, source, url, **kwargs): |
457 ret = cg.apply(op.repo, tr, source, url, **kwargs) |
460 ret = cg.apply(op.repo, tr, source, url, **kwargs) |
458 op.records.add('changegroup', { |
461 op.records.add('changegroup', { |
459 'return': ret, |
462 'return': ret, |