mercurial/wireproto.py
changeset 20913 fc7219ec08bb
parent 20912 96ecb77f971d
child 20914 d81b518a1862
equal deleted inserted replaced
20912:96ecb77f971d 20913:fc7219ec08bb
   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 *'),