HomeSort by relevance Sort by last modified time
    Searched refs:READY (Results 1 - 25 of 80) sorted by null

1 2 3 4

  /external/grpc-grpc-java/core/src/main/java/io/grpc/
ConnectivityState.java 39 READY,
57 * RPCs for this period, channels that are READY or CONNECTING switch to IDLE. Additionaly,
  /external/grpc-grpc/src/ruby/spec/
channel_connection_spec.rb 62 while count < 20 && state != GRPC::Core::ConnectivityStates::READY
68 expect(state).to be(GRPC::Core::ConnectivityStates::READY)
75 while count < 20 && state == GRPC::Core::ConnectivityStates::READY
81 expect(state).to_not be(GRPC::Core::ConnectivityStates::READY)
88 while count < 20 && state != GRPC::Core::ConnectivityStates::READY
94 expect(state).to be(GRPC::Core::ConnectivityStates::READY)
109 while ch.connectivity_state(true) != ConnectivityStates::READY
111 ConnectivityStates::READY, Time.now + 60)
  /external/autotest/client/common_lib/
host_states.py 13 Status = enum.Enum('Verifying', 'Running', 'Ready', 'Repairing',
19 IDLE_STATES = {Status.READY, Status.REPAIR_FAILED}
  /external/python/cpython2/Lib/plat-irix5/
CD.py 7 READY = 2
  /external/python/cpython2/Lib/plat-irix6/
CD.py 7 READY = 2
  /external/guava/guava/src/com/google/common/base/
AbstractIterator.java 37 READY, NOT_READY, DONE, FAILED,
55 case READY:
66 state = State.READY;
  /external/guava/guava/src/com/google/common/collect/
AbstractIterator.java 72 READY,
134 case READY:
145 state = State.READY;
  /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
_connectivity_channel_test.py 26 self.assertIsNotNone(interfaces.ChannelConnectivity.READY)
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
ConnectivityStateManagerTest.java 21 import static io.grpc.ConnectivityState.READY;
138 state.gotoState(READY);
171 }, executor.getScheduledExecutorService(), READY);
215 state.gotoState(READY);
219 assertEquals(READY, sink.poll());
231 state.gotoState(READY);
233 assertEquals(READY, sink.poll());
241 state.gotoState(READY);
ForwardingManagedChannelTest.java 105 when(mock.getState(true)).thenReturn(ConnectivityState.READY);
106 assertSame(ConnectivityState.READY, forward.getState(true));
115 forward.notifyWhenStateChanged(ConnectivityState.READY, callback);
116 verify(mock).notifyWhenStateChanged(same(ConnectivityState.READY), same(callback));
  /development/samples/browseable/WearSpeakerSample/src/com.example.android.wearable.speaker/
MainActivity.java 54 private AppState mState = AppState.READY;
63 READY, PLAYING_VOICE, PLAYING_MUSIC, RECORDING
111 mState = AppState.READY;
125 mState = AppState.READY;
130 mState = AppState.READY;
135 mState = AppState.READY;
159 // we need to transition to the READY/Home state
268 mState = AppState.READY;
  /external/openssh/regress/
forward-control.sh 9 READY=$OBJ/ready
40 rm -f $READY
44 -n host exec sh -c \'"sleep 60 & echo \$! > $READY ; wait "\' \
47 wait_for_file_to_appear $READY || \
52 kill $_sshpid `cat $READY` 2>/dev/null
70 rm -f $READY
74 -n host exec sh -c \'"sleep 60 & echo \$! > $READY ; wait "\' \
77 wait_for_file_to_appear $READY
83 kill $_sshpid `cat $READY` 2>/dev/nul
    [all...]
  /external/grpc-grpc/src/python/grpcio_tests/tests/unit/
_api_test.py 91 grpc.ChannelConnectivity.READY,
_channel_connectivity_test.py 26 return grpc.ChannelConnectivity.READY in connectivities
30 return connectivities[-1] is not grpc.ChannelConnectivity.READY
79 self.assertNotIn(grpc.ChannelConnectivity.READY, second_connectivities)
80 self.assertNotIn(grpc.ChannelConnectivity.READY, third_connectivities)
81 self.assertNotIn(grpc.ChannelConnectivity.READY, fourth_connectivities)
82 self.assertNotIn(grpc.ChannelConnectivity.READY, fifth_connectivities)
  /external/autotest/client/tests/tsc/src/
checktsc.c 166 #define READY 1
212 set_state(&master, READY);
214 wait_for_state(&slave, READY);
246 wait_for_state(&master, READY);
262 set_state(&slave, READY);
308 set_state(&master, READY);
  /developers/build/prebuilts/gradle/WearSpeakerSample/wear/src/main/java/com/example/android/wearable/speaker/
MainActivity.java 60 private AppState mState = AppState.READY;
78 READY, PLAYING_VOICE, PLAYING_MUSIC, RECORDING
131 mState = AppState.READY;
145 mState = AppState.READY;
150 mState = AppState.READY;
155 mState = AppState.READY;
179 // we need to transition to the READY/Home state
288 mState = AppState.READY;
  /developers/samples/android/wearable/wear/WearSpeakerSample/wear/src/main/java/com/example/android/wearable/speaker/
MainActivity.java 61 private AppState mState = AppState.READY;
79 READY, PLAYING_VOICE, PLAYING_MUSIC, RECORDING
132 mState = AppState.READY;
146 mState = AppState.READY;
151 mState = AppState.READY;
156 mState = AppState.READY;
180 // we need to transition to the READY/Home state
289 mState = AppState.READY;
  /external/grpc-grpc-java/core/src/test/java/io/grpc/util/
RoundRobinLoadBalancerTest.java 22 import static io.grpc.ConnectivityState.READY;
147 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY));
162 assertEquals(READY, stateCaptor.getAllValues().get(1));
178 ConnectivityStateInfo.forNonError(READY))).build());
206 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
238 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
265 ConnectivityStateInfo.forNonError(READY));
266 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
269 ConnectivityStateInfo.forNonError(READY));
336 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY));
    [all...]
  /cts/apps/CtsVerifier/src/com/android/cts/verifier/notifications/
NotificationListenerVerifierActivity.java 249 status = READY;
294 status = READY;
373 status = READY;
442 status = READY;
514 status = READY;
575 status = READY;
654 status = READY;
718 status = READY;
723 if (status == READY) {
761 status = READY;
    [all...]
  /external/guice/core/src/com/google/inject/internal/
Initializer.java 152 READY
200 if (state == InjectableReferenceState.READY) {
226 case READY:
250 // mark instance as ready to skip a lock on subsequent calls
251 state = InjectableReferenceState.READY;
  /cts/apps/CtsVerifier/src/com/android/cts/verifier/qstiles/
InteractiveVerifierActivity.java 47 protected static final int READY = 1;
93 /** Set status to {@link #READY} to proceed, or {@link #SETUP} to try again. */
95 status = READY;
99 /** Set status to {@link #PASS} or @{link #FAIL} to proceed, or {@link #READY} to retry. */
186 mCurrentTest.status = READY;
216 case READY:
291 case READY:
  /external/ltp/testcases/kernel/syscalls/sigrelse/
sigrelse01.c 61 * wait for child to send ready message over pipe
84 * send parent ready message if setup went ok.
150 #define READY "ready" /* signal to parent that child is set up */
237 * parent() : wait for "ready" from child, send signals to child, wait for
251 /* wait for "ready" message from child */
257 if (strcmp(str, READY) != 0) {
286 if (write_pipe(pipe_fd2[1], READY) < 0) {
389 /* set note to READY and if an error occurs, overwrite it */
390 (void)strcpy(note, READY);
    [all...]
  /development/samples/Snake/src/com/example/android/snake/
SnakeView.java 40 * Current mode of application: READY to run, RUNNING, or you have already lost. static final
43 private int mMode = READY;
45 public static final int READY = 1;
262 if (mMode == READY | mMode == LOSE) {
350 if (newMode == READY) {
367 * @return the Game state as Running, Ready, Paused, Lose
  /external/testng/src/main/java/org/testng/internal/
DynamicGraph.java 31 READY, RUNNING, FINISHED
113 case READY: m_nodesReady.add(node); break;
138 case READY: return m_nodesReady.size();
155 result.append("\n Ready:" + m_nodesReady);
  /external/u-boot/board/cobra5272/
flash.c 123 #define READY 1
192 /* wait until flash is ready */
207 chip1 = READY;
282 /* wait until flash is ready */
293 chip1 = READY;

Completed in 1571 milliseconds

1 2 3 4