Home
last modified time | relevance | path

Searched refs:STARTING (Results 1 – 25 of 35) sorted by relevance

12

/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractService.java23 import static com.google.common.util.concurrent.Service.State.STARTING;
78 stoppingEvent(STARTING);
85 terminatedEvent(STARTING);
247 snapshot = new StateSnapshot(STARTING);
273 case STARTING:
274 snapshot = new StateSnapshot(STARTING, true, null);
275 enqueueStoppingEvent(STARTING);
397 if (snapshot.state != STARTING) {
438 case STARTING:
466 case STARTING:
[all …]
DServiceManager.java29 import static com.google.common.util.concurrent.Service.State.STARTING;
578 + Multimaps.filterKeys(servicesByState, in(ImmutableSet.of(NEW, STARTING)))); in awaitHealthy()
782 state.transitionService(service, NEW, STARTING); in starting()
793 state.transitionService(service, STARTING, RUNNING); in running()
830 log &= from != State.STARTING; in failed()
DService.java217 STARTING { enumConstant
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractService.java23 import static com.google.common.util.concurrent.Service.State.STARTING;
77 stoppingEvent(STARTING);
84 terminatedEvent(STARTING);
246 snapshot = new StateSnapshot(STARTING);
272 case STARTING:
273 snapshot = new StateSnapshot(STARTING, true, null);
274 enqueueStoppingEvent(STARTING);
384 if (snapshot.state != STARTING) {
425 case STARTING:
453 case STARTING:
[all …]
DServiceManager.java28 import static com.google.common.util.concurrent.Service.State.STARTING;
548 + Multimaps.filterKeys(servicesByState, in(ImmutableSet.of(NEW, STARTING)))); in awaitHealthy()
749 state.transitionService(service, NEW, STARTING); in starting()
760 state.transitionService(service, STARTING, RUNNING); in running()
DService.java186 STARTING { enumConstant
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DServiceTest.java22 import static com.google.common.util.concurrent.Service.State.STARTING;
35 assertLessThan(NEW, STARTING); in testStateOrdering()
38 assertLessThan(STARTING, RUNNING); in testStateOrdering()
39 assertLessThan(STARTING, STOPPING); in testStateOrdering()
40 assertLessThan(STARTING, FAILED); in testStateOrdering()
DAbstractServiceTest.java67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
166 assertEquals(State.STARTING, service.state()); in testManualServiceStartStop()
183 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testManualServiceStartStop()
199 ImmutableList.of(State.STARTING, State.RUNNING, State.TERMINATED), in testManualServiceNotifyStoppedWhileRunning()
208 assertEquals(State.STARTING, service.state()); in testManualServiceStopWhileStarting()
226 ImmutableList.of(State.STARTING, State.STOPPING, State.TERMINATED), in testManualServiceStopWhileStarting()
271 assertEquals(ImmutableList.of(State.STARTING, State.FAILED), listener.getStateHistory()); in testManualServiceFailWhileStarting()
281 ImmutableList.of(State.STARTING, State.RUNNING, State.FAILED), listener.getStateHistory()); in testManualServiceFailWhileRunning()
292 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.FAILED), in testManualServiceFailWhileStopping()
[all …]
DAbstractIdleServiceTest.java102 assertThat(service.transitionStates).containsExactly(Service.State.STARTING); in testStart()
124 assertThat(service.transitionStates).containsExactly(Service.State.STARTING); in testStart_failed()
146 .containsExactly(Service.State.STARTING, Service.State.STOPPING) in testStop_afterStart()
173 .containsExactly(Service.State.STARTING, Service.State.STOPPING) in testStop_failed()
223 assertEquals(State.STARTING, state()); in startUp()
DAbstractExecutionThreadServiceTest.java134 assertEquals(State.STARTING, state()); in startUp()
310 assertThat(e.getMessage()).contains(Service.State.STARTING.toString()); in testServiceTimeoutOnStartUp()
DAbstractScheduledServiceTest.java335 assertEquals(State.STARTING, state()); in startUp()
535 if (state() != State.STARTING) { in testCustomScheduler_deadlock()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DServiceTest.java22 import static com.google.common.util.concurrent.Service.State.STARTING;
35 assertLessThan(NEW, STARTING); in testStateOrdering()
38 assertLessThan(STARTING, RUNNING); in testStateOrdering()
39 assertLessThan(STARTING, STOPPING); in testStateOrdering()
40 assertLessThan(STARTING, FAILED); in testStateOrdering()
DAbstractServiceTest.java67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
166 assertEquals(State.STARTING, service.state()); in testManualServiceStartStop()
183 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testManualServiceStartStop()
199 ImmutableList.of(State.STARTING, State.RUNNING, State.TERMINATED), in testManualServiceNotifyStoppedWhileRunning()
208 assertEquals(State.STARTING, service.state()); in testManualServiceStopWhileStarting()
226 ImmutableList.of(State.STARTING, State.STOPPING, State.TERMINATED), in testManualServiceStopWhileStarting()
271 assertEquals(ImmutableList.of(State.STARTING, State.FAILED), listener.getStateHistory()); in testManualServiceFailWhileStarting()
281 ImmutableList.of(State.STARTING, State.RUNNING, State.FAILED), listener.getStateHistory()); in testManualServiceFailWhileRunning()
292 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.FAILED), in testManualServiceFailWhileStopping()
[all …]
DAbstractIdleServiceTest.java102 assertThat(service.transitionStates).containsExactly(Service.State.STARTING); in testStart()
124 assertThat(service.transitionStates).containsExactly(Service.State.STARTING); in testStart_failed()
146 .containsExactly(Service.State.STARTING, Service.State.STOPPING) in testStop_afterStart()
173 .containsExactly(Service.State.STARTING, Service.State.STOPPING) in testStop_failed()
223 assertEquals(State.STARTING, state()); in startUp()
DAbstractExecutionThreadServiceTest.java134 assertEquals(State.STARTING, state()); in startUp()
310 assertThat(e.getMessage()).contains(Service.State.STARTING.toString()); in testServiceTimeoutOnStartUp()
DAbstractScheduledServiceTest.java335 assertEquals(State.STARTING, state()); in startUp()
535 if (state() != State.STARTING) { in testCustomScheduler_deadlock()
/external/ppp/pppd/
Dfsm.c106 case STARTING:
137 f->state = STARTING;
151 f->state = STARTING;
158 f->state = STARTING;
176 f->state = STARTING;
257 case STARTING:
365 if( f->state == INITIAL || f->state == STARTING ){
Dfsm.h124 #define STARTING 1 /* Down, been opened */ macro
/external/autotest/client/common_lib/
Dhost_queue_entry_states.py16 ACTIVE_STATUSES = (Status.STARTING, Status.RESETTING, Status.VERIFYING,
/external/walt/android/WALT/app/src/main/java/org/chromium/latency/walt/
DWaltTcpConnection.java81 connectionState = Utils.ListenerState.STARTING; in connect()
DUtils.java215 STARTING, enumConstant
DWaltDevice.java415 triggerListener.state = Utils.ListenerState.STARTING; in startListener()
/external/oss-fuzz/projects/mysql-server/targets/
Dfuzz_initfile.dict582 STARTING="STARTING"
Dfuzz_docommand.dict582 STARTING="STARTING"
/external/tensorflow/tensorflow/python/framework/
Dpython_op_gen.cc229 enum { STARTING, WAS_LIST_INPUT, WAS_SOLO_INPUT } inputs_state = STARTING; in FlattenInputs() enumerator
266 if (inputs_state == STARTING) return "[]"; in FlattenInputs()

12