Lines Matching refs:State

26 import com.google.common.util.concurrent.Service.State;
54 assertEquals(State.NEW, service.state());
59 assertEquals(State.RUNNING, service.state());
64 assertEquals(State.TERMINATED, service.state());
69 State.STARTING,
70 State.RUNNING,
71 State.STOPPING,
72 State.TERMINATED),
80 assertEquals(State.RUNNING, service.state());
83 assertEquals(State.TERMINATED, service.state());
90 assertEquals(State.RUNNING, service.state());
93 assertEquals(State.TERMINATED, service.state());
100 assertEquals(State.RUNNING, service.state());
104 assertEquals(State.TERMINATED, service.state());
107 State.STARTING,
108 State.RUNNING,
109 State.STOPPING,
110 State.TERMINATED),
121 assertEquals(State.TERMINATED, service.state());
128 assertEquals(State.RUNNING, service.state());
132 assertEquals(State.TERMINATED, service.state());
142 assertEquals(State.RUNNING, service.state());
145 assertEquals(State.TERMINATED, service.state());
174 assertEquals(State.STARTING, service.state());
179 assertEquals(State.RUNNING, service.state());
183 assertEquals(State.STOPPING, service.state());
188 assertEquals(State.TERMINATED, service.state());
192 State.STARTING,
193 State.RUNNING,
194 State.STOPPING,
195 State.TERMINATED),
207 assertEquals(State.TERMINATED, service.state());
213 State.STARTING,
214 State.RUNNING,
215 State.TERMINATED),
224 assertEquals(State.STARTING, service.state());
229 assertEquals(State.STOPPING, service.state());
234 assertEquals(State.STOPPING, service.state());
239 assertEquals(State.TERMINATED, service.state());
243 State.STARTING,
244 State.STOPPING,
245 State.TERMINATED),
251 * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
258 @Override public void stopping(State from) {
275 assertEquals(State.TERMINATED, service.state());
279 assertEquals(ImmutableList.of(State.TERMINATED), listener.getStateHistory());
287 assertEquals(ImmutableList.of(State.STARTING, State.FAILED), listener.getStateHistory());
296 assertEquals(ImmutableList.of(State.STARTING, State.RUNNING, State.FAILED),
307 assertEquals(ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.FAILED),
317 assertEquals(State.RUNNING, service.state());
322 assertEquals(State.TERMINATED, service.state());
355 assertEquals(State.RUNNING, service.state());
377 assertEquals(State.RUNNING, service.state());
379 assertEquals(State.FAILED, service.state());
390 assertEquals(State.RUNNING, service.state());
395 assertEquals(State.TERMINATED, service.state());
400 State.STARTING,
401 State.RUNNING,
402 State.STOPPING,
403 State.TERMINATED),
411 assertEquals(State.RUNNING, service.state());
417 assertEquals(State.TERMINATED, service.state());
427 assertEquals(State.RUNNING, service.state());
433 assertEquals(State.TERMINATED, service.state());
445 assertEquals(State.RUNNING, service.state());
451 assertEquals(State.TERMINATED, service.state());
489 assertEquals(State.STARTING, state());
492 assertEquals(State.STARTING, state());
494 assertEquals(State.RUNNING, state());
501 assertEquals(State.STOPPING, state());
504 assertEquals(State.STOPPING, state());
506 assertEquals(State.TERMINATED, state());
534 assertEquals(State.TERMINATED, service.state());
540 assertEquals(State.TERMINATED, Iterables.getOnlyElement(listener.getStateHistory()));
556 State.STARTING,
557 State.FAILED),
575 State.STARTING,
576 State.RUNNING,
577 State.STOPPING,
578 State.FAILED),
596 State.STARTING,
597 State.RUNNING,
598 State.FAILED),
615 State.STARTING,
616 State.FAILED),
634 State.STARTING,
635 State.RUNNING,
636 State.STOPPING,
637 State.FAILED),
655 State.STARTING,
656 State.RUNNING,
657 State.FAILED),
688 assertEquals(State.FAILED, service.state());
715 @Override public void terminated(State from) {
826 final List<State> stateHistory = Lists.newArrayList();
829 ImmutableList<State> getStateHistory() throws Exception {
838 assertNotSame(State.NEW, service.state());
839 stateHistory.add(State.STARTING);
843 assertEquals(State.STARTING, Iterables.getOnlyElement(stateHistory));
844 stateHistory.add(State.RUNNING);
846 assertNotSame(State.STARTING, service.state());
849 @Override public synchronized void stopping(State from) {
851 stateHistory.add(State.STOPPING);
852 if (from == State.STARTING) {
865 @Override public synchronized void terminated(State from) {
866 assertEquals(from, Iterables.getLast(stateHistory, State.NEW));
867 stateHistory.add(State.TERMINATED);
868 assertEquals(State.TERMINATED, service.state());
869 if (from == State.NEW) {
882 @Override public synchronized void failed(State from, Throwable failure) {
884 stateHistory.add(State.FAILED);
885 assertEquals(State.FAILED, service.state());
887 if (from == State.STARTING) {