Lines Matching defs:service
26 import com.google.common.util.concurrent.Service.Listener;
27 import com.google.common.util.concurrent.Service.State;
52 NoOpService service = new NoOpService();
53 RecordingListener listener = RecordingListener.record(service);
55 assertEquals(State.NEW, service.state());
56 assertFalse(service.isRunning());
57 assertFalse(service.running);
59 service.startAsync();
60 assertEquals(State.RUNNING, service.state());
61 assertTrue(service.isRunning());
62 assertTrue(service.running);
64 service.stopAsync();
65 assertEquals(State.TERMINATED, service.state());
66 assertFalse(service.isRunning());
67 assertFalse(service.running);
78 NoOpService service = new NoOpService();
80 service.startAsync().awaitRunning();
81 assertEquals(State.RUNNING, service.state());
83 service.stopAsync().awaitTerminated();
84 assertEquals(State.TERMINATED, service.state());
88 NoOpService service = new NoOpService();
90 service.startAsync().awaitRunning();
91 assertEquals(State.RUNNING, service.state());
93 service.stopAsync().awaitTerminated();
94 assertEquals(State.TERMINATED, service.state());
98 NoOpService service = new NoOpService();
99 RecordingListener listener = RecordingListener.record(service);
100 service.startAsync().awaitRunning();
101 assertEquals(State.RUNNING, service.state());
103 service.stopAsync();
104 service.stopAsync();
105 assertEquals(State.TERMINATED, service.state());
116 NoOpService service = new NoOpService();
118 service.startAsync().awaitRunning();
120 service.stopAsync().awaitTerminated();
121 service.stopAsync();
122 assertEquals(State.TERMINATED, service.state());
126 NoOpService service = new NoOpService();
128 service.startAsync().awaitRunning();
129 assertEquals(State.RUNNING, service.state());
131 service.stopAsync().awaitTerminated();
132 service.stopAsync().awaitTerminated();
133 assertEquals(State.TERMINATED, service.state());
138 NoOpService service = new NoOpService();
142 service.startAsync().awaitRunning();
143 assertEquals(State.RUNNING, service.state());
145 service.stopAsync().awaitTerminated();
146 assertEquals(State.TERMINATED, service.state());
171 ManualSwitchedService service = new ManualSwitchedService();
172 RecordingListener listener = RecordingListener.record(service);
174 service.startAsync();
175 assertEquals(State.STARTING, service.state());
176 assertFalse(service.isRunning());
177 assertTrue(service.doStartCalled);
179 service.notifyStarted(); // usually this would be invoked by another thread
180 assertEquals(State.RUNNING, service.state());
181 assertTrue(service.isRunning());
183 service.stopAsync();
184 assertEquals(State.STOPPING, service.state());
185 assertFalse(service.isRunning());
186 assertTrue(service.doStopCalled);
188 service.notifyStopped(); // usually this would be invoked by another thread
189 assertEquals(State.TERMINATED, service.state());
190 assertFalse(service.isRunning());
202 ManualSwitchedService service = new ManualSwitchedService();
203 RecordingListener listener = RecordingListener.record(service);
205 service.startAsync();
206 service.notifyStarted();
207 service.notifyStopped();
208 assertEquals(State.TERMINATED, service.state());
209 assertFalse(service.isRunning());
210 assertFalse(service.doStopCalled);
221 ManualSwitchedService service = new ManualSwitchedService();
222 RecordingListener listener = RecordingListener.record(service);
224 service.startAsync();
225 assertEquals(State.STARTING, service.state());
226 assertFalse(service.isRunning());
227 assertTrue(service.doStartCalled);
229 service.stopAsync();
230 assertEquals(State.STOPPING, service.state());
231 assertFalse(service.isRunning());
232 assertFalse(service.doStopCalled);
234 service.notifyStarted();
235 assertEquals(State.STOPPING, service.state());
236 assertFalse(service.isRunning());
237 assertTrue(service.doStopCalled);
239 service.notifyStopped();
240 assertEquals(State.TERMINATED, service.state());
241 assertFalse(service.isRunning());
251 * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
256 ManualSwitchedService service = new ManualSwitchedService();
258 service.addListener(new Listener() {
264 service.startAsync();
265 service.stopAsync();
267 service.stopAsync();
272 ManualSwitchedService service = new ManualSwitchedService();
273 RecordingListener listener = RecordingListener.record(service);
275 service.stopAsync();
276 assertEquals(State.TERMINATED, service.state());
277 assertFalse(service.isRunning());
278 assertFalse(service.doStartCalled);
279 assertFalse(service.doStopCalled);
284 ManualSwitchedService service = new ManualSwitchedService();
285 RecordingListener listener = RecordingListener.record(service);
286 service.startAsync();
287 service.notifyFailed(EXCEPTION);
292 ManualSwitchedService service = new ManualSwitchedService();
293 RecordingListener listener = RecordingListener.record(service);
294 service.startAsync();
295 service.notifyStarted();
296 service.notifyFailed(EXCEPTION);
302 ManualSwitchedService service = new ManualSwitchedService();
303 RecordingListener listener = RecordingListener.record(service);
304 service.startAsync();
305 service.notifyStarted();
306 service.stopAsync();
307 service.notifyFailed(EXCEPTION);
313 ManualSwitchedService service = new ManualSwitchedService();
315 service.startAsync();
317 service.notifyStarted();
318 assertEquals(State.RUNNING, service.state());
319 assertTrue(service.isRunning());
320 assertFalse(service.doStopCalled);
322 service.notifyStopped();
323 assertEquals(State.TERMINATED, service.state());
324 assertFalse(service.isRunning());
325 assertFalse(service.doStopCalled);
329 * The user of this service should call {@link #notifyStarted} and {@link
348 final NoOpService service = new NoOpService();
351 service.awaitTerminated();
355 service.startAsync().awaitRunning();
356 assertEquals(State.RUNNING, service.state());
357 service.stopAsync();
363 final ManualSwitchedService service = new ManualSwitchedService();
368 service.awaitTerminated();
376 service.startAsync();
377 service.notifyStarted();
378 assertEquals(State.RUNNING, service.state());
379 service.notifyFailed(EXCEPTION);
380 assertEquals(State.FAILED, service.state());
388 ThreadedService service = new ThreadedService();
389 RecordingListener listener = RecordingListener.record(service);
390 service.startAsync().awaitRunning();
391 assertEquals(State.RUNNING, service.state());
393 service.awaitRunChecks();
395 service.stopAsync().awaitTerminated();
396 assertEquals(State.TERMINATED, service.state());
409 ThreadedService service = new ThreadedService();
411 service.startAsync().awaitRunning();
412 assertEquals(State.RUNNING, service.state());
414 service.awaitRunChecks();
416 service.stopAsync();
417 service.stopAsync().awaitTerminated();
418 assertEquals(State.TERMINATED, service.state());
425 ThreadedService service = new ThreadedService();
427 service.startAsync().awaitRunning();
428 assertEquals(State.RUNNING, service.state());
430 service.awaitRunChecks();
432 service.stopAsync().awaitTerminated();
433 service.stopAsync();
434 assertEquals(State.TERMINATED, service.state());
443 ThreadedService service = new ThreadedService();
445 service.startAsync().awaitRunning();
446 assertEquals(State.RUNNING, service.state());
448 service.awaitRunChecks();
450 service.stopAsync().awaitTerminated();
451 service.stopAsync().awaitTerminated();
452 assertEquals(State.TERMINATED, service.state());
458 ManualSwitchedService service = new ManualSwitchedService();
459 RecordingListener.record(service);
460 service.startAsync();
461 service.notifyFailed(new Exception("1"));
462 service.notifyFailed(new Exception("2"));
463 assertEquals("1", service.failureCause().getMessage());
465 service.awaitRunning();
476 * The main test thread tries to stop() the service shortly after
477 * confirming that it is running. Meanwhile, the service itself is trying
480 * thread calls this method, which waits until the service has performed
484 assertTrue("Service thread hasn't finished its checks. "
531 NoOpService service = new NoOpService();
532 RecordingListener listener = RecordingListener.record(service);
534 service.stopAsync();
535 assertEquals(State.TERMINATED, service.state());
538 service.startAsync();
545 StartFailingService service = new StartFailingService();
546 RecordingListener listener = RecordingListener.record(service);
549 service.startAsync().awaitRunning();
552 assertEquals(EXCEPTION, service.failureCause());
563 StopFailingService service = new StopFailingService();
564 RecordingListener listener = RecordingListener.record(service);
566 service.startAsync().awaitRunning();
568 service.stopAsync().awaitTerminated();
571 assertEquals(EXCEPTION, service.failureCause());
584 RunFailingService service = new RunFailingService();
585 RecordingListener listener = RecordingListener.record(service);
587 service.startAsync();
589 service.awaitRunning();
592 assertEquals(EXCEPTION, service.failureCause());
604 StartThrowingService service = new StartThrowingService();
605 RecordingListener listener = RecordingListener.record(service);
608 service.startAsync().awaitRunning();
611 assertEquals(service.exception, service.failureCause());
612 assertEquals(service.exception, e.getCause());
622 StopThrowingService service = new StopThrowingService();
623 RecordingListener listener = RecordingListener.record(service);
625 service.startAsync().awaitRunning();
627 service.stopAsync().awaitTerminated();
630 assertEquals(service.exception, service.failureCause());
631 assertEquals(service.exception, e.getCause());
643 RunThrowingService service = new RunThrowingService();
644 RecordingListener listener = RecordingListener.record(service);
646 service.startAsync();
648 service.awaitTerminated();
651 assertEquals(service.exception, service.failureCause());
652 assertEquals(service.exception, e.getCause());
663 StopFailingService service = new StopFailingService();
665 service.failureCause();
670 service.startAsync().awaitRunning();
672 service.failureCause();
678 service.stopAsync().awaitTerminated();
681 assertEquals(EXCEPTION, service.failureCause());
687 final StartFailingService service = new StartFailingService();
688 service.startAsync();
689 assertEquals(State.FAILED, service.state());
690 service.addListener(new RecordingListener(service), directExecutor());
694 service.stopAsync();
703 final NoOpThreadedService service = new NoOpThreadedService();
704 service.addListener(new Listener() {
706 service.awaitRunning();
709 service.startAsync().awaitRunning(LONG_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
710 service.stopAsync();
714 final NoOpThreadedService service = new NoOpThreadedService();
715 service.addListener(new Listener() {
717 service.stopAsync().awaitTerminated();
720 service.startAsync().awaitRunning();
724 service.stopAsync().awaitTerminated();
814 static RecordingListener record(Service service) {
815 RecordingListener listener = new RecordingListener(service);
816 service.addListener(listener, directExecutor());
820 final Service service;
822 RecordingListener(Service service) {
823 this.service = service;
839 assertNotSame(State.NEW, service.state());
846 service.awaitRunning();
847 assertNotSame(State.STARTING, service.state());
855 service.awaitRunning();
860 "Expected the service to be RUNNING, but was STOPPING"));
863 assertNotSame(from, service.state());
869 assertEquals(State.TERMINATED, service.state());
872 service.awaitRunning();
877 "Expected the service to be RUNNING, but was TERMINATED"));
886 assertEquals(State.FAILED, service.state());
887 assertEquals(failure, service.failureCause());
890 service.awaitRunning();
897 service.awaitTerminated();
907 AbstractService service = new DefaultService();
909 service.notifyStarted();
915 AbstractService service = new DefaultService();
917 service.notifyStopped();
923 AbstractService service = new DefaultService();
925 service.notifyFailed(new Exception());
931 NoOpService service = new NoOpService();
932 service.startAsync().awaitRunning();
933 service.stopAsync().awaitTerminated();
935 service.notifyFailed(new Exception());
