import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
/**
 * @param role initial role
 * @param roleChangeDescription initial value of the change description
 * @throws NullPointerException if role or roleChangeDescription is null
 */
public RoleManager(@Nonnull Controller controller,
        @Nonnull IShutdownService shutdownService,
        @Nonnull HARole role,
        @Nonnull String roleChangeDescription) {
    Preconditions.checkNotNull(controller, "controller must not be null");
    Preconditions.checkNotNull(role, "role must not be null");
    Preconditions.checkNotNull(roleChangeDescription, "roleChangeDescription must not be null");
    Preconditions.checkNotNull(shutdownService, "shutdownService must not be null");

    this.currentRoleInfo = new RoleInfo(role,
                                   roleChangeDescription,
                                   new Date());
    this.controller = controller;
    this.shutdownService = shutdownService;
    this.counters = new RoleManagerCounters(controller.getDebugCounter());
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
private void doSetUp(HARole role) {
    controller = createMock(Controller.class);

    // Mock controller behavior
    reset(controller);
    IDebugCounterService counterService = new MockDebugCounterService();
    expect(controller.getDebugCounter()).andReturn(counterService).anyTimes();
    replay(controller);


    IShutdownService shutdownService = createMock(IShutdownService.class);
    roleManager = new RoleManager(controller, shutdownService , role, "test");

    // Make sure the desired role is set
    assertTrue(roleManager.getRole().equals(role));
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
/**
 * @param role initial role
 * @param roleChangeDescription initial value of the change description
 * @throws NullPointerException if role or roleChangeDescription is null
 */
public RoleManager(@Nonnull Controller controller,
        @Nonnull IShutdownService shutdownService,
        @Nonnull HARole role,
        @Nonnull String roleChangeDescription,
        @Nonnull IClusterService clusterService) {
    Preconditions.checkNotNull(controller, "controller must not be null");
    Preconditions.checkNotNull(role, "role must not be null");
    Preconditions.checkNotNull(roleChangeDescription, "roleChangeDescription must not be null");
    Preconditions.checkNotNull(shutdownService, "shutdownService must not be null");
    Preconditions.checkNotNull(clusterService, "clusterService must not be null");
    
    this.currentRoleInfo = new RoleInfo(role,
                                   roleChangeDescription,
                                   new Date());
    this.controller = controller;
    this.shutdownService = shutdownService;
    this.counters = new RoleManagerCounters(controller.getDebugCounter());
    this.clusterService=clusterService;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
private void doSetUp(HARole role) {
    controller = createMock(Controller.class);

    // Mock controller behavior
    reset(controller);
    IDebugCounterService counterService = new MockDebugCounterService();
    expect(controller.getDebugCounter()).andReturn(counterService).anyTimes();
    replay(controller);


    IShutdownService shutdownService = createMock(IShutdownService.class);
    roleManager = new RoleManager(controller, shutdownService , role, "test",null);

    // Make sure the desired role is set
    assertTrue(roleManager.getRole().equals(role));
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public Collection<Class<? extends IFloodlightService>>
        getModuleDependencies() {
    ArrayList<Class<? extends IFloodlightService>> deps = new ArrayList<Class<? extends IFloodlightService>>();
    deps.add(IShutdownService.class);
    return deps;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public void startUp(FloodlightModuleContext context) {
    IShutdownService shutdownService =
            context.getServiceImpl(IShutdownService.class);
    shutdownService.registerShutdownListener(new ShutdownListenenerDelegate());
    DebugEventAppender.setDebugEventServiceImpl(this);
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public Collection<Class<? extends IFloodlightService>> getModuleDependencies() {
	Collection<Class<? extends IFloodlightService>> l =
			new ArrayList<Class<? extends IFloodlightService>>();
	l.add(IFloodlightProviderService.class);
	l.add(IStorageSourceService.class);
	l.add(IThreadPoolService.class);
	l.add(IRestApiService.class);
	l.add(IShutdownService.class);
	return l;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public Collection<Class<? extends IFloodlightService>> getModuleDependencies() {
    ArrayList<Class<? extends IFloodlightService>> deps =
            new ArrayList<Class<? extends IFloodlightService>>();
    deps.add(IShutdownService.class);
    return deps;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public Collection<Class<? extends IFloodlightService>> getModuleServices() {
    Collection<Class<? extends IFloodlightService>> l =
            new ArrayList<>();
    l.add(IShutdownService.class);
    return l;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
public Map<Class<? extends IFloodlightService>, IFloodlightService>
getServiceImpls() {
    Map<Class<? extends IFloodlightService>, IFloodlightService> m =
            new HashMap<>();
    m.put(IShutdownService.class, this);
    return m;
}
 

import net.floodlightcontroller.core.IShutdownService; //导入依赖的package包/类
@Override
@Before
public void setUp() throws Exception {
    debugEvent = new DebugEventService();
    FloodlightModuleContext fmc = new FloodlightModuleContext();
    IShutdownService shutdownService =
            EasyMock.createMock(IShutdownService.class);
    shutdownService.registerShutdownListener(anyObject(IShutdownListener.class));
    EasyMock.expectLastCall().once();
    EasyMock.replay(shutdownService);
    fmc.addService(IShutdownService.class, shutdownService);
    debugEvent.startUp(fmc);
    EasyMock.verify(shutdownService);
}