Revision 4fbe3851 lib/rpc.py
| b/lib/rpc.py | ||
|---|---|---|
| 513 | 513 |
""" |
| 514 | 514 |
return self._InstDict(instance, osp=osparams) |
| 515 | 515 |
|
| 516 |
def _MultiNodeCall(self, node_list, procedure, args, read_timeout=None): |
|
| 517 |
"""Helper for making a multi-node call |
|
| 518 |
|
|
| 519 |
""" |
|
| 520 |
body = serializer.DumpJson(args, indent=False) |
|
| 521 |
return self._proc(node_list, procedure, body, read_timeout=read_timeout) |
|
| 522 |
|
|
| 523 | 516 |
def _Call(self, node_list, procedure, timeout, args): |
| 524 | 517 |
"""Entry point for automatically generated RPC wrappers. |
| 525 | 518 |
|
| 526 | 519 |
""" |
| 527 |
return self._MultiNodeCall(node_list, procedure, args, read_timeout=timeout) |
|
| 528 |
|
|
| 529 |
@staticmethod |
|
| 530 |
def _StaticMultiNodeCall(node_list, procedure, args, |
|
| 531 |
address_list=None, read_timeout=None): |
|
| 532 |
"""Helper for making a multi-node static call |
|
| 533 |
|
|
| 534 |
""" |
|
| 535 | 520 |
body = serializer.DumpJson(args, indent=False) |
| 536 | 521 |
|
| 537 |
if address_list is None: |
|
| 538 |
resolver = _SsconfResolver |
|
| 539 |
else: |
|
| 540 |
# Caller provided an address list |
|
| 541 |
resolver = _StaticResolver(address_list) |
|
| 542 |
|
|
| 543 |
proc = _RpcProcessor(resolver, |
|
| 544 |
netutils.GetDaemonPort(constants.NODED)) |
|
| 545 |
return proc(node_list, procedure, body, read_timeout=read_timeout) |
|
| 546 |
|
|
| 547 |
def _SingleNodeCall(self, node, procedure, args, read_timeout=None): |
|
| 548 |
"""Helper for making a single-node call |
|
| 549 |
|
|
| 550 |
""" |
|
| 551 |
body = serializer.DumpJson(args, indent=False) |
|
| 552 |
return self._proc([node], procedure, body, read_timeout=read_timeout)[node] |
|
| 553 |
|
|
| 554 |
@classmethod |
|
| 555 |
def _StaticSingleNodeCall(cls, node, procedure, args, read_timeout=None): |
|
| 556 |
"""Helper for making a single-node static call |
|
| 557 |
|
|
| 558 |
""" |
|
| 559 |
body = serializer.DumpJson(args, indent=False) |
|
| 560 |
proc = _RpcProcessor(_SsconfResolver, |
|
| 561 |
netutils.GetDaemonPort(constants.NODED)) |
|
| 562 |
return proc([node], procedure, body, read_timeout=read_timeout)[node] |
|
| 522 |
return self._proc(node_list, procedure, body, read_timeout=timeout) |
|
| 563 | 523 |
|
| 564 | 524 |
@staticmethod |
| 565 | 525 |
def _BlockdevFindPostProc(result): |
Also available in: Unified diff