diff options
| author | Gordon Chung <chungg@ca.ibm.com> | 2014-03-27 17:38:40 -0400 |
|---|---|---|
| committer | Gordon Chung <chungg@ca.ibm.com> | 2014-03-27 17:38:40 -0400 |
| commit | 5df14763a5a88b9549066da04dac13ae2ad73144 (patch) | |
| tree | d6cc1b4ded7c3181cd455bac00f4a9d472b6b4df /ceilometer/service.py | |
| parent | e8a7eed15c5e796d240cac34cdc732294347096a (diff) | |
| download | ceilometer-5df14763a5a88b9549066da04dac13ae2ad73144.tar.gz | |
ensure dispatcher service is configured before rpc
there is a rare race condition where when the mq contains
notifications, the rpc service is configured before dispatcher so
it may attempt to start sending messages to dispatcher before it
has been configured. this patch ensures the dispatcher
configuration is done before starting rpc service.
Change-Id: If4c3a225e0bd5ae6eefad072b844af1ef5786f3f
Diffstat (limited to 'ceilometer/service.py')
| -rw-r--r-- | ceilometer/service.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ceilometer/service.py b/ceilometer/service.py index 8838483f..2095068e 100644 --- a/ceilometer/service.py +++ b/ceilometer/service.py @@ -107,7 +107,6 @@ class DispatchedService(object): DISPATCHER_NAMESPACE = 'ceilometer.dispatcher' def start(self): - super(DispatchedService, self).start() LOG.debug(_('loading dispatchers from %s'), self.DISPATCHER_NAMESPACE) self.dispatcher_manager = named.NamedExtensionManager( @@ -118,6 +117,8 @@ class DispatchedService(object): if not list(self.dispatcher_manager): LOG.warning(_('Failed to load any dispatchers for %s'), self.DISPATCHER_NAMESPACE) + # ensure dispatcher is configured before starting other services + super(DispatchedService, self).start() def get_workers(name): |