Merge "Fix update of ports cache in router_info class"

This commit is contained in:
Zuul 2019-02-09 14:46:56 +00:00 committed by Gerrit Code Review
commit 6d5e32fbc7
2 changed files with 48 additions and 15 deletions

View File

@ -493,9 +493,23 @@ class RouterInfo(object):
ip_devs = ip_wrapper.get_devices()
return [ip_dev.name for ip_dev in ip_devs]
def _update_internal_ports_cache(self, port):
# NOTE(slaweq): self.internal_ports is a list of port objects but
# when it is updated in _process_internal_ports() method,
# but it can be based only on indexes of elements in
# self.internal_ports as index of element to updated is unknown.
# It has to be done based on port_id and this method is doing exactly
# that.
for index, p in enumerate(self.internal_ports):
if p['id'] == port['id']:
self.internal_ports[index] = port
break
else:
self.internal_ports.append(port)
@staticmethod
def _get_updated_ports(existing_ports, current_ports):
updated_ports = dict()
updated_ports = []
current_ports_dict = {p['id']: p for p in current_ports}
for existing_port in existing_ports:
current_port = current_ports_dict.get(existing_port['id'])
@ -507,7 +521,7 @@ class RouterInfo(object):
key=helpers.safe_sort_key))
mtu_changed = existing_port['mtu'] != current_port['mtu']
if fixed_ips_changed or mtu_changed:
updated_ports[current_port['id']] = current_port
updated_ports.append(current_port)
return updated_ports
@staticmethod
@ -563,7 +577,7 @@ class RouterInfo(object):
for p in new_ports:
self.internal_network_added(p)
LOG.debug("appending port %s to internal_ports cache", p)
self.internal_ports.append(p)
self._update_internal_ports_cache(p)
enable_ra = enable_ra or self._port_has_ipv6_subnet(p)
for subnet in p['subnets']:
if ipv6_utils.is_ipv6_pd_enabled(subnet):
@ -586,11 +600,8 @@ class RouterInfo(object):
del self.pd_subnets[subnet['id']]
updated_cidrs = []
if updated_ports:
for index, p in enumerate(internal_ports):
if not updated_ports.get(p['id']):
continue
self.internal_ports[index] = updated_ports[p['id']]
for p in updated_ports:
self._update_internal_ports_cache(p)
interface_name = self.get_internal_device_name(p['id'])
ip_cidrs = common_utils.fixed_ip_cidrs(p['fixed_ips'])
LOG.debug("updating internal network for port %s", p)

View File

@ -209,6 +209,28 @@ class TestRouterInfo(base.BaseTestCase):
p_i_p.assert_called_once_with()
p_e_o_d.assert_called_once_with()
def test__update_internal_ports_cache(self):
ri = router_info.RouterInfo(mock.Mock(), _uuid(), {}, **self.ri_kwargs)
ri.internal_ports = [
{'id': 'port-id-1', 'mtu': 1500},
{'id': 'port-id-2', 'mtu': 2000}]
initial_internal_ports = ri.internal_ports[:]
# Test add new element to the cache
new_port = {'id': 'new-port-id', 'mtu': 1500}
ri._update_internal_ports_cache(new_port)
self.assertEqual(
initial_internal_ports + [new_port],
ri.internal_ports)
# Test update existing port in cache
updated_port = new_port.copy()
updated_port['mtu'] = 2500
ri._update_internal_ports_cache(updated_port)
self.assertEqual(
initial_internal_ports + [updated_port],
ri.internal_ports)
class BasicRouterTestCaseFramework(base.BaseTestCase):
def _create_router(self, router=None, **kwargs):