/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;
|