Package ganeti :: Module rpc :: Class _RpcProcessor

Class _RpcProcessor

Instance Methods

__init__(self, resolver, port, lock_monitor_cb=None)
Initializes this class.

source code

dictionary

__call__(self, nodes, procedure, body, read_timeout, resolver_opts, _req_process_fn=None)
Makes an RPC request to a number of nodes.

source code

Static Methods

_PrepareRequests(hosts, port, procedure, body, read_timeout)
Prepares requests by sorting offline hosts into separate list.

source code

_CombineResults(results, requests, procedure)
Combines pre-computed results for offline hosts with actual call results.

source code

Method Details

Initializes this class.

Parameters:

resolver - callable accepting a list of node UUIDs or hostnames, returning a list of tuples containing name, IP address and original name of the resolved node. IP address can be the name or the special value _OFFLINE to mark offline machines.
port (int) - TCP port
lock_monitor_cb - Callable for registering with lock monitor

Prepares requests by sorting offline hosts into separate list.

Parameters:

Makes an RPC request to a number of nodes.

Parameters:

Returns: dictionary

a dictionary mapping host names to rpc.RpcResult objects