def test_iface_to_br_handles_ovs_vsctl_exception(self):
        iface = "tap0"
        root_helper = "sudo"
        self.execute.side_effect = Exception

        self.assertIsNone(ovs_lib.get_bridge_for_iface(root_helper, iface))
        self.execute.assert_called_once_with(["ovs-vsctl", self.TO, "iface-to-br", iface], root_helper=root_helper)

    def test_iface_to_br_handles_ovs_vsctl_exception(self):
        iface = "tap0"
        root_helper = "sudo"
        utils.execute(["ovs-vsctl", self.TO, "iface-to-br", iface], root_helper=root_helper).AndRaise(Exception)

        self.mox.ReplayAll()
        self.assertIsNone(ovs_lib.get_bridge_for_iface(root_helper, iface))
        self.mox.VerifyAll()

    def test_iface_to_br(self):
        iface = "tap0"
        br = "br-int"
        root_helper = "sudo"
        utils.execute(["ovs-vsctl", self.TO, "iface-to-br", iface], root_helper=root_helper).AndReturn("br-int")

        self.mox.ReplayAll()
        self.assertEqual(ovs_lib.get_bridge_for_iface(root_helper, iface), br)
        self.mox.VerifyAll()

 def _test_iface_to_br(self, exp_timeout=None):
     iface = 'tap0'
     br = 'br-int'
     root_helper = 'sudo'
     self.execute.return_value = 'br-int'
     exp_timeout_str = self._build_timeout_opt(exp_timeout)
     self.assertEqual(ovs_lib.get_bridge_for_iface(root_helper, iface), br)
     self.execute.assert_called_once_with(
         ["ovs-vsctl", exp_timeout_str, "iface-to-br", iface],
         root_helper=root_helper)

    def test_iface_to_br(self):
        iface = 'tap0'
        br = 'br-int'
        root_helper = 'sudo'
        self.execute.return_value = 'br-int'

        self.assertEqual(ovs_lib.get_bridge_for_iface(root_helper, iface), br)
        self.execute.assert_called_once_with(
            ["ovs-vsctl", self.TO, "iface-to-br", iface],
            root_helper=root_helper)

def unplug_device(conf, device):
    try:
        device.link.delete()
    except RuntimeError:
        root_helper = agent_config.get_root_helper(conf)
        # Maybe the device is OVS port, so try to delete
        bridge_name = ovs_lib.get_bridge_for_iface(root_helper, device.name)
        if bridge_name:
            bridge = ovs_lib.OVSBridge(bridge_name, root_helper)
            bridge.delete_port(device.name)
        else:
            LOG.debug(_('Unable to find bridge for device: %s'), device.name)