openstack
/
neutron
Code Issues Proposed changes

Merge "[Trivial]Remove unused helper get_port_external_ids/mac"

This commit is contained in:
Zuul 2019-08-15 16:09:31 +00:00 committed by Gerrit Code Review
parent 2a97ffe892 3b1083b1e4
commit 905b9aea7a
2 changed files with 0 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
neutron/agent/common/ovs_lib.py
View File

@ -372,24 +372,6 @@ class OVSBridge(BaseOVS):
port_name)
return ofport
def get_port_external_ids(self, port_name):
"""Get the port's assigned ofport, retrying if not yet assigned."""
port_external_ids = dict()
try:
port_external_ids = self._get_port_val(port_name, "external_ids")
except tenacity.RetryError:
LOG.exception("Timed out retrieving external_ids on port %s.",
port_name)
return port_external_ids
def get_port_mac(self, port_name):
"""Get the port's mac address.
This is especially useful when the port is not a neutron port.
E.g. networking-sfc needs the MAC address of "patch-tun
"""
return self.db_get_val("Interface", port_name, "mac_in_use")
@_ovsdb_retry
def _get_datapath_id(self):
return self.db_get_val('Bridge', self.br_name, 'datapath_id')

20
neutron/tests/unit/agent/common/test_ovs_lib.py
View File

@ -526,26 +526,6 @@ class OVS_Lib_Test(base.BaseTestCase):
self.assertRaises(tenacity.RetryError,
self.br._get_port_val, '1', 'ofport')
def test_get_port_external_ids_retry(self):
external_ids = [["iface-id", "tap99id"],
["iface-status", "active"],
["attached-mac", "de:ad:be:ef:13:37"]]
with mock.patch.object(
self.br, 'db_get_val',
side_effect=[[], [], [], [], external_ids]):
self.assertEqual(external_ids,
self.br._get_port_val('1', 'external_ids'))
def test_get_port_external_ids_retry_fails(self):
# reduce timeout for faster execution
self.br.ovsdb_timeout = 1
# after 7 calls the retry will timeout and raise
with mock.patch.object(
self.br, 'db_get_val',
side_effect=[[] for _ in range(7)]):
self.assertRaises(tenacity.RetryError,
self.br._get_port_val, '1', 'external_ids')
def test_set_controller_rate_limit(self):
with mock.patch.object(
self.br, "set_controller_field"