/** * @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()); }
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)); }
/** * @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; }
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)); }
@Override public Collection<Class<? extends IFloodlightService>> getModuleDependencies() { ArrayList<Class<? extends IFloodlightService>> deps = new ArrayList<Class<? extends IFloodlightService>>(); deps.add(IShutdownService.class); return deps; }
@Override public void startUp(FloodlightModuleContext context) { IShutdownService shutdownService = context.getServiceImpl(IShutdownService.class); shutdownService.registerShutdownListener(new ShutdownListenenerDelegate()); DebugEventAppender.setDebugEventServiceImpl(this); }
@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; }
@Override public Collection<Class<? extends IFloodlightService>> getModuleServices() { Collection<Class<? extends IFloodlightService>> l = new ArrayList<>(); l.add(IShutdownService.class); return l; }
@Override public Map<Class<? extends IFloodlightService>, IFloodlightService> getServiceImpls() { Map<Class<? extends IFloodlightService>, IFloodlightService> m = new HashMap<>(); m.put(IShutdownService.class, this); return m; }
@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); }