openstack
/
neutron
Code Issues Proposed changes

Merge "Async notify neutron-server for HA states" into stable/ocata

This commit is contained in:
Zuul 2019-05-25 01:14:55 +00:00 committed by Gerrit Code Review
parent 115c3ed6d2 5d39377d51
commit 19506f3116
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
neutron/agent/l3/agent.py
View File

@ -144,7 +144,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):

3
neutron/agent/l3/ha.py
View File

@ -171,6 +171,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',