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