diff --git a/neutron/agent/l3/agent.py b/neutron/agent/l3/agent.py index d1ac187e264..3cbf45bb612 100644 --- a/neutron/agent/l3/agent.py +++ b/neutron/agent/l3/agent.py @@ -174,7 +174,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 899be9b7f00..79587910d23 100644 --- a/neutron/agent/l3/ha.py +++ b/neutron/agent/l3/ha.py @@ -182,6 +182,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',