| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | InternalChannelz.java | 56 private final ConcurrentMap<Long, InternalInstrumented<ChannelStats>> subchannels field in InternalChannelz
87 add(subchannels, subchannel); in addSubchannel()
121 remove(subchannels, subchannel); in removeSubchannel()
166 return subchannels.get(id); in getSubchannel()
225 return contains(subchannels, subchannelRef); in containsSubchannel()
370 public final List<InternalWithLogId> subchannels; field in InternalChannelz.ChannelStats
384 List<InternalWithLogId> subchannels, in ChannelStats() argument
387 subchannels.isEmpty() || sockets.isEmpty(), in ChannelStats()
397 this.subchannels = checkNotNull(subchannels); in ChannelStats()
409 private List<InternalWithLogId> subchannels = Collections.emptyList(); field in InternalChannelz.ChannelStats.Builder
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 113 private final Map<EquivalentAddressGroup, Subchannel> subchannels = field in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
131 Set<EquivalentAddressGroup> currentAddrs = subchannels.keySet(); in handleResolvedAddressGroups()
176 subchannels.put(addressGroup, subchannel); in handleResolvedAddressGroups()
182 Subchannel subchannel = subchannels.remove(addressGroup); in handleResolvedAddressGroups()
198 if (subchannels.get(subchannel.getAddresses()) != subchannel) { in handleSubchannelState()
275 Collection<Subchannel> subchannels) { in filterNonFailingSubchannels() argument
276 List<Subchannel> readySubchannels = new ArrayList<>(subchannels.size()); in filterNonFailingSubchannels()
277 for (Subchannel subchannel : subchannels) { in filterNonFailingSubchannels()
299 return subchannels.values(); in getSubchannels()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 94 private Map<EquivalentAddressGroup, Subchannel> subchannels = Maps.newLinkedHashMap(); field in RoundRobinLoadBalancerTest
120 subchannels.put(eag, sc); in setUp()
128 Subchannel subchannel = subchannels.get(args[0]); in setUp()
145 final Subchannel readySubchannel = subchannels.values().iterator().next(); in pickAfterResolved()
152 assertThat(eagCaptor.getAllValues()).containsAllIn(subchannels.keySet()); in pickAfterResolved()
153 for (Subchannel subchannel : subchannels.values()) { in pickAfterResolved()
334 final Subchannel readySubchannel = subchannels.values().iterator().next(); in nameResolutionErrorWithActiveChannels()
360 Iterator<Subchannel> subchannelIterator = subchannels.values().iterator(); in subchannelStateIsolation()
405 for (Subchannel subchannel : subchannels.values()) { in noStickinessEnabled_withStickyHeader()
438 for (Subchannel subchannel : subchannels.values()) { in stickinessEnabled_withoutStickyHeader()
[all …]
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 138 private Map<EquivalentAddressGroup, Subchannel> subchannels = Collections.emptyMap(); field in GrpclbState
166 if (newState.getState() == SHUTDOWN || !(subchannels.values().contains(subchannel))) { in handleSubchannelState()
222 for (Subchannel subchannel : subchannels.values()) { in maybeUseFallbackBackends()
314 for (Subchannel subchannel : subchannels.values()) { in shutdown()
317 subchannels = Collections.emptyMap(); in shutdown()
357 subchannel = subchannels.get(eag); in useRoundRobinLists()
380 for (Entry<EquivalentAddressGroup, Subchannel> entry : subchannels.entrySet()) { in useRoundRobinLists()
387 subchannels = Collections.unmodifiableMap(newSubchannelMap); in useRoundRobinLists()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelImpl.java | 180 private final Set<InternalSubchannel> subchannels = new HashSet<InternalSubchannel>(16, .75f); field in ManagedChannelImpl
271 for (InternalSubchannel subchannel : subchannels) { in maybeShutdownNowSubchannels()
312 children.addAll(subchannels); in getStats()
844 if (shutdown.get() && subchannels.isEmpty() && oobChannels.isEmpty()) { in maybeTerminateChannel()
899 for (InternalSubchannel subchannel : subchannels) { in resetConnectBackoff()
1050 subchannels.remove(is); in createSubchannel()
1104 subchannels.add(internalSubchannel); in createSubchannel()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 348 for (InternalWithLogId subchannel : stats.subchannels) { in toChannel()
416 Preconditions.checkState(stats.sockets.isEmpty() || stats.subchannels.isEmpty()); in toSubchannel()
420 for (InternalWithLogId childSubchannel : stats.subchannels) { in toSubchannel()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 1253 List<Subchannel> subchannels = fallbackTestVerifyUseOfBalancerBackendLists(inOrder, serverList); in subtestGrpclbFallbackConnectionLost() local
1265 for (Subchannel subchannel : subchannels) { in subtestGrpclbFallbackConnectionLost()
1273 subchannels = fallbackTestVerifyUseOfFallbackBackendLists( in subtestGrpclbFallbackConnectionLost()
1278 for (Subchannel subchannel : subchannels) { in subtestGrpclbFallbackConnectionLost()
1330 ArrayList<Subchannel> subchannels = new ArrayList<>(mockSubchannels); in fallbackTestVerifyUseOfBackendLists() local
1332 for (Subchannel subchannel : subchannels) { in fallbackTestVerifyUseOfBackendLists()
1342 Subchannel subchannel = subchannels.get(i); in fallbackTestVerifyUseOfBackendLists()
1359 return subchannels; in fallbackTestVerifyUseOfBackendLists()
|
| /external/grpc-grpc-java/services/src/main/proto/grpc/channelz/v1/ |
| D | channelz.proto | 36 // Channel is a logical grouping of channels, subchannels, and sockets.
59 // Subchannel is a logical grouping of channels, subchannels, and sockets.
423 // created). This does not include subchannels nor non-top level channels.
|
| /external/grpc-grpc/src/proto/grpc/channelz/ |
| D | channelz.proto | 36 // Channel is a logical grouping of channels, subchannels, and sockets.
59 // Subchannel is a logical grouping of channels, subchannels, and sockets.
423 // created). This does not include subchannels nor non-top level channels.
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzProtoUtilTest.java | 921 if (!stats.subchannels.isEmpty()) { in toBuilder()
922 builder.setSubchannels(stats.subchannels); in toBuilder()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 350 assertThat(getStats(channel).subchannels) in channelzMembership_subchannel()
368 assertThat(getStats(channel).subchannels).isEmpty(); in channelzMembership_subchannel()
381 assertThat(getStats(channel).subchannels).containsExactly(oob); in channelzMembership_oob()
386 assertThat(getStats(oob).subchannels) in channelzMembership_oob()
402 assertThat(getStats(channel).subchannels).isEmpty(); in channelzMembership_oob()
1048 public void subchannels() { in subchannels() method in ManagedChannelImplTest
|
| /external/grpc-grpc-java/core/ |
| D | grpc-core-1.14.0.jar | META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/ ... |
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |