diff options
author | Lucas Alvares Gomes <lucasagomes@gmail.com> | 2014-04-16 15:37:23 +0100 |
---|---|---|
committer | Lucas Alvares Gomes <lucasagomes@gmail.com> | 2014-04-25 22:46:44 +0100 |
commit | 69dc8400db6e0c2b1b2be83f06f8ef15638cd54e (patch) | |
tree | 3819e9d8f9bf25b00ce44f8fc206ed800133a50d /ironic/cmd/conductor.py | |
parent | 580ee8f065b377a853e94116bff98a13cec49ff4 (diff) | |
download | ironic-69dc8400db6e0c2b1b2be83f06f8ef15638cd54e.tar.gz |
Port to oslo.messaging
The oslo.messaging library takes the existing RPC code from oslo and
wraps it in a sane API with well defined semantics around which we can
make a commitment to retain compatibility in future.
The patch is large and hard to be split into different patches, but the
changes can be summarized as:
* Remove openstack/common/{rpc, notifier, log_handler} modules dependency
(superceded by oslo.messaging)
* New config option `conductor.workers_pool_size` add to determine the
size of the workers greenthread pool.
* PeriodicService class refactored and renamed to RPCService, all periodic
tasks methods were moved to the ConductorManager class leaving RPCService
class to be resposable for setting up and starting the RPCServer from
oslo.messaging only.
* In oslo.messaging, a request context is expected to be a dict so the
method RequestContext.{to,from}_dict() was updated/added to the module.
* The allowed_rpc_exception_modules configuration option is replaced
by an allowed_remote_exmods get_transport() parameter. This is not
something that users ever need to configure, but it is something each
project using oslo.messaging needs to be able to customize.
* New common/rpc.py module added to wrap the global messaging state. It
also contains transport aliases for backwards compatibility with IceHouse
rpc_backend configuration values.
blueprint: oslo-messaging
Change-Id: I454e8898baed002a1cddb9eb76492ae9c2f1212b
Diffstat (limited to 'ironic/cmd/conductor.py')
-rw-r--r-- | ironic/cmd/conductor.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ironic/cmd/conductor.py b/ironic/cmd/conductor.py index cb99251d4..78afc28f7 100644 --- a/ironic/cmd/conductor.py +++ b/ironic/cmd/conductor.py @@ -34,8 +34,8 @@ def main(): # Pase config file and command line options, then start logging ironic_service.prepare_service(sys.argv) - mgr = ironic_service.load_manager('ironic.conductor.manager', - 'ConductorManager', - CONF.host) + mgr = ironic_service.RPCService(CONF.host, + 'ironic.conductor.manager', + 'ConductorManager') launcher = service.launch(mgr) launcher.wait() |