Revision 87b3cb26 lib/rpc.py
| b/lib/rpc.py | ||
|---|---|---|
| 414 | 414 |
|
| 415 | 415 |
|
| 416 | 416 |
class RpcRunner(object): |
| 417 |
"""RPC runner class"""
|
|
| 417 |
"""RPC runner class.
|
|
| 418 | 418 |
|
| 419 |
def __init__(self, cfg): |
|
| 420 |
"""Initialized the rpc runner. |
|
| 419 |
""" |
|
| 420 |
def __init__(self, context): |
|
| 421 |
"""Initialized the RPC runner. |
|
| 421 | 422 |
|
| 422 |
@type cfg: C{config.ConfigWriter}
|
|
| 423 |
@param cfg: the configuration object that will be used to get data |
|
| 424 |
about the cluster |
|
| 423 |
@type context: C{masterd.GanetiContext}
|
|
| 424 |
@param context: Ganeti context |
|
| 425 | 425 |
|
| 426 | 426 |
""" |
| 427 |
self._cfg = cfg |
|
| 427 |
self._cfg = context.cfg
|
|
| 428 | 428 |
self.port = netutils.GetDaemonPort(constants.NODED) |
| 429 | 429 |
|
| 430 | 430 |
def _InstDict(self, instance, hvp=None, bep=None, osp=None): |
Also available in: Unified diff