equal
deleted
inserted
replaced
409 repo.invalidatevolatilesets() |
409 repo.invalidatevolatilesets() |
410 |
410 |
411 if changesets > 0: |
411 if changesets > 0: |
412 if 'node' not in tr.hookargs: |
412 if 'node' not in tr.hookargs: |
413 tr.hookargs['node'] = hex(cl.node(clstart)) |
413 tr.hookargs['node'] = hex(cl.node(clstart)) |
|
414 tr.hookargs['node_last'] = hex(cl.node(clend - 1)) |
414 hookargs = dict(tr.hookargs) |
415 hookargs = dict(tr.hookargs) |
415 else: |
416 else: |
416 hookargs = dict(tr.hookargs) |
417 hookargs = dict(tr.hookargs) |
417 hookargs['node'] = hex(cl.node(clstart)) |
418 hookargs['node'] = hex(cl.node(clstart)) |
|
419 hookargs['node_last'] = hex(cl.node(clend - 1)) |
418 repo.hook('pretxnchangegroup', throw=True, **hookargs) |
420 repo.hook('pretxnchangegroup', throw=True, **hookargs) |
419 |
421 |
420 added = [cl.node(r) for r in xrange(clstart, clend)] |
422 added = [cl.node(r) for r in xrange(clstart, clend)] |
421 publishing = repo.publishing() |
423 publishing = repo.publishing() |
422 if srctype in ('push', 'serve'): |
424 if srctype in ('push', 'serve'): |
459 repo.hook("changegroup", **hookargs) |
461 repo.hook("changegroup", **hookargs) |
460 |
462 |
461 for n in added: |
463 for n in added: |
462 args = hookargs.copy() |
464 args = hookargs.copy() |
463 args['node'] = hex(n) |
465 args['node'] = hex(n) |
|
466 del args['node_last'] |
464 repo.hook("incoming", **args) |
467 repo.hook("incoming", **args) |
465 |
468 |
466 newheads = [h for h in repo.heads() if h not in oldheads] |
469 newheads = [h for h in repo.heads() if h not in oldheads] |
467 repo.ui.log("incoming", |
470 repo.ui.log("incoming", |
468 "%s incoming changes - new heads: %s\n", |
471 "%s incoming changes - new heads: %s\n", |