Home
last modified time | relevance | path

Searched defs:subchannel (Results 1 – 25 of 43) sorted by relevance

12

/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DCachedSubchannelPool.java56 Subchannel subchannel; in takeOrCreateSubchannel() local
67 public void returnSubchannel(Subchannel subchannel) { in returnSubchannel()
113 private final Subchannel subchannel; field in CachedSubchannelPool.ShutdownSubchannelTask
116 private ShutdownSubchannelTask(Subchannel subchannel) { in ShutdownSubchannelTask()
134 final Subchannel subchannel; field in CachedSubchannelPool.CacheEntry
137 CacheEntry(Subchannel subchannel, ScheduledFuture<?> shutdownTimer) { in CacheEntry()
DGrpclbState.java165 void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
352 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists() local
674 Subchannel subchannel = entry.result.getSubchannel(); in maybeUpdatePicker() local
816 BackendEntry(Subchannel subchannel, GrpclbClientLoadRecorder loadRecorder, String token) { in BackendEntry()
825 BackendEntry(Subchannel subchannel) { in BackendEntry()
DSubchannelPool.java49 void returnSubchannel(Subchannel subchannel); in returnSubchannel()
DGrpclbLoadBalancer.java80 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java147 Subchannel subchannel, ConnectivityStateInfo stateInfo); in handleSubchannelState()
243 @Nullable private final Subchannel subchannel; field in LoadBalancer.PickResult
252 private PickResult( in PickResult()
329 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel()
340 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
504 Subchannel subchannel, EquivalentAddressGroup addrs) { in updateSubchannelAddresses()
519 Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
DPickFirstBalancerFactory.java59 private Subchannel subchannel; field in PickFirstBalancerFactory.PickFirstBalancer
92 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
148 private final Subchannel subchannel; field in PickFirstBalancerFactory.RequestConnectionPicker
150 RequestConnectionPicker(Subchannel subchannel) { in RequestConnectionPicker()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java171 Subchannel subchannel = checkNotNull( in handleResolvedAddressGroups() local
182 Subchannel subchannel = subchannels.remove(addressGroup); in handleResolvedAddressGroups() local
197 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
211 private void shutdownSubchannel(Subchannel subchannel) { in shutdownSubchannel()
303 Subchannel subchannel) { in getSubchannelStateInfoRef()
308 static boolean isReady(Subchannel subchannel) { in isReady()
350 String stickinessValue, @Nonnull Subchannel subchannel) { in maybeRegister()
385 void remove(Subchannel subchannel) { in remove()
429 Subchannel subchannel = null; in pickSubchannel() local
DForwardingLoadBalancerHelper.java50 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/lb_policy/
Dsubchannel_list.h92 SubchannelInterface* subchannel() const { return subchannel_.get(); } in subchannel() function
184 SubchannelDataType* subchannel(size_t index) { return &subchannels_[index]; } in subchannel() function
270 RefCountedPtr<SubchannelInterface> subchannel) in SubchannelData()
370 RefCountedPtr<SubchannelInterface> subchannel = in SubchannelList() local
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplTest.java344 AbstractSubchannel subchannel = in channelzMembership_subchannel() local
383 AbstractSubchannel subchannel = (AbstractSubchannel) oob.getSubchannel(); in channelzMembership_oob() local
437 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown() local
636 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in callOptionsExecutor() local
852 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in firstResolvedServerFailedToConnect() local
997 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in allServersFailedToConnect() local
1351 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestRefreshNameResolutionWhenConnectionFailed() local
1420 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in informationPropagatedToNewStreamAndCallCredentials() local
1496 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in pickerReturnsStreamTracer_noDelay() local
1534 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in pickerReturnsStreamTracer_delayed() local
[all …]
DManagedChannelImplIdlenessTest.java265 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in realTransportsHoldsOffIdleness() local
304 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_newAddressConnects() local
324 Subchannel subchannel = helper.createSubchannel(servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_existingAddressDoesNotConnect() local
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h90 grpc_subchannel* subchannel() const { return subchannel_; } in subchannel() function
198 SubchannelDataType* subchannel(size_t index) { return &subchannels_[index]; } in subchannel() function
280 const grpc_lb_address& address, grpc_subchannel* subchannel, in SubchannelData()
516 grpc_subchannel* subchannel = grpc_client_channel_factory_create_subchannel( in SubchannelList() local
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java69 private InternalSubchannel subchannel; field in OobChannel
142 void setSubchannel(final InternalSubchannel subchannel) { in setSubchannel()
DAutoConfiguredLoadBalancerFactory.java75 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) {} in handleSubchannelState()
146 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dlocal_subchannel_pool.cc39 Subchannel* subchannel) { in UnregisterSubchannel()
Dsubchannel_interface.h98 explicit DelegatingSubchannel(RefCountedPtr<SubchannelInterface> subchannel) in DelegatingSubchannel()
Dglobal_subchannel_pool.cc65 Subchannel* subchannel) { in UnregisterSubchannel()
Dsubchannel.cc366 Subchannel* subchannel, grpc_connectivity_state state, in AsyncWatcherNotifierLocked()
408 Subchannel* subchannel, grpc_connectivity_state state, in NotifyLocked()
523 WeakRefCountedPtr<Subchannel> subchannel, in AddWatcherLocked()
563 Subchannel* subchannel, const std::string& health_check_service_name) { in CheckConnectivityStateLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc65 grpc_subchannel* subchannel; member
71 grpc_subchannel* subchannel; member
410 grpc_subchannel* subchannel) { in grpc_subchannel_get_channelz_node()
693 void grpc_subchannel_reset_backoff(grpc_subchannel* subchannel) { in grpc_subchannel_reset_backoff()
755 const grpc_subchannel* subchannel) { in grpc_subchannel_get_key()
788 const char* grpc_subchannel_get_target(grpc_subchannel* subchannel) { in grpc_subchannel_get_target()
Dclient_channel_channelz.cc115 SubchannelNode::SubchannelNode(grpc_subchannel* subchannel, in SubchannelNode()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java36 private final Subchannel subchannel = mock(Subchannel.class); field in LoadBalancerTest
184 OverrideGetAllAddresses subchannel = new OverrideGetAllAddresses(); in subchannel_getAddresses_delegates() local
DPickFirstLoadBalancerTest.java165 Subchannel subchannel = pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel(); in pickAfterStateChangeAfterResolution() local
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc70 RefCountedPtr<SubchannelInterface> subchannel) in PickFirstSubchannelData()
113 explicit Picker(RefCountedPtr<SubchannelInterface> subchannel) in Picker()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java300 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerNoDrop() local
338 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithDrop() local
1373 Subchannel subchannel = subchannels.get(i); in fallbackTestVerifyUseOfBackendLists() local
1522 final Subchannel subchannel, final ConnectivityStateInfo newState) { in deliverSubchannelState()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzServiceTest.java94 TestChannel subchannel = new TestChannel(); in getSubchannel() local

12