Merge "[OVN] Wait for WaitForDataPathBindingCreateEvent event in functional tests" into stable/ussuri

This commit is contained in:
Zuul 2020-07-19 01:34:47 +00:00 committed by Gerrit Code Review
commit f3418f852a
1 changed files with 15 additions and 2 deletions

View File

@ -38,6 +38,17 @@ class WaitForMACBindingDeleteEvent(event.WaitEvent):
events, table, conditions, timeout=15)
class WaitForDataPathBindingCreateEvent(event.WaitEvent):
event_name = 'WaitForDataPathBindingCreateEvent'
def __init__(self, net_name):
table = 'Datapath_Binding'
events = (self.ROW_CREATE,)
conditions = (('external_ids', '=', {'name2': net_name}),)
super(WaitForDataPathBindingCreateEvent, self).__init__(
events, table, conditions, timeout=15)
class DistributedLockTestEvent(event.WaitEvent):
ONETIME = False
COUNTER = 0
@ -124,10 +135,12 @@ class TestNBDbMonitor(base.TestOVNFunctionalBase):
* Delete the FIP.
* Check that the MAC_Binding entry gets deleted.
"""
self._make_network(self.fmt, 'network1', True)
net_name = 'network1'
self._make_network(self.fmt, net_name, True)
row_event = WaitForDataPathBindingCreateEvent(net_name)
dp = self.sb_api.db_find(
'Datapath_Binding',
('external_ids', '=', {'name2': 'network1'})).execute()
('external_ids', '=', {'name2': net_name})).execute()
macb_id = self.sb_api.db_create('MAC_Binding', datapath=dp[0]['_uuid'],
ip='100.0.0.21').execute()
port = self.create_port()