x/vmware-nsx
Code Issues Proposed changes

V2T migration: Update FWaaS group status from driver

Browse Source 
When the migration takes place, the rpc queues are not working so the
group's status should be updated in the DB directly

Change-Id: I7a1afe751f329eabb055dccb7d5367c47de12426
This commit is contained in:
asarfaty 2021-03-18 10:56:23 +02:00 committed by Adit Sarfaty
parent 44915a99b4
commit 870cba3810
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
vmware_nsx/services/fwaas/nsx_v3/edge_fwaas_driver_base.py
View File

@ -13,12 +13,21 @@
# License for the specific language governing permissions and limitations # License for the specific language governing permissions and limitations
# under the License. # under the License.
from neutron_lib import constants as nl_constants
from neutron_lib import context as n_context from neutron_lib import context as n_context
from neutron_lib.exceptions import firewall_v2 as exceptions from neutron_lib.exceptions import firewall_v2 as exceptions
from oslo_config import cfg
from oslo_log import log as logging from oslo_log import log as logging
from vmware_nsx.services.fwaas.common import fwaas_driver_base from vmware_nsx.services.fwaas.common import fwaas_driver_base
try:
from neutron_fwaas.db.firewall.v2 import firewall_db_v2
except ImportError:
# FWaaS project no found
from vmware_nsx.services.fwaas.common import fwaas_mocks \
as firewall_db_v2
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
@ -61,6 +70,14 @@ class CommonEdgeFwaasV3Driver(fwaas_driver_base.EdgeFwaasDriverBaseV2):
"%s", router_id, e) "%s", router_id, e)
raise self.driver_exception(driver=self.driver_name) raise self.driver_exception(driver=self.driver_name)
if cfg.CONF.api_replay_mode and len(routers) > 0:
# In api replay mode the RPC isn't working so the FW group status
# should be updated directly
with context.session.begin(subtransactions=True):
group = (context.session.query(firewall_db_v2.FirewallGroup).
filter_by(id=fwg_id).one())
group['status'] = nl_constants.ACTIVE
def should_apply_firewall_to_router(self, router_data): def should_apply_firewall_to_router(self, router_data):
"""Return True if the firewall rules should be added the router""" """Return True if the firewall rules should be added the router"""
if not router_data.get('external_gateway_info'): if not router_data.get('external_gateway_info'):