import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Before
public void setUp() {
    networkConfigListener = createMock(NetworkConfigListener.class);
    deviceService = new TestDeviceService();
    deviceListener = createMock(DeviceListener.class);

    interfaceListener = createMock(InterfaceListener.class);
    deviceService.addListener(deviceListener);
    setUpInterfaceService();
    interfaceService = new InternalInterfaceService();
    interfaceService.addListener(interfaceListener);
    networkConfigService = new TestNetworkConfigService();
    networkConfigService.addListener(networkConfigListener);
    flowObjectiveService = createMock(FlowObjectiveService.class);
    setUpFlowObjectiveService();
    controlPlaneRedirectManager.coreService = coreService;
    controlPlaneRedirectManager.flowObjectiveService = flowObjectiveService;
    controlPlaneRedirectManager.networkConfigService = networkConfigService;
    controlPlaneRedirectManager.interfaceService = interfaceService;
    controlPlaneRedirectManager.deviceService = deviceService;
    controlPlaneRedirectManager.hostService = createNiceMock(HostService.class);
    controlPlaneRedirectManager.mastershipService = mastershipService;
    controlPlaneRedirectManager.activate();
    verify(flowObjectiveService);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Test
public void deviceEventTest() {
    // Make four router topology with SR-TE capabilities.
    build4RouterTopo(true, false, true, true, 0);

    // Add new L3 device
    DefaultAnnotations.Builder builderDev5 = DefaultAnnotations.builder();
    builderDev5.set(AnnotationKeys.TYPE, L3);
    builderDev5.set(LSRID, "5.5.5.5");

    Device dev5 = new MockDevice(DeviceId.deviceId("P005"), builderDev5.build());
    deviceService.addDevice(dev5);

    // Add capability
    DeviceCapability device5Cap = netConfigRegistry.addConfig(DeviceId.deviceId("5.5.5.5"), DeviceCapability.class);
    device5Cap.setLabelStackCap(true)
            .setLocalLabelCap(false)
            .setSrCap(true)
            .apply();

    // Get listener
    DeviceListener listener = deviceService.getListener();

    // Generate Remove events
    deviceService.removeDevice(dev5);
    DeviceEvent event = new DeviceEvent(DeviceEvent.Type.DEVICE_REMOVED, dev5);
    listener.event(event);

    assertThat(pceStore.getGlobalNodeLabel(dev5.id()), is(nullValue()));
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void removeListener(DeviceListener listener) {
    DeviceListener wrappedListener = wrapped.remove(listener);
    if (wrappedListener != null) {
        super.removeListener(wrappedListener);
    }
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
/**
 * Tests receipt of a device up event.
 *
 * @throws TestUtilsException if lookup of a field fails
 */
@Test
public void deviceUpEvent() throws TestUtilsException {
    TrafficSelector selector = DefaultTrafficSelector.emptySelector();
    TrafficTreatment treatment = DefaultTrafficTreatment.emptyTreatment();

    DeviceEvent event = new DeviceEvent(DeviceEvent.Type.DEVICE_ADDED, d2);
    DeviceListener listener = TestUtils.getField(manager, "deviceListener");
    assertThat(listener, notNullValue());

    listener.event(event);

    ForwardingObjective forward =
            DefaultForwardingObjective.builder()
                    .fromApp(NetTestTools.APP_ID)
                    .withFlag(ForwardingObjective.Flag.SPECIFIC)
                    .withSelector(selector)
                    .withTreatment(treatment)
                    .makePermanent()
                    .add();
    manager.forward(id2, forward);

    // new device should have an objective now
    TestTools.assertAfter(RETRY_MS, () ->
            assertThat(forwardingObjectives, hasSize(1)));

    assertThat(forwardingObjectives, hasItem("of:d2"));
    assertThat(filteringObjectives, hasSize(0));
    assertThat(nextObjectives, hasSize(0));
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
/**
 * Creates a fake topology to feed into the ARP module.
 * <p>
 * The default topology is a unidirectional ring topology. Each switch has
 * 3 ports. Ports 2 and 3 have the links to neighbor switches, and port 1
 * is free (edge port).
 * The first half of the switches have IP addresses configured on their
 * free ports (port 1). The second half of the switches have no IP
 * addresses configured.
 */
private void createTopology() {
    deviceService = createMock(DeviceService.class);
    linkService = createMock(LinkService.class);

    deviceService.addListener(anyObject(DeviceListener.class));
    linkService.addListener(anyObject(LinkListener.class));

    createDevices(NUM_DEVICES, NUM_PORTS_PER_DEVICE);
    createLinks(NUM_DEVICES);
    addIntfConfig();
    popluateEdgePortService();
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
/**
 * Creates a fake topology to feed into the ARP module.
 * <p/>
 * The default topology is a unidirectional ring topology. Each switch has
 * 3 ports. Ports 2 and 3 have the links to neighbor switches, and port 1
 * is free (edge port).
 * The first half of the switches have IP addresses configured on their
 * free ports (port 1). The second half of the switches have no IP
 * addresses configured.
 */
private void createTopology() {
    deviceService = createMock(DeviceService.class);
    linkService = createMock(LinkService.class);

    deviceService.addListener(anyObject(DeviceListener.class));
    linkService.addListener(anyObject(LinkListener.class));

    createDevices(NUM_DEVICES, NUM_PORTS_PER_DEVICE);
    createLinks(NUM_DEVICES);
    addAddressBindings();
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Before
public void setUp() {
    networkConfigListener = createMock(NetworkConfigListener.class);
    deviceService = new TestDeviceService();
    deviceListener = createMock(DeviceListener.class);

    interfaceListener = createMock(InterfaceListener.class);
    deviceService.addListener(deviceListener);
    setUpInterfaceService();
    interfaceService = new InternalInterfaceService();
    interfaceService.addListener(interfaceListener);
    networkConfigService = new TestNetworkConfigService();
    networkConfigService.addListener(networkConfigListener);
    flowObjectiveService = createMock(FlowObjectiveService.class);
    applicationService = createNiceMock(ApplicationService.class);
    replay(applicationService);
    setUpFlowObjectiveService();
    controlPlaneRedirectManager.coreService = coreService;
    controlPlaneRedirectManager.flowObjectiveService = flowObjectiveService;
    controlPlaneRedirectManager.networkConfigService = networkConfigService;
    controlPlaneRedirectManager.interfaceService = interfaceService;
    controlPlaneRedirectManager.deviceService = deviceService;
    controlPlaneRedirectManager.hostService = createNiceMock(HostService.class);
    controlPlaneRedirectManager.mastershipService = mastershipService;
    controlPlaneRedirectManager.applicationService = applicationService;
    controlPlaneRedirectManager.activate(new ComponentContextAdapter());
    verify(flowObjectiveService);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    this.listener = listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    deviceListener = listener;

}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    deviceListener = listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    deviceListeners.add(listener);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void removeListener(DeviceListener listener) {
    deviceListeners.remove(listener);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    SingleSwitchFibInstallerTest.this.deviceListener = listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    ControlPlaneRedirectManagerTest.this.deviceListener = listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
/**
 * Get the listener.
 */
public DeviceListener getListener() {
    return listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    delegate.addListener(listener);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void removeListener(DeviceListener listener) {
    delegate.removeListener(listener);
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
    super.addListener(wrapped.computeIfAbsent(listener, OpticalDeviceListener::new));
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
public OpticalDeviceListener(DeviceListener listener) {
    this.listener = listener;
}
 

import org.onosproject.net.device.DeviceListener; //导入依赖的package包/类
@Override
public void addListener(DeviceListener listener) {
}