Add ChassisPrivateCreateEvent to the events

We were only adding the ChassisCreateEvent, but if Chassis_Private
table is present, we should also add the event related to it

Change-Id: I40cf7d4c04636160ac65dfe32664430878d72b9c
This commit is contained in:
Luis Tomas Bolivar 2023-03-15 10:36:39 +01:00
parent 99c416deec
commit d9e753d17d
2 changed files with 6 additions and 2 deletions
ovn_bgp_agent/drivers/openstack

View File

@ -120,6 +120,7 @@ class OVNBGPDriver(driver_api.AgentDriverBase):
tables=OVN_TABLES + ["Chassis_Private"], tables=OVN_TABLES + ["Chassis_Private"],
events=events).start() events=events).start()
except AssertionError: except AssertionError:
events.remove("ChassisPrivateCreateEvent")
self.sb_idl = ovn.OvnSbIdl( self.sb_idl = ovn.OvnSbIdl(
self.ovn_remote, self.ovn_remote,
chassis=self.chassis, chassis=self.chassis,
@ -135,7 +136,8 @@ class OVNBGPDriver(driver_api.AgentDriverBase):
"FIPSetEvent", "FIPSetEvent",
"FIPUnsetEvent", "FIPUnsetEvent",
"OVNLBMemberCreateDeleteEvent", "OVNLBMemberCreateDeleteEvent",
"ChassisCreateEvent"]) "ChassisCreateEvent",
"ChassisPrivateCreateEvent"])
if self._expose_tenant_networks: if self._expose_tenant_networks:
events.update(["SubnetRouterAttachedEvent", events.update(["SubnetRouterAttachedEvent",
"SubnetRouterDetachedEvent", "SubnetRouterDetachedEvent",

View File

@ -87,6 +87,7 @@ class OVNEVPNDriver(driver_api.AgentDriverBase):
tables=OVN_TABLES + ["Chassis_Private"], tables=OVN_TABLES + ["Chassis_Private"],
events=events).start() events=events).start()
except AssertionError: except AssertionError:
events.remove("ChassisPrivateCreateEvent")
self.sb_idl = ovn.OvnSbIdl( self.sb_idl = ovn.OvnSbIdl(
self.ovn_remote, self.ovn_remote,
chassis=self.chassis, chassis=self.chassis,
@ -103,7 +104,8 @@ class OVNEVPNDriver(driver_api.AgentDriverBase):
"SubnetRouterDetachedEvent", "SubnetRouterDetachedEvent",
"TenantPortCreatedEvent", "TenantPortCreatedEvent",
"TenantPortDeletedEvent", "TenantPortDeletedEvent",
"ChassisCreateEvent"]) "ChassisCreateEvent",
"ChassisPrivateCreateEvent"])
return events return events
@lockutils.synchronized('evpn') @lockutils.synchronized('evpn')