| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 38 import io.grpc.LoadBalancer.Subchannel;
108 static final Attributes.Key<Ref<Subchannel>> STICKY_REF = Attributes.Key.create("sticky-ref");
113 private final Map<EquivalentAddressGroup, Subchannel> subchannels =
114 new HashMap<EquivalentAddressGroup, Subchannel>();
166 Ref<Subchannel> stickyRef = null; in handleResolvedAddressGroups()
168 subchannelAttrs.set(STICKY_REF, stickyRef = new Ref<Subchannel>(null)); in handleResolvedAddressGroups()
171 Subchannel subchannel = checkNotNull( in handleResolvedAddressGroups()
182 Subchannel subchannel = subchannels.remove(addressGroup); in handleResolvedAddressGroups()
197 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
211 private void shutdownSubchannel(Subchannel subchannel) { in shutdownSubchannel()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 57 import io.grpc.LoadBalancer.Subchannel;
94 private Map<EquivalentAddressGroup, Subchannel> subchannels = Maps.newLinkedHashMap();
118 Subchannel sc = mock(Subchannel.class); in setUp()
124 .then(new Answer<Subchannel>() { in setUp()
126 public Subchannel answer(InvocationOnMock invocation) throws Throwable { in setUp()
128 Subchannel subchannel = subchannels.get(args[0]); in setUp()
145 final Subchannel readySubchannel = subchannels.values().iterator().next(); in pickAfterResolved()
153 for (Subchannel subchannel : subchannels.values()) { in pickAfterResolved()
170 Subchannel removedSubchannel = mock(Subchannel.class); in pickAfterResolvedUpdatedHosts()
171 Subchannel oldSubchannel = mock(Subchannel.class); in pickAfterResolvedUpdatedHosts()
[all …]
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | CachedSubchannelPoolTest.java | 36 import io.grpc.LoadBalancer.Subchannel;
73 private final ArrayList<Subchannel> mockSubchannels = new ArrayList<>();
77 doAnswer(new Answer<Subchannel>() { in setUp()
79 public Subchannel answer(InvocationOnMock invocation) throws Throwable { in setUp()
80 Subchannel subchannel = mock(Subchannel.class); in setUp()
103 for (Subchannel subchannel : mockSubchannels) { in wrapUp()
110 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); in subchannelExpireAfterReturned()
114 Subchannel subchannel2 = pool.takeOrCreateSubchannel(EAG2, ATTRS2); in subchannelExpireAfterReturned()
141 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); in subchannelReused()
145 Subchannel subchannel2 = pool.takeOrCreateSubchannel(EAG2, ATTRS2); in subchannelReused()
[all …]
|
| D | GrpclbLoadBalancerTest.java | 60 import io.grpc.LoadBalancer.Subchannel;
151 private final LinkedList<Subchannel> mockSubchannels = new LinkedList<Subchannel>();
153 private final ArrayList<Subchannel> subchannelTracker = new ArrayList<>();
219 doAnswer(new Answer<Subchannel>() { in setUp()
221 public Subchannel answer(InvocationOnMock invocation) throws Throwable { in setUp()
222 Subchannel subchannel = mock(Subchannel.class); in setUp()
281 for (Subchannel subchannel: subchannelTracker) { in tearDown()
301 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerNoDrop()
339 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithDrop()
435 Subchannel subchannel1 = mockSubchannels.poll(); in loadReporting()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 146 Subchannel subchannel, ConnectivityStateInfo stateInfo); in handleSubchannelState()
237 @Nullable private final Subchannel subchannel;
247 @Nullable Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory, in PickResult()
323 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel()
334 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
379 public Subchannel getSubchannel() { in getSubchannel()
464 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel()
481 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel()
498 Subchannel subchannel, EquivalentAddressGroup addrs) { in updateSubchannelAddresses()
513 Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
[all …]
|
| D | PickFirstBalancerFactory.java | 27 import io.grpc.LoadBalancer.Subchannel;
59 private Subchannel subchannel;
92 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
148 private final Subchannel subchannel;
150 RequestConnectionPicker(Subchannel subchannel) { in RequestConnectionPicker()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | CachedSubchannelPool.java | 26 import io.grpc.LoadBalancer.Subchannel;
53 public Subchannel takeOrCreateSubchannel( in takeOrCreateSubchannel()
56 Subchannel subchannel; in takeOrCreateSubchannel()
67 public void returnSubchannel(Subchannel subchannel) { in returnSubchannel()
113 private final Subchannel subchannel;
116 private ShutdownSubchannelTask(Subchannel subchannel) { in ShutdownSubchannelTask()
134 final Subchannel subchannel;
137 CacheEntry(Subchannel subchannel, ScheduledFuture<?> shutdownTimer) { in CacheEntry()
|
| D | SubchannelPool.java | 22 import io.grpc.LoadBalancer.Subchannel;
43 Subchannel takeOrCreateSubchannel(EquivalentAddressGroup eag, Attributes defaultAttributes); in takeOrCreateSubchannel()
49 void returnSubchannel(Subchannel subchannel); in returnSubchannel()
|
| D | GrpclbState.java | 40 import io.grpc.LoadBalancer.Subchannel;
138 private Map<EquivalentAddressGroup, Subchannel> subchannels = Collections.emptyMap();
165 void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
222 for (Subchannel subchannel : subchannels.values()) { in maybeUseFallbackBackends()
314 for (Subchannel subchannel : subchannels.values()) { in shutdown()
349 HashMap<EquivalentAddressGroup, Subchannel> newSubchannelMap = in useRoundRobinLists()
350 new HashMap<EquivalentAddressGroup, Subchannel>(); in useRoundRobinLists()
355 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists()
380 for (Entry<EquivalentAddressGroup, Subchannel> entry : subchannels.entrySet()) { in useRoundRobinLists()
680 Subchannel subchannel = entry.result.getSubchannel(); in maybeUpdatePicker()
[all …]
|
| D | GrpclbLoadBalancer.java | 80 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | GetSubchannelResponse.java | 53 io.grpc.channelz.v1.Subchannel.Builder subBuilder = null; in GetSubchannelResponse()
57 … subchannel_ = input.readMessage(io.grpc.channelz.v1.Subchannel.parser(), extensionRegistry); in GetSubchannelResponse()
90 private io.grpc.channelz.v1.Subchannel subchannel_;
110 public io.grpc.channelz.v1.Subchannel getSubchannel() { in getSubchannel()
111 return subchannel_ == null ? io.grpc.channelz.v1.Subchannel.getDefaultInstance() : subchannel_; in getSubchannel()
421 private io.grpc.channelz.v1.Subchannel subchannel_ = null;
423 …io.grpc.channelz.v1.Subchannel, io.grpc.channelz.v1.Subchannel.Builder, io.grpc.channelz.v1.Subcha…
443 public io.grpc.channelz.v1.Subchannel getSubchannel() { in getSubchannel()
445 … return subchannel_ == null ? io.grpc.channelz.v1.Subchannel.getDefaultInstance() : subchannel_; in getSubchannel()
458 public Builder setSubchannel(io.grpc.channelz.v1.Subchannel value) { in setSubchannel()
[all …]
|
| D | Subchannel.java | 14 public final class Subchannel extends class
20 private Subchannel(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Subchannel() method in Subchannel
23 private Subchannel() { in Subchannel() method in Subchannel
34 private Subchannel( in Subchannel() method in Subchannel
143 io.grpc.channelz.v1.Subchannel.class, io.grpc.channelz.v1.Subchannel.Builder.class); in internalGetFieldAccessorTable()
468 if (!(obj instanceof io.grpc.channelz.v1.Subchannel)) { in equals()
471 io.grpc.channelz.v1.Subchannel other = (io.grpc.channelz.v1.Subchannel) obj; in equals()
526 public static io.grpc.channelz.v1.Subchannel parseFrom( in parseFrom()
531 public static io.grpc.channelz.v1.Subchannel parseFrom( in parseFrom()
537 public static io.grpc.channelz.v1.Subchannel parseFrom( in parseFrom()
[all …]
|
| D | GetSubchannelResponseOrBuilder.java | 27 io.grpc.channelz.v1.Subchannel getSubchannel(); in getSubchannel()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | LoadBalancerTest.java | 24 import io.grpc.LoadBalancer.Subchannel;
36 private final Subchannel subchannel = mock(Subchannel.class);
37 private final Subchannel subchannel2 = mock(Subchannel.class);
45 private final Subchannel emptySubchannel = new EmptySubchannel();
129 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrsIn, Attributes attrsIn) { in helper_createSubchannel_delegates()
155 Subchannel subchannelIn, List<EquivalentAddressGroup> addrsIn) { in helper_updateSubchannelAddresses_delegates()
223 private static class EmptySubchannel extends LoadBalancer.Subchannel {
|
| D | PickFirstLoadBalancerTest.java | 40 import io.grpc.LoadBalancer.Subchannel;
74 private Subchannel mockSubchannel;
165 Subchannel subchannel = pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel(); in pickAfterStateChangeAfterResolution()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 29 import io.grpc.LoadBalancer.Subchannel;
87 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in forwardsCalls()
116 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_keepOldBalancer()
150 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_shutsDownOldBalancer()
171 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleResolvedAddressGroups_shutsDownOldBalancer()
284 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
307 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel()
350 private static class TestSubchannel extends Subchannel {
|
| D | ManagedChannelImplTest.java | 80 import io.grpc.LoadBalancer.Subchannel;
438 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown()
571 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown()
572 Subchannel subchannel2 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown()
637 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in callOptionsExecutor()
853 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in firstResolvedServerFailedToConnect()
998 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in allServersFailedToConnect()
1054 Subchannel sub1 = helper.createSubchannel(addressGroup, attrs1); in subchannels()
1055 Subchannel sub2 = helper.createSubchannel(addressGroup, attrs2); in subchannels()
1110 Subchannel sub1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subchannelsWhenChannelShutdownNow()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 45 import io.grpc.LoadBalancer.Subchannel;
265 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in realTransportsHoldsOffIdleness()
304 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_newAddressConnects()
324 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_existingAddressDoesNotConnect()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactory.java | 62 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) {} in handleSubchannelState()
115 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
|
| D | AbstractSubchannel.java | 29 abstract class AbstractSubchannel extends LoadBalancer.Subchannel {
|
| D | OobChannel.java | 42 import io.grpc.LoadBalancer.Subchannel;
283 Subchannel getSubchannel() { in getSubchannel()
|
| /external/grpc-grpc-java/services/src/main/proto/grpc/channelz/v1/ |
| D | channelz.proto | 59 // Subchannel is a logical grouping of channels, subchannels, and sockets.
61 message Subchannel { message
97 // Channel data is data related to a specific Channel or Subchannel.
168 // ChannelRef is a reference to a Subchannel.
431 // Returns a single Subchannel, or else a NOT_FOUND code.
503 // The Subchannel that corresponds to the requested subchannel_id. This
505 Subchannel subchannel = 1;
|
| /external/grpc-grpc/src/proto/grpc/channelz/ |
| D | channelz.proto | 59 // Subchannel is a logical grouping of channels, subchannels, and sockets.
61 message Subchannel { message
97 // Channel data is data related to a specific Channel or Subchannel.
168 // ChannelRef is a reference to a Subchannel.
431 // Returns a single Subchannel, or else a NOT_FOUND code.
503 // The Subchannel that corresponds to the requested subchannel_id. This
505 Subchannel subchannel = 1;
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 68 import io.grpc.channelz.v1.Subchannel;
410 static Subchannel toSubchannel(InternalInstrumented<ChannelStats> subchannel) { in toSubchannel()
412 Subchannel.Builder subchannelBuilder = Subchannel in toSubchannel()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | channel_trace_proto_helper.cc | 86 VaidateProtoJsonTranslation<grpc::channelz::v1::Subchannel>(json_c_str); in ValidateSubchannelProtoJsonTranslation()
|