summaryrefslogtreecommitdiff
path: root/ironic/cmd/conductor.py
diff options
context:
space:
mode:
authorLucas Alvares Gomes <lucasagomes@gmail.com>2014-04-16 15:37:23 +0100
committerLucas Alvares Gomes <lucasagomes@gmail.com>2014-04-25 22:46:44 +0100
commit69dc8400db6e0c2b1b2be83f06f8ef15638cd54e (patch)
tree3819e9d8f9bf25b00ce44f8fc206ed800133a50d /ironic/cmd/conductor.py
parent580ee8f065b377a853e94116bff98a13cec49ff4 (diff)
downloadironic-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.py6
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()