| /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 …]
|
| D | ForwardingLoadBalancerHelper.java | 24 import io.grpc.LoadBalancer.Subchannel;
39 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel()
44 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel()
50 Subchannel subchannel, EquivalentAddressGroup addrs) { in updateSubchannelAddresses()
56 Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 302 class Subchannel::ConnectedSubchannelStateWatcher
306 explicit ConnectedSubchannelStateWatcher(Subchannel* c) : subchannel_(c) { in ConnectedSubchannelStateWatcher()
319 Subchannel* c = subchannel_; in OnConnectivityStateChange()
360 Subchannel* subchannel_;
365 class Subchannel::AsyncWatcherNotifierLocked {
368 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher, in AsyncWatcherNotifierLocked()
369 Subchannel* subchannel, grpc_connectivity_state state, in AsyncWatcherNotifierLocked()
392 RefCountedPtr<Subchannel::ConnectivityStateWatcherInterface> watcher_;
400 void Subchannel::ConnectivityStateWatcherList::AddWatcherLocked( in AddWatcherLocked()
405 void Subchannel::ConnectivityStateWatcherList::RemoveWatcherLocked( in RemoveWatcherLocked()
[all …]
|
| D | local_subchannel_pool.cc | 35 Subchannel* LocalSubchannelPool::RegisterSubchannel(SubchannelKey* key, in RegisterSubchannel()
36 Subchannel* constructed) { in RegisterSubchannel()
38 Subchannel* c = in RegisterSubchannel()
39 static_cast<Subchannel*>(grpc_avl_get(subchannel_map_, key, nullptr)); in RegisterSubchannel()
57 Subchannel* LocalSubchannelPool::FindSubchannel(SubchannelKey* key) { in FindSubchannel()
58 Subchannel* c = in FindSubchannel()
59 static_cast<Subchannel*>(grpc_avl_get(subchannel_map_, key, nullptr)); in FindSubchannel()
|
| D | global_subchannel_pool.cc | 60 Subchannel* GlobalSubchannelPool::RegisterSubchannel(SubchannelKey* key, in RegisterSubchannel()
61 Subchannel* constructed) { in RegisterSubchannel()
62 Subchannel* c = nullptr; in RegisterSubchannel()
70 c = static_cast<Subchannel*>(grpc_avl_get(old_map, key, nullptr)); in RegisterSubchannel()
149 Subchannel* GlobalSubchannelPool::FindSubchannel(SubchannelKey* key) { in FindSubchannel()
155 Subchannel* c = static_cast<Subchannel*>(grpc_avl_get(index, key, nullptr)); in FindSubchannel()
183 GRPC_SUBCHANNEL_WEAK_UNREF((Subchannel*)p, "global_subchannel_pool"); in scv_avl_destroy()
187 GRPC_SUBCHANNEL_WEAK_REF((Subchannel*)p, "global_subchannel_pool"); in scv_avl_copy()
|
| D | subchannel.h | 171 class Subchannel {
216 Subchannel(SubchannelKey* key, OrphanablePtr<SubchannelConnector> connector,
218 ~Subchannel();
221 static Subchannel* Create(OrphanablePtr<SubchannelConnector> connector,
230 Subchannel* Ref(GRPC_SUBCHANNEL_REF_EXTRA_ARGS);
232 Subchannel* WeakRef(GRPC_SUBCHANNEL_REF_EXTRA_ARGS);
237 Subchannel* RefFromWeakRef();
309 void NotifyLocked(Subchannel* subchannel, grpc_connectivity_state state,
336 Subchannel* subchannel, grpc_connectivity_state initial_state,
347 Subchannel* subchannel, const std::string& health_check_service_name);
|
| D | subchannel_pool_interface.h | 31 class Subchannel; variable
75 virtual Subchannel* RegisterSubchannel(SubchannelKey* key,
76 Subchannel* constructed) = 0;
83 virtual Subchannel* FindSubchannel(SubchannelKey* key) = 0;
|
| D | local_subchannel_pool.h | 43 Subchannel* RegisterSubchannel(SubchannelKey* key,
44 Subchannel* constructed) override;
46 Subchannel* FindSubchannel(SubchannelKey* key) override;
|
| D | global_subchannel_pool.h | 48 Subchannel* RegisterSubchannel(SubchannelKey* key,
49 Subchannel* constructed) override;
51 Subchannel* FindSubchannel(SubchannelKey* key) override;
|
| /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 | 59 import io.grpc.LoadBalancer.Subchannel;
150 private final LinkedList<Subchannel> mockSubchannels = new LinkedList<Subchannel>();
152 private final ArrayList<Subchannel> subchannelTracker = new ArrayList<>();
218 doAnswer(new Answer<Subchannel>() { in setUp()
220 public Subchannel answer(InvocationOnMock invocation) throws Throwable { in setUp()
221 Subchannel subchannel = mock(Subchannel.class); in setUp()
280 for (Subchannel subchannel: subchannelTracker) { in tearDown()
300 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerNoDrop()
338 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithDrop()
434 Subchannel subchannel1 = mockSubchannels.poll(); in loadReporting()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 147 Subchannel subchannel, ConnectivityStateInfo stateInfo); in handleSubchannelState()
243 @Nullable private final Subchannel subchannel;
253 @Nullable Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory, in PickResult()
329 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel()
340 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
385 public Subchannel getSubchannel() { in getSubchannel()
470 public Subchannel createSubchannel(EquivalentAddressGroup addrs, Attributes attrs) { in createSubchannel()
487 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel()
504 Subchannel subchannel, EquivalentAddressGroup addrs) { in updateSubchannelAddresses()
519 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()
219 for (Subchannel subchannel : subchannels.values()) { in maybeUseFallbackBackends()
311 for (Subchannel subchannel : subchannels.values()) { in shutdown()
346 HashMap<EquivalentAddressGroup, Subchannel> newSubchannelMap = in useRoundRobinLists()
347 new HashMap<EquivalentAddressGroup, Subchannel>(); in useRoundRobinLists()
352 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists()
377 for (Entry<EquivalentAddressGroup, Subchannel> entry : subchannels.entrySet()) { in useRoundRobinLists()
674 Subchannel subchannel = entry.result.getSubchannel(); in maybeUpdatePicker()
[all …]
|
| /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 {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 32 import io.grpc.LoadBalancer.Subchannel;
91 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in forwardsCalls()
120 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_keepOldBalancer()
154 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in handleResolvedAddressGroups_shutsDownOldBalancer()
175 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleResolvedAddressGroups_shutsDownOldBalancer()
283 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in channelTracing_lbPolicyChanged()
362 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
385 public Subchannel createSubchannel(List<EquivalentAddressGroup> addrs, Attributes attrs) { in createSubchannel()
428 private static class TestSubchannel extends Subchannel {
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/rpc/ |
| D | grpc_channelz.py | 38 Subchannel = channelz_pb2.Subchannel variable
174 channel: Channel) -> Iterator[Subchannel]:
180 subchannel: Subchannel) -> Iterator[Socket]: argument
185 def get_subchannel(self, subchannel_id) -> Subchannel:
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/insecure/ |
| D | channel_create.cc | 40 Subchannel* CreateSubchannel(const grpc_channel_args* args) override { in CreateSubchannel()
43 Subchannel* s = in CreateSubchannel()
44 Subchannel::Create(MakeOrphanable<Chttp2Connector>(), new_args); in CreateSubchannel()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/secure/ |
| D | secure_channel_create.cc | 46 Subchannel* CreateSubchannel(const grpc_channel_args* args) override { in CreateSubchannel()
53 Subchannel* s = in CreateSubchannel()
54 Subchannel::Create(MakeOrphanable<Chttp2Connector>(), new_args); in CreateSubchannel()
|