

def test_get_events_includes_ofport(self):
    utils.wait_until_true((lambda : self.monitor.has_updates))
    p1.monitor.get_events()
    br = self.useFixture(net_helpers.OVSBridgeFixture())
    p1 = self.useFixture(net_helpers.OVSPortFixture(br.bridge))

    def p1_event_has_ofport():
        if (not self.monitor.has_updates):
            return
        for e in self.monitor.new_events['added']:
            if ((e['name'] == p1.port.name) and (e['ofport'] != ovs_lib.UNASSIGNED_OFPORT)):
                return True
    utils.wait_until_true(p1_event_has_ofport)

dataset/ETHPy150Open openstack/neutron/neutron/tests/functional/agent/linux/test_ovsdb_monitor.py TestSimpleInterfaceMonitor.test_get_events_includes_ofport/VarMisuse@25/35 `self`->`p1`