Home | History | Annotate | Download | only in concurrent

Lines Matching refs:service

64     WaitOnRunService service = new WaitOnRunService();
65 assertFalse(service.startUpCalled);
67 service.startAsync().awaitRunning();
68 assertTrue(service.startUpCalled);
69 assertEquals(Service.State.RUNNING, service.state());
71 enterRun.await(); // to avoid stopping the service until run() is invoked
73 service.stopAsync().awaitTerminated();
74 assertTrue(service.shutDownCalled);
75 assertEquals(Service.State.TERMINATED, service.state());
81 WaitOnRunService service = new WaitOnRunService();
83 service.startAsync().awaitRunning();
84 enterRun.await(); // to avoid stopping the service until run() is invoked
86 service.stopAsync();
87 service.stopAsync();
88 service.stopAsync().awaitTerminated();
89 assertEquals(Service.State.TERMINATED, service.state());
90 service.stopAsync().awaitTerminated();
91 assertEquals(Service.State.TERMINATED, service.state());
98 WaitOnRunService service = new WaitOnRunService();
99 service.expectedShutdownState = Service.State.RUNNING;
101 service.startAsync().awaitRunning();
102 assertTrue(service.startUpCalled);
103 assertEquals(Service.State.RUNNING, service.state());
105 exitRun.countDown(); // the service will exit voluntarily
108 assertTrue(service.shutDownCalled);
109 assertEquals(Service.State.TERMINATED, service.state());
112 service.stopAsync().awaitTerminated(); // no-op
113 assertEquals(Service.State.TERMINATED, service.state());
114 assertTrue(service.shutDownCalled);
164 ThrowOnStartUpService service = new ThrowOnStartUpService();
165 assertFalse(service.startUpCalled);
167 service.startAsync();
169 service.awaitRunning();
176 assertTrue(service.startUpCalled);
177 assertEquals(Service.State.FAILED, service.state());
199 ThrowOnRunService service = new ThrowOnRunService();
201 service.startAsync();
203 service.awaitTerminated();
209 assertTrue(service.shutDownCalled);
210 assertEquals(Service.State.FAILED, service.state());
215 ThrowOnRunService service = new ThrowOnRunService();
216 service.throwOnShutDown = true;
218 service.startAsync();
220 service.awaitTerminated();
227 assertTrue(service.shutDownCalled);
228 assertEquals(Service.State.FAILED, service.state());
253 ThrowOnShutDown service = new ThrowOnShutDown();
255 service.startAsync().awaitRunning();
256 assertEquals(Service.State.RUNNING, service.state());
258 service.stopAsync();
262 assertEquals(Service.State.FAILED, service.state());
285 TimeoutOnStartUp service = new TimeoutOnStartUp();
288 service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS);
291 assertTrue(e.getMessage().contains(Service.State.STARTING.toString()));
310 FakeService service = new FakeService() {
316 service.startAsync();
317 service.stopAsync();
319 service.awaitTerminated();
320 assertEquals(Service.State.TERMINATED, service.state());
321 assertEquals(1, service.startupCalled);
322 assertEquals(0, service.runCalled);
323 assertEquals(1, service.shutdownCalled);
327 FakeService service = new FakeService();
328 service.stopAsync().awaitTerminated();
329 assertEquals(Service.State.TERMINATED, service.state());
330 assertEquals(0, service.startupCalled);
331 assertEquals(0, service.runCalled);
332 assertEquals(0, service.shutdownCalled);
336 WaitOnRunService service = new WaitOnRunService();
337 service.startAsync().awaitRunning();
339 service.stopAsync().awaitTerminated();
371 assertEquals(Service.State.STOPPING, state());