Java 类net.floodlightcontroller.core.test.MockThreadPoolService 实例源码

项目：fresco_floodlight 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：iTAP-controller 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：SDN-Multicast 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：arscheduler 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：QoS-floodlight 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight1.2-delay 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：floodlight-hardware 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：ACAMPController 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：fast-failover-demo 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：floodlightLB 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(IOFSwitchService.class, new MockSwitchManager());
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：DSC 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：Multipath-Hedera-system-in-Floodlight-controller 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight_with_topoguard 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：FloodligtModule 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：smartenit 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：multicastSDN 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight-qosmanager 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight-nfv 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：HederaInFloodlight 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：floodlight-oss 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：my-floodlight 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：FL_HAND 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：sdn-project 文件：FlowReconcileMgrTest.java

@Before
public void setUp() throws Exception {
    super.setUp();

    fmc = new FloodlightModuleContext();
    flowReconcileMgr = new FlowReconcileManager();
    threadPool = new MockThreadPoolService();
    counterStore = createMock(ICounterStoreService.class);

    fmc.addService(ICounterStoreService.class, counterStore);
    fmc.addService(IThreadPoolService.class, threadPool);

    threadPool.init(fmc);
    flowReconcileMgr.init(fmc);

    threadPool.startUp(fmc);
    flowReconcileMgr.startUp(fmc);
}

项目：fresco_floodlight 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：iTAP-controller 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：SDN-Multicast 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：arscheduler 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：QoS-floodlight 文件：LinkDiscoveryManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    FloodlightModuleContext cntx = new FloodlightModuleContext();
    ldm = new TestLinkDiscoveryManager();
    TopologyManager routingEngine = new TopologyManager();
    ldm.linkDiscoveryAware = new ArrayList<ILinkDiscoveryListener>();
    MockThreadPoolService tp = new MockThreadPoolService();
    RestApiServer restApi = new RestApiServer();
    cntx.addService(IRestApiService.class, restApi);
    cntx.addService(IThreadPoolService.class, tp);
    cntx.addService(IRoutingService.class, routingEngine);
    cntx.addService(ILinkDiscoveryService.class, ldm);
    cntx.addService(ITopologyService.class, ldm);
    cntx.addService(IStorageSourceService.class, new MemoryStorageSource());
    cntx.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    restApi.init(cntx);
    tp.init(cntx);
    routingEngine.init(cntx);
    ldm.init(cntx);
    restApi.startUp(cntx);
    tp.startUp(cntx);
    routingEngine.startUp(cntx);
    ldm.startUp(cntx);

    IOFSwitch sw1 = createMockSwitch(1L);
    IOFSwitch sw2 = createMockSwitch(2L);
    Map<Long, IOFSwitch> switches = new HashMap<Long, IOFSwitch>();
    switches.put(1L, sw1);
    switches.put(2L, sw2);
    getMockFloodlightProvider().setSwitches(switches);
    replay(sw1, sw2);
}

项目：QoS-floodlight 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：QoS-floodlight 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    linkDiscovery = EasyMock.createMock(ILinkDiscoveryService.class);
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    fmc.addService(ILinkDiscoveryService.class, linkDiscovery);
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}

项目：floodlight1.2-delay 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：floodlight-hardware 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：ACAMPController 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：fast-failover-demo 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：floodlightLB 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：DSC 文件：TopologyManagerTest.java

@Override
@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    fmc.addService(IDebugCounterService.class, new MockDebugCounterService());
    fmc.addService(IDebugEventService.class, new MockDebugEventService());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：Multipath-Hedera-system-in-Floodlight-controller 文件：LinkDiscoveryManagerTest.java

@Before
public void setUp() throws Exception {
    super.setUp();
    FloodlightModuleContext cntx = new FloodlightModuleContext();
    ldm = new TestLinkDiscoveryManager();
    TopologyManager routingEngine = new TopologyManager();
    ldm.linkDiscoveryAware = new ArrayList<ILinkDiscoveryListener>();
    MockThreadPoolService tp = new MockThreadPoolService();
    RestApiServer restApi = new RestApiServer();
    cntx.addService(IRestApiService.class, restApi);
    cntx.addService(IThreadPoolService.class, tp);
    cntx.addService(IRoutingService.class, routingEngine);
    cntx.addService(ILinkDiscoveryService.class, ldm);
    cntx.addService(ITopologyService.class, ldm);
    cntx.addService(IStorageSourceService.class, new MemoryStorageSource());
    cntx.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    restApi.init(cntx);
    tp.init(cntx);
    routingEngine.init(cntx);
    ldm.init(cntx);
    restApi.startUp(cntx);
    tp.startUp(cntx);
    routingEngine.startUp(cntx);
    ldm.startUp(cntx);

    IOFSwitch sw1 = createMockSwitch(1L);
    IOFSwitch sw2 = createMockSwitch(2L);
    Map<Long, IOFSwitch> switches = new HashMap<Long, IOFSwitch>();
    switches.put(1L, sw1);
    switches.put(2L, sw2);
    getMockFloodlightProvider().setSwitches(switches);
    replay(sw1, sw2);
}

项目：Multipath-Hedera-system-in-Floodlight-controller 文件：TopologyManagerTest.java

@Before
public void setUp() throws Exception {
    super.setUp();
    fmc = new FloodlightModuleContext();
    fmc.addService(IFloodlightProviderService.class, getMockFloodlightProvider());
    MockThreadPoolService tp = new MockThreadPoolService();
    fmc.addService(IThreadPoolService.class, tp);
    tm  = new TopologyManager();
    tp.init(fmc);
    tm.init(fmc);
    tp.startUp(fmc);
}

项目：Multipath-Hedera-system-in-Floodlight-controller 文件：TopologyInstanceTest.java

@Before 
public void SetUp() throws Exception {
    fmc = new FloodlightModuleContext();
    mockFloodlightProvider = new MockFloodlightProvider();
    fmc.addService(IFloodlightProviderService.class, mockFloodlightProvider);
    MockThreadPoolService tp = new MockThreadPoolService();
    topologyManager  = new TopologyManager();
    fmc.addService(IThreadPoolService.class, tp);
    topologyManager.init(fmc);
    tp.init(fmc);
    tp.startUp(fmc);
}