| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 22 import static io.grpc.ConnectivityState.READY;
147 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY)); in pickAfterResolved()
162 assertEquals(READY, stateCaptor.getAllValues().get(1)); in pickAfterResolved()
178 ConnectivityStateInfo.forNonError(READY))).build()); in pickAfterResolvedUpdatedHosts()
206 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
238 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
265 ConnectivityStateInfo.forNonError(READY)); in pickAfterStateChange()
266 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterStateChange()
269 ConnectivityStateInfo.forNonError(READY)); in pickAfterStateChange()
336 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY)); in nameResolutionErrorWithActiveChannels()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 21 import static io.grpc.ConnectivityState.READY;
138 state.gotoState(READY); in callbacksAreOneShot()
171 }, executor.getScheduledExecutorService(), READY); in multipleCallbacks()
215 state.gotoState(READY);
219 assertEquals(READY, sink.poll());
231 state.gotoState(READY);
233 assertEquals(READY, sink.poll());
241 state.gotoState(READY);
|
| D | ForwardingManagedChannelTest.java | 105 when(mock.getState(true)).thenReturn(ConnectivityState.READY); in getState()
106 assertSame(ConnectivityState.READY, forward.getState(true)); in getState()
115 forward.notifyWhenStateChanged(ConnectivityState.READY, callback); in notifyWhenStateChanged()
116 verify(mock).notifyWhenStateChanged(same(ConnectivityState.READY), same(callback)); in notifyWhenStateChanged()
|
| D | ManagedChannelImplTest.java | 23 import static io.grpc.ConnectivityState.READY;
457 helper.updateBalancingState(READY, mockPicker); in subtestCallsAndShutdown()
515 helper.updateBalancingState(READY, picker2); in subtestCallsAndShutdown()
585 assertSame(READY, stateInfoCaptor.getAllValues().get(1).getState()); in noMoreCallbackAfterLoadBalancerShutdown()
652 helper.updateBalancingState(READY, mockPicker); in callOptionsExecutor()
753 helper.updateBalancingState(READY, picker); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
883 assertEquals(READY, stateInfoCaptor.getValue().getState()); in firstResolvedServerFailedToConnect()
886 helper.updateBalancingState(READY, mockPicker); in firstResolvedServerFailedToConnect()
935 helper.updateBalancingState(READY, picker); in subtestFailRpcFromBalancer()
1444 helper.updateBalancingState(READY, mockPicker); in informationPropagatedToNewStreamAndCallCredentials()
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _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/ |
| D | checktsc.c | 166 #define READY 1 macro
212 set_state(&master, READY); in tsc_delta()
214 wait_for_state(&slave, READY); in tsc_delta()
246 wait_for_state(&master, READY); in slave_thread()
262 set_state(&slave, READY); in slave_thread()
308 set_state(&master, READY); in check_tsc()
|
| /external/guava/guava/src/com/google/common/base/ |
| D | AbstractIterator.java | 37 READY, NOT_READY, DONE, FAILED, enumConstant
55 case READY: in hasNext()
66 state = State.READY; in tryToComputeNext()
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | AbstractIterator.java | 72 READY, enumConstant
134 case READY: in hasNext()
145 state = State.READY; in tryToComputeNext()
|
| /external/grpc-grpc/doc/ |
| D | wait-for-ready.md | 8 channel being in other states (`CONNECTING`, `READY`, or `IDLE`).
12 queues the RPCs until the channel is `READY`. This is known as "wait for ready."
13 The RPCs SHOULD still fail before `READY` if there are unrelated reasons, such
|
| /external/guice/core/src/com/google/inject/internal/ |
| D | Initializer.java | 152 READY enumConstant
200 if (state == InjectableReferenceState.READY) { in get()
226 case READY: in get()
251 state = InjectableReferenceState.READY; in get()
|
| /external/ltp/testcases/kernel/syscalls/sigrelse/ |
| D | sigrelse01.c | 150 #define READY "ready" /* signal to parent that child is set up */ macro
257 if (strcmp(str, READY) != 0) { in parent()
286 if (write_pipe(pipe_fd2[1], READY) < 0) { in parent()
390 (void)strcpy(note, READY); in child()
466 if (strcmp(str, READY) != 0) { in child()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 21 import static io.grpc.ConnectivityState.READY;
156 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(READY)); in stateChangeBeforeResolution()
180 loadBalancer.handleSubchannelState(subchannel, ConnectivityStateInfo.forNonError(READY)); in pickAfterStateChangeAfterResolution()
181 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
236 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(READY)); in nameResolutionErrorWithStateChanges()
|
| /external/openssh/regress/ |
| D | forward-control.sh | 9 READY=$OBJ/ready
40 rm -f $READY
|
| /external/u-boot/board/cobra5272/ |
| D | flash.c | 123 #define READY 1 macro
207 chip1 = READY; in flash_erase()
293 chip1 = READY; in write_word()
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | DynamicGraph.java | 31 READY, RUNNING, FINISHED enumConstant
113 case READY: m_nodesReady.add(node); break; in setStatus()
138 case READY: return m_nodesReady.size(); in getNodeCountWithStatus()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 22 import static io.grpc.ConnectivityState.READY;
439 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(READY)); in loadReporting()
440 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(READY)); in loadReporting()
443 .updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
598 helperInOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
896 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(READY)); in grpclbWorking()
897 inOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in grpclbWorking()
904 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(READY)); in grpclbWorking()
905 inOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in grpclbWorking()
917 inOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in grpclbWorking()
[all …]
|
| /external/autotest/scheduler/ |
| D | prejob_task.py | 198 self.host.set_status(models.Host.Status.READY)
249 self.host.set_status(models.Host.Status.READY)
301 self.host.set_status(models.Host.Status.READY)
470 self.host.set_status(models.Host.Status.READY)
|
| D | monitor_db_functional_test.py | 444 self._check_statuses(queue_entry, HqeStatus.COMPLETED, HostStatus.READY)
540 self._check_statuses(queue_entry, HqeStatus.COMPLETED, HostStatus.READY)
588 self._check_host_status(host, HostStatus.READY)
600 self._check_host_status(host, HostStatus.READY)
648 self._check_statuses(queue_entry, HqeStatus.COMPLETED, HostStatus.READY)
662 self._check_host_status(host, HostStatus.READY) # ignore failure
882 HostStatus.READY)
905 self._check_host_status(queue_entry.host, HostStatus.READY)
940 self._check_host_status(queue_entry.host, HostStatus.READY)
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ConnectivityState.java | 39 READY, enumConstant
|
| /external/python/cpython2/Lib/plat-irix6/ |
| D | CD.py | 7 READY = 2 variable
|
| /external/python/cpython2/Lib/plat-irix5/ |
| D | CD.py | 7 READY = 2 variable
|
| /external/autotest/client/common_lib/ |
| D | host_states.py | 19 IDLE_STATES = {Status.READY, Status.REPAIR_FAILED}
|
| /external/turbine/javatests/com/google/turbine/lower/testdata/ |
| D | enumingeneric.test | 7 enum State { READY, SET, GO, }
|
| D | enumint.test | 10 enum Foo implements I<String> { READY, SET, GO, }
|
| D | enumint_byte.test | 18 READY{
|