| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 306 assertEquals(subchannel, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
307 assertEquals(subchannel1, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
308 assertEquals(subchannel2, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
309 assertEquals(subchannel, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
316 assertEquals(null, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerEmptyList()
327 assertNull(pickResult.getSubchannel()); in nameResolutionErrorWithNoChannels()
350 assertEquals(readySubchannel, pickResult.getSubchannel()); in nameResolutionErrorWithActiveChannels()
354 assertEquals(readySubchannel, pickResult2.getSubchannel()); in nameResolutionErrorWithActiveChannels()
418 Subchannel sc1 = picker.pickSubchannel(mockArgs).getSubchannel(); in noStickinessEnabled_withStickyHeader()
419 Subchannel sc2 = picker.pickSubchannel(mockArgs).getSubchannel(); in noStickinessEnabled_withStickyHeader()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 145 assertEquals(mockSubchannel, pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel()); in pickAfterResolvedAndChanged()
165 Subchannel subchannel = pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel(); in pickAfterStateChangeAfterResolution()
182 assertEquals(subchannel, pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel()); in pickAfterStateChangeAfterResolution()
193 assertEquals(null, pickResult.getSubchannel()); in nameResolutionError()
214 .getSubchannel()); in nameResolutionSuccessAfterError()
233 assertEquals(null, pickResult.getSubchannel()); in nameResolutionErrorWithStateChanges()
242 assertEquals(null, pickResult.getSubchannel()); in nameResolutionErrorWithStateChanges()
|
| D | LoadBalancerTest.java | 50 assertThat(result.getSubchannel()).isSameAs(subchannel); in pickResult_withSubchannel()
59 assertThat(result.getSubchannel()).isSameAs(subchannel); in pickResult_withSubchannelAndTracer()
68 assertThat(result.getSubchannel()).isNull(); in pickResult_withNoResult()
77 assertThat(result.getSubchannel()).isNull(); in pickResult_withError()
86 assertThat(result.getSubchannel()).isNull(); in pickResult_withDrop()
|
| D | InternalChannelzTest.java | 200 assertNull(channelz.getSubchannel(id(root))); in getChannel()
207 public void getSubchannel() { in getSubchannel() method in InternalChannelzTest
209 assertNull(channelz.getSubchannel(id(sub))); in getSubchannel()
212 assertSame(sub, channelz.getSubchannel(id(sub))); in getSubchannel()
216 assertNull(channelz.getSubchannel(id(sub))); in getSubchannel()
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | GetSubchannelResponse.java | 110 public io.grpc.channelz.v1.Subchannel getSubchannel() { in getSubchannel() method in GetSubchannelResponse
122 return getSubchannel(); in getSubchannelOrBuilder()
138 output.writeMessage(1, getSubchannel()); in writeTo()
150 .computeMessageSize(1, getSubchannel()); in getSerializedSize()
170 result = result && getSubchannel() in equals()
171 .equals(other.getSubchannel()); in equals()
186 hash = (53 * hash) + getSubchannel().hashCode(); in hashCode()
392 mergeSubchannel(other.getSubchannel()); in mergeFrom()
443 public io.grpc.channelz.v1.Subchannel getSubchannel() { in getSubchannel() method in GetSubchannelResponse.Builder
575 getSubchannel(), in getSubchannelFieldBuilder()
|
| D | GetSubchannelResponseOrBuilder.java | 27 io.grpc.channelz.v1.Subchannel getSubchannel(); in getSubchannel() method
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzService.java | 105 public void getSubchannel( in getSubchannel() method in ChannelzService
107 InternalInstrumented<ChannelStats> s = channelz.getSubchannel(request.getSubchannelId()); in getSubchannel()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzServiceTest.java | 93 public void getSubchannel() throws Exception { in getSubchannel() method in ChannelzServiceTest
186 service.getSubchannel(GetSubchannelRequest.newBuilder().setSubchannelId(id).build(), observer); in getSubchannelHelper()
196 service.getSubchannel(GetSubchannelRequest.newBuilder().setSubchannelId(id).build(), observer); in assertSubchannelNotFound()
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
| D | ChannelzGrpc.java | 303 public void getSubchannel(io.grpc.channelz.v1.GetSubchannelRequest request, in getSubchannel() method in ChannelzGrpc.ChannelzImplBase
438 public void getSubchannel(io.grpc.channelz.v1.GetSubchannelRequest request, in getSubchannel() method in ChannelzGrpc.ChannelzStub
524 …public io.grpc.channelz.v1.GetSubchannelResponse getSubchannel(io.grpc.channelz.v1.GetSubchannelRe… in getSubchannel() method in ChannelzGrpc.ChannelzBlockingStub
612 …e.common.util.concurrent.ListenableFuture<io.grpc.channelz.v1.GetSubchannelResponse> getSubchannel( in getSubchannel() method in ChannelzGrpc.ChannelzFutureStub
671 serviceImpl.getSubchannel((io.grpc.channelz.v1.GetSubchannelRequest) request, in invoke()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 385 public Subchannel getSubchannel() { in getSubchannel() method in LoadBalancer.PickResult
|
| D | InternalChannelz.java | 165 public InternalInstrumented<ChannelStats> getSubchannel(long id) { in getSubchannel() method in InternalChannelz
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 393 Subchannel getSubchannel(String stickinessValue) { in getSubchannel() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer.StickinessState
433 subchannel = stickinessState.getSubchannel(stickinessValue); in pickSubchannel()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 459 assertSame(subchannel1, pick1.getSubchannel()); in loadReporting()
471 assertNull(pick2.getSubchannel()); in loadReporting()
488 assertSame(subchannel2, pick3.getSubchannel()); in loadReporting()
504 assertNull(pick4.getSubchannel()); in loadReporting()
525 assertSame(subchannel1, pick1.getSubchannel()); in loadReporting()
583 assertNull(pick6.getSubchannel()); in loadReporting()
601 assertSame(subchannel1, pick1p.getSubchannel()); in loadReporting()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | OobChannel.java | 283 Subchannel getSubchannel() { in getSubchannel() method in OobChannel
|
| D | GrpcUtil.java | 667 Subchannel subchannel = result.getSubchannel(); in getTransportFromPickResult()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 383 AbstractSubchannel subchannel = (AbstractSubchannel) oob.getSubchannel(); in channelzMembership_oob()
389 oob.getSubchannel().requestConnection(); in channelzMembership_oob()
1349 oobChannel.getSubchannel().requestConnection(); in subtestRefreshNameResolutionWhenConnectionFailed()
2475 AbstractSubchannel oobSubchannel = (AbstractSubchannel) oobChannel.getSubchannel(); in channelsAndSubchannels_oob_instrumented0()
2547 oobChannel.getSubchannel().requestConnection(); in channelsAndSubchannels_oob_instrumented_state()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 674 Subchannel subchannel = entry.result.getSubchannel(); in maybeUpdatePicker()
|