diff --git a/neutron/agent/l3/agent.py b/neutron/agent/l3/agent.py index 99294ab5f7f..85410c95863 100644 --- a/neutron/agent/l3/agent.py +++ b/neutron/agent/l3/agent.py @@ -152,7 +152,7 @@ class L3PluginApi(object): def update_ha_routers_states(self, context, states): """Update HA routers states.""" cctxt = self.client.prepare(version='1.5') - return cctxt.call(context, 'update_ha_routers_states', + return cctxt.cast(context, 'update_ha_routers_states', host=self.host, states=states) def process_prefix_update(self, context, prefix_update): diff --git a/neutron/agent/l3/ha.py b/neutron/agent/l3/ha.py index db02e05aaa7..fc60363da09 100644 --- a/neutron/agent/l3/ha.py +++ b/neutron/agent/l3/ha.py @@ -177,6 +177,9 @@ class AgentMixin(object): ri.disable_radvd() def notify_server(self, batched_events): + eventlet.spawn_n(self._notify_server, batched_events) + + def _notify_server(self, batched_events): translated_states = dict((router_id, TRANSLATION_MAP[state]) for router_id, state in batched_events) LOG.debug('Updating server with HA routers states %s',