mercurial/wireproto.py
changeset 20912 96ecb77f971d
parent 20911 1bb8ed6c000c
child 20913 fc7219ec08bb
equal deleted inserted replaced
20911:1bb8ed6c000c 20912:96ecb77f971d
   573 # `_capabilities` instead.
   573 # `_capabilities` instead.
   574 @wireprotocommand('capabilities')
   574 @wireprotocommand('capabilities')
   575 def capabilities(repo, proto):
   575 def capabilities(repo, proto):
   576     return ' '.join(_capabilities(repo, proto))
   576     return ' '.join(_capabilities(repo, proto))
   577 
   577 
       
   578 @wireprotocommand('changegroup', 'roots')
   578 def changegroup(repo, proto, roots):
   579 def changegroup(repo, proto, roots):
   579     nodes = decodelist(roots)
   580     nodes = decodelist(roots)
   580     cg = repo.changegroup(nodes, 'serve')
   581     cg = repo.changegroup(nodes, 'serve')
   581     return streamres(proto.groupchunks(cg))
   582     return streamres(proto.groupchunks(cg))
   582 
   583 
   784     finally:
   785     finally:
   785         fp.close()
   786         fp.close()
   786         os.unlink(tempname)
   787         os.unlink(tempname)
   787 
   788 
   788 commands.update({
   789 commands.update({
   789     'changegroup': (changegroup, 'roots'),
       
   790     'changegroupsubset': (changegroupsubset, 'bases heads'),
   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, ''),