From d966845e5b80b1cec3cbfe25e4a7e1542e9fca65 Mon Sep 17 00:00:00 2001 From: Rodolfo Alonso Hernandez Date: Sun, 6 Mar 2022 11:12:03 +0000 Subject: [PATCH] [OVN] Remove maintenance "check_for_localnet_legacy_port_name" Remove maintenance task "check_for_localnet_legacy_port_name". This method was added in [1], four releases ago. We can now be sure any logical switch port will have the correct field "name" value. Related-Bug: #1865889 [1]https://review.opendev.org/c/openstack/neutron/+/715157 Change-Id: I71bb605582e2572807e1f38f7ee5b8dd91ab0c4a --- .../ovn/mech_driver/ovsdb/maintenance.py | 40 ------------------- 1 file changed, 40 deletions(-) diff --git a/neutron/plugins/ml2/drivers/ovn/mech_driver/ovsdb/maintenance.py b/neutron/plugins/ml2/drivers/ovn/mech_driver/ovsdb/maintenance.py index 92c27b496f0..cca4eeab809 100644 --- a/neutron/plugins/ml2/drivers/ovn/mech_driver/ovsdb/maintenance.py +++ b/neutron/plugins/ml2/drivers/ovn/mech_driver/ovsdb/maintenance.py @@ -22,7 +22,6 @@ import threading from futurist import periodics from neutron_lib.api.definitions import external_net from neutron_lib.api.definitions import provider_net as pnet -from neutron_lib.api.definitions import segment as segment_def from neutron_lib import constants as n_const from neutron_lib import context as n_context from neutron_lib import exceptions as n_exc @@ -36,7 +35,6 @@ from neutron.common.ovn import utils from neutron.conf.plugins.ml2.drivers.ovn import ovn_conf from neutron.db import ovn_hash_ring_db as hash_ring_db from neutron.db import ovn_revision_numbers_db as revision_numbers_db -from neutron.db import segments_db from neutron.plugins.ml2.drivers.ovn.mech_driver.ovsdb import ovn_db_sync @@ -640,44 +638,6 @@ class DBInconsistenciesPeriodics(SchemaAwarePeriodicsBase): raise periodics.NeverAgain() - # A static spacing value is used here, but this method will only run - # once per lock due to the use of periodics.NeverAgain(). - @periodics.periodic(spacing=600, run_immediately=True) - def check_for_localnet_legacy_port_name(self): - if not self.has_lock: - return - - admin_context = n_context.get_admin_context() - cmds = [] - for ls in self._nb_idl.ls_list().execute(check_error=True): - network_id = ls.name.replace('neutron-', '') - legacy_name = utils.ovn_provnet_port_name(network_id) - legacy_port = None - segment_id = None - for lsp in ls.ports: - if legacy_name == lsp.name: - legacy_port = lsp - break - else: - continue - for segment in segments_db.get_network_segments( - admin_context, network_id): - if (segment.get(segment_def.PHYSICAL_NETWORK) == - legacy_port.options['network_name']): - segment_id = segment['id'] - break - if not segment_id: - continue - new_p_name = utils.ovn_provnet_port_name(segment_id) - cmds.append(self._nb_idl.db_set('Logical_Switch_Port', - legacy_port.uuid, - ('name', new_p_name))) - if cmds: - with self._nb_idl.transaction(check_error=True) as txn: - for cmd in cmds: - txn.add(cmd) - raise periodics.NeverAgain() - # TODO(lucasagomes): Remove this in the Z cycle # A static spacing value is used here, but this method will only run # once per lock due to the use of periodics.NeverAgain().