Lines Matching refs:service
20 import com.google.common.util.concurrent.Service.State;
60 NullService service = new NullService();
61 service.startAndWait();
63 service.stopAndWait();
76 TestService service = new TestService();
77 service.runException = new Exception();
78 service.startAndWait();
79 service.runFirstBarrier.await();
80 service.runSecondBarrier.await();
87 assertEquals(service.runException, e.getCause().getCause());
89 assertEquals(service.state(), Service.State.FAILED);
93 TestService service = new TestService();
94 service.startUpException = new Exception();
96 service.startAndWait();
99 assertEquals(service.startUpException, e.getCause());
101 assertEquals(0, service.numberOfTimesRunCalled.get());
102 assertEquals(Service.State.FAILED, service.state());
106 TestService service = new TestService();
107 service.shutDownException = new Exception();
108 service.startAndWait();
109 service.runFirstBarrier.await();
110 ListenableFuture<Service.State> stopHandle = service.stop();
111 service.runSecondBarrier.await();
116 assertEquals(service.shutDownException, e.getCause());
118 assertEquals(Service.State.FAILED, service.state());
122 TestService service = new TestService();
123 service.startAndWait();
125 service.runFirstBarrier.await();
126 assertEquals(i, service.numberOfTimesRunCalled.get());
127 service.runSecondBarrier.await();
129 service.runFirstBarrier.await();
130 service.stop();
131 service.runSecondBarrier.await();
132 service.stopAndWait();
136 TestService service = new TestService();
137 service.startAndWait();
139 assertEquals(1, service.numberOfTimesExecutorCalled.get());
141 service.runFirstBarrier.await();
142 assertEquals(i, service.numberOfTimesRunCalled.get());
143 service.runSecondBarrier.await();
145 service.runFirstBarrier.await();
146 service.stop();
147 service.runSecondBarrier.await();
148 service.stopAndWait();
150 assertEquals(1, service.numberOfTimesExecutorCalled.get());
154 TestService service = new TestService();
155 service.startAndWait();
157 assertEquals(1, service.numberOfTimesSchedulerCalled.get());
159 service.runFirstBarrier.await();
160 assertEquals(i, service.numberOfTimesRunCalled.get());
161 service.runSecondBarrier.await();
163 service.runFirstBarrier.await();
164 service.stop();
165 service.runSecondBarrier.await();
166 service.stopAndWait();
168 assertEquals(1, service.numberOfTimesSchedulerCalled.get());
316 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService();
317 service.startAndWait();
318 service.firstBarrier.await();
319 assertEquals(1, service.numIterations.get());
320 service.stop();
321 service.secondBarrier.await();
322 service.stopAndWait();
325 assertEquals(1, service.numIterations.get());
329 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService() {
341 service.useBarriers = false;
342 service.startAndWait();
344 service.useBarriers = true;
345 service.firstBarrier.await();
346 int numIterations = service.numIterations.get();
347 service.stop();
348 service.secondBarrier.await();
349 service.stopAndWait();
350 assertEquals(numIterations, service.numIterations.get());
386 TestFailingCustomScheduledService service = new TestFailingCustomScheduledService();
387 service.startAndWait();
389 service.firstBarrier.await();
390 assertEquals(i, service.numIterations.get());
391 service.secondBarrier.await();
395 service.stop().get(100, TimeUnit.SECONDS);
398 assertEquals(State.FAILED, service.state());
