equal
deleted
inserted
replaced
13 from .i18n import _ |
13 from .i18n import _ |
14 from . import ( |
14 from . import ( |
15 error, |
15 error, |
16 pycompat, |
16 pycompat, |
17 util, |
17 util, |
18 wireproto, |
|
19 wireprotoserver, |
18 wireprotoserver, |
20 wireprototypes, |
19 wireprototypes, |
21 wireprotov1peer, |
20 wireprotov1peer, |
|
21 wireprotov1server, |
22 ) |
22 ) |
23 from .utils import ( |
23 from .utils import ( |
24 procutil, |
24 procutil, |
25 ) |
25 ) |
26 |
26 |
439 else: |
439 else: |
440 for dk, dv in sorted(value.items()): |
440 for dk, dv in sorted(value.items()): |
441 dbg(line % ' %s-%s: %d' % (key, dk, len(dv))) |
441 dbg(line % ' %s-%s: %d' % (key, dk, len(dv))) |
442 self.ui.debug("sending %s command\n" % cmd) |
442 self.ui.debug("sending %s command\n" % cmd) |
443 self._pipeo.write("%s\n" % cmd) |
443 self._pipeo.write("%s\n" % cmd) |
444 _func, names = wireproto.commands[cmd] |
444 _func, names = wireprotov1server.commands[cmd] |
445 keys = names.split() |
445 keys = names.split() |
446 wireargs = {} |
446 wireargs = {} |
447 for k in keys: |
447 for k in keys: |
448 if k == '*': |
448 if k == '*': |
449 wireargs['*'] = args |
449 wireargs['*'] = args |