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