| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ServiceTest.java | 22 import static com.google.common.util.concurrent.Service.State.STARTING;
36 assertLessThan(NEW, STARTING);
39 assertLessThan(STARTING, RUNNING);
40 assertLessThan(STARTING, STOPPING);
41 assertLessThan(STARTING, FAILED);
|
| AbstractIdleServiceTest.java | 97 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder();
117 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder();
139 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder();
163 .has().exactly(Service.State.STARTING, Service.State.STOPPING).inOrder();
188 assertThat(e.getMessage()).contains(Service.State.STARTING.toString());
201 assertEquals(State.STARTING, state());
|
| AbstractServiceTest.java | 70 State.STARTING,
108 State.STARTING,
175 assertEquals(State.STARTING, service.state());
193 State.STARTING,
214 State.STARTING,
225 assertEquals(State.STARTING, service.state());
244 State.STARTING,
252 * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
288 assertEquals(ImmutableList.of(State.STARTING, State.FAILED), listener.getStateHistory());
297 assertEquals(ImmutableList.of(State.STARTING, State.RUNNING, State.FAILED)
837 @Override public synchronized void starting() { method in class:AbstractServiceTest.RecordingListener
[all...] |
| AbstractExecutionThreadServiceTest.java | 128 assertEquals(State.STARTING, state());
291 assertTrue(e.getMessage().contains(Service.State.STARTING.toString()));
|
| AbstractScheduledServiceTest.java | 250 assertEquals(State.STARTING, state());
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AbstractService.java | 25 import static com.google.common.util.concurrent.Service.State.STARTING;
58 new Callback<Listener>("starting()") {
60 listener.starting();
70 stoppingCallback(STARTING);
172 snapshot = new StateSnapshot(STARTING);
173 starting();
197 case STARTING:
198 snapshot = new StateSnapshot(STARTING, true, null);
199 stopping(STARTING);
295 * the service to transition from {@link State#STARTING} to {@link State#RUNNING}
[all...] |
| Service.java | 33 * <li>{@linkplain State#STARTING STARTING} ->
78 * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running},
198 STARTING {
258 * {@linkplain State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called
261 public void starting() {} method in class:Service.Listener
264 * Called when the service transitions from {@linkplain State#STARTING STARTING} to
[all...] |
| ServiceManager.java | 29 import static com.google.common.util.concurrent.Service.State.STARTING;
75 * provides methods for {@linkplain #startAsync() starting}, {@linkplain #stopAsync() stopping} and
311 * @throws TimeoutException if not all of the services have finished starting within the deadline
381 * have finished starting.
547 + Multimaps.filterKeys(servicesByState, in(ImmutableSet.of(NEW, STARTING))));
651 // N.B. if we miss the STARTING event then we may never record a startup time.
711 "Expected to be healthy after starting. The following services are not running: "
734 @Override public void starting() { method in class:ServiceManager.ServiceListener
737 state.transitionService(service, NEW, STARTING);
739 logger.log(Level.FINE, "Starting {0}.", service)
[all...] |
| /external/autotest/client/common_lib/ |
| host_queue_entry_states.py | 10 Status_list = ['Queued', 'Starting', 'Resetting', 'Verifying', 'Provisioning',
16 ACTIVE_STATUSES = (Status.STARTING, Status.RESETTING, Status.VERIFYING,
|
| /external/autotest/venv/lucifer/ |
| eventlib.py | 45 TODO(crbug.com/748234): Events starting with X are temporary to
51 STARTING = 'starting'
81 logger.debug('Starting event command with %r', args)
|
| /external/ppp/pppd/ |
| fsm.h | 106 void (*starting) /* Called when we want the lower layer */ member in struct:fsm_callbacks
124 #define STARTING 1 /* Down, been opened */
|
| fsm.c | 106 case STARTING:
137 f->state = STARTING;
138 if( f->callbacks->starting )
139 (*f->callbacks->starting)(f);
151 f->state = STARTING;
158 f->state = STARTING;
176 f->state = STARTING;
177 if( f->callbacks->starting )
178 (*f->callbacks->starting)(f);
257 case STARTING
[all...] |
| /frameworks/base/services/core/java/com/android/server/connectivity/ |
| Nat464Xlat.java | 69 STARTING, // start() called. Base iface and stacked iface names are known.
101 * A true result corresponds to internal states STARTING and RUNNING.
111 return mState == State.STARTING;
143 Slog.e(TAG, "Error starting clatd on " + baseIface, e);
147 mState = State.STARTING;
206 Slog.i(TAG, "Starting clatd on " + baseIface);
|
| /hardware/google/av/media/sfplugin/ |
| CCodec.h | 119 STARTING, // ALLOCATED -> RUNNING
|
| /external/autotest/scheduler/ |
| monitor_db.py | 89 """Make sure the configs are consistent before starting the scheduler"""
234 logging.info("%s> dispatcher starting", time.strftime("%X %x"))
302 self._log_tick_msg('Starting %s' % func.__name__)
380 self._log_tick_msg('Starting _drone_manager.trigger_refresh')
391 self._log_tick_msg('Starting _drone_manager.sync_refresh')
411 self._log_tick_msg('Starting _host_scheduler.tick')
414 self._log_tick_msg('Starting _drone_manager.execute_actions')
418 'Starting email_manager.manager.send_queued_emails')
421 self._log_tick_msg('Starting django.db.reset_queries')
495 if luciferlib.is_enabled_for('STARTING')
[all...] |
| monitor_db_unittest.py | 183 queue_entry.set_status('Starting')
404 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
762 expected_status = models.HostQueueEntry.Status.STARTING
810 models.HostQueueEntry.Status.STARTING)
838 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
844 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
[all...] |
| monitor_db_functional_test.py | [all...] |
| /external/walt/android/WALT/app/src/main/java/org/chromium/latency/walt/ |
| Utils.java | 182 STARTING,
|
| WaltTcpConnection.java | 81 connectionState = Utils.ListenerState.STARTING;
|
| WaltDevice.java | 399 logger.log("Starting Listener");
400 triggerListener.state = Utils.ListenerState.STARTING;
|
| /frameworks/av/services/audioflinger/ |
| Effects.h | 56 STARTING,
|
| Effects.cpp | 251 case STARTING:
[all...] |
| /external/tensorflow/tensorflow/python/eager/ |
| python_eager_op_gen.cc | 194 enum { STARTING, WAS_LIST_INPUT, WAS_SOLO_INPUT } inputs_state = STARTING;
231 if (inputs_state == STARTING) return "[]";
[all...] |
| /frameworks/av/media/libstagefright/include/media/stagefright/ |
| MediaCodec.h | 217 STARTING,
|
| /external/webrtc/webrtc/modules/audio_coding/codecs/isac/main/test/QA/ |
| runiSACLongtest.txt | 111 echo STARTING TO TEST SUPER-WIDEBAND
|
