Revision 702abcf9 lib/rpc.py
b/lib/rpc.py | ||
---|---|---|
430 | 430 |
else: |
431 | 431 |
return encoder_fn(argkind)(value) |
432 | 432 |
|
433 |
def _Call(self, node_list, procedure, timeout, argdefs, args):
|
|
433 |
def _Call(self, cdef, node_list, timeout, args):
|
|
434 | 434 |
"""Entry point for automatically generated RPC wrappers. |
435 | 435 |
|
436 | 436 |
""" |
437 |
assert len(args) == len(argdefs), "Wrong number of arguments"
|
|
437 |
(procedure, _, _, argdefs, _, _) = cdef
|
|
438 | 438 |
|
439 |
body = serializer.DumpJson(map(self._encoder, zip(argdefs, args)), |
|
439 |
body = serializer.DumpJson(map(self._encoder, |
|
440 |
zip(map(compat.snd, argdefs), args)), |
|
440 | 441 |
indent=False) |
441 | 442 |
|
442 | 443 |
return self._proc(node_list, procedure, body, read_timeout=timeout) |
Also available in: Unified diff