| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 25 import static com.google.common.util.concurrent.Service.State.STARTING;
70 stoppingCallback(STARTING);
172 snapshot = new StateSnapshot(STARTING);
197 case STARTING:
198 snapshot = new StateSnapshot(STARTING, true, null);
199 stopping(STARTING);
304 if (snapshot.state != STARTING) {
369 case STARTING:
450 if (from == State.STARTING) {
471 case STARTING:
[all …]
|
| D | ServiceManager.java | 29 import static com.google.common.util.concurrent.Service.State.STARTING;
547 + Multimaps.filterKeys(servicesByState, in(ImmutableSet.of(NEW, STARTING)))); in awaitHealthy()
737 state.transitionService(service, NEW, STARTING); in starting()
747 state.transitionService(service, STARTING, RUNNING); in running()
|
| D | Service.java | 198 STARTING { enumConstant
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ServiceTest.java | 22 import static com.google.common.util.concurrent.Service.State.STARTING;
36 assertLessThan(NEW, STARTING); in testStateOrdering()
39 assertLessThan(STARTING, RUNNING); in testStateOrdering()
40 assertLessThan(STARTING, STOPPING); in testStateOrdering()
41 assertLessThan(STARTING, FAILED); in testStateOrdering()
|
| D | AbstractServiceTest.java | 70 State.STARTING, in testNoOpServiceStartStop()
108 State.STARTING, in testNoOpServiceStopIdempotence()
175 assertEquals(State.STARTING, service.state()); in testManualServiceStartStop()
193 State.STARTING, in testManualServiceStartStop()
214 State.STARTING, in testManualServiceNotifyStoppedWhileRunning()
225 assertEquals(State.STARTING, service.state()); in testManualServiceStopWhileStarting()
244 State.STARTING, in testManualServiceStopWhileStarting()
288 assertEquals(ImmutableList.of(State.STARTING, State.FAILED), listener.getStateHistory()); in testManualServiceFailWhileStarting()
297 assertEquals(ImmutableList.of(State.STARTING, State.RUNNING, State.FAILED), in testManualServiceFailWhileRunning()
308 assertEquals(ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.FAILED), in testManualServiceFailWhileStopping()
[all …]
|
| D | AbstractIdleServiceTest.java | 97 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder(); in testStart()
117 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder(); in testStart_failed()
139 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder(); in testStop_afterStart()
163 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder(); in testStop_failed()
188 assertThat(e.getMessage()).contains(Service.State.STARTING.toString()); in testTimeout()
201 assertEquals(State.STARTING, state()); in startUp()
|
| D | AbstractExecutionThreadServiceTest.java | 128 assertEquals(State.STARTING, state()); in startUp()
291 assertTrue(e.getMessage().contains(Service.State.STARTING.toString())); in testServiceTimeoutOnStartUp()
|
| D | AbstractScheduledServiceTest.java | 250 assertEquals(State.STARTING, state()); in startUp()
|
| /external/ppp/pppd/ |
| D | fsm.c | 106 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 ){
|
| D | fsm.h | 124 #define STARTING 1 /* Down, been opened */ macro
|
| /external/autotest/client/common_lib/ |
| D | host_queue_entry_states.py | 16 ACTIVE_STATUSES = (Status.STARTING, Status.RESETTING, Status.VERIFYING,
|
| /external/autotest/venv/lucifer/ |
| D | eventlib.py | 51 STARTING = 'starting' variable in Event
|
| D | handlers.py | 309 if hqe.status in (Status.STARTING, Status.PENDING, Status.RUNNING):
|
| /external/autotest/scheduler/ |
| D | monitor_db.py | 557 statuses = (models.HostQueueEntry.Status.STARTING,
628 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
892 queue_entry.set_status(models.HostQueueEntry.Status.STARTING)
980 .filter(status=Status.STARTING))
1445 allowed_hqe_statuses=(models.HostQueueEntry.Status.STARTING,
1507 if hqe.status != models.HostQueueEntry.Status.STARTING:
|
| D | monitor_db_unittest.py | 405 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
748 expected_status = models.HostQueueEntry.Status.STARTING
795 models.HostQueueEntry.Status.STARTING)
823 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
1041 hqe.status = models.HostQueueEntry.Status.STARTING
|
| D | monitor_db_functional_test.py | 969 _check_hqe_statuses(HqeStatus.STARTING, HqeStatus.STARTING,
970 HqeStatus.STARTING)
1007 self._check_statuses(queue_entry, HqeStatus.STARTING,
|
| D | scheduler_models.py | 884 if self.status in {Status.STARTING, Status.PENDING, Status.RUNNING}:
897 if self.status in {Status.STARTING, Status.PENDING, Status.RUNNING}:
1383 queue_entry.set_status(models.HostQueueEntry.Status.STARTING)
|
| D | scheduler_models_unittest.py | 270 hqe.status = models.HostQueueEntry.Status.STARTING
|
| /external/walt/android/WALT/app/src/main/java/org/chromium/latency/walt/ |
| D | Utils.java | 182 STARTING, enumConstant
|
| D | WaltTcpConnection.java | 81 connectionState = Utils.ListenerState.STARTING; in connect()
|
| D | WaltDevice.java | 400 triggerListener.state = Utils.ListenerState.STARTING; in startListener()
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | python_op_gen.cc | 188 enum { STARTING, WAS_LIST_INPUT, WAS_SOLO_INPUT } inputs_state = STARTING; in FlattenInputs() enumerator
225 if (inputs_state == STARTING) return "[]"; in FlattenInputs()
|
| /external/webrtc/webrtc/modules/audio_coding/codecs/isac/main/test/QA/ |
| D | runiSACLongtest.txt | 111 echo STARTING TO TEST SUPER-WIDEBAND
|
| /external/perfetto/src/tracing/core/ |
| D | tracing_service_impl.h | 322 STARTING, enumerator
|
| D | tracing_service_impl.cc | 744 instance->state = DataSourceInstance::STARTING; in StartDataSourceInstance()
808 instance.state == DataSourceInstance::STARTING || in DisableTracing()
857 if (instance->state != DataSourceInstance::STARTING) { in NotifyDataSourceStarted()
|