equal
deleted
inserted
replaced
579 def changegroup(repo, proto, roots): |
579 def changegroup(repo, proto, roots): |
580 nodes = decodelist(roots) |
580 nodes = decodelist(roots) |
581 cg = repo.changegroup(nodes, 'serve') |
581 cg = repo.changegroup(nodes, 'serve') |
582 return streamres(proto.groupchunks(cg)) |
582 return streamres(proto.groupchunks(cg)) |
583 |
583 |
|
584 @wireprotocommand('changegroupsubset', 'bases heads') |
584 def changegroupsubset(repo, proto, bases, heads): |
585 def changegroupsubset(repo, proto, bases, heads): |
585 bases = decodelist(bases) |
586 bases = decodelist(bases) |
586 heads = decodelist(heads) |
587 heads = decodelist(heads) |
587 cg = repo.changegroupsubset(bases, heads, 'serve') |
588 cg = repo.changegroupsubset(bases, heads, 'serve') |
588 return streamres(proto.groupchunks(cg)) |
589 return streamres(proto.groupchunks(cg)) |
785 finally: |
786 finally: |
786 fp.close() |
787 fp.close() |
787 os.unlink(tempname) |
788 os.unlink(tempname) |
788 |
789 |
789 commands.update({ |
790 commands.update({ |
790 'changegroupsubset': (changegroupsubset, 'bases heads'), |
|
791 'debugwireargs': (debugwireargs, 'one two *'), |
791 'debugwireargs': (debugwireargs, 'one two *'), |
792 'getbundle': (getbundle, '*'), |
792 'getbundle': (getbundle, '*'), |
793 'heads': (heads, ''), |
793 'heads': (heads, ''), |
794 'hello': (hello, ''), |
794 'hello': (hello, ''), |
795 'known': (known, 'nodes *'), |
795 'known': (known, 'nodes *'), |