Home
last modified time | relevance | path

Searched defs:subchannel (Results 1 – 25 of 32) 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()
DSubchannelPool.java49 void returnSubchannel(Subchannel subchannel); in returnSubchannel()
DGrpclbState.java165 void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
355 Subchannel subchannel = newSubchannelMap.get(eag); in useRoundRobinLists() local
680 Subchannel subchannel = entry.result.getSubchannel(); in maybeUpdatePicker() local
822 BackendEntry(Subchannel subchannel, GrpclbClientLoadRecorder loadRecorder, String token) { in BackendEntry()
831 BackendEntry(Subchannel subchannel) { in BackendEntry()
DGrpclbLoadBalancer.java80 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java146 Subchannel subchannel, ConnectivityStateInfo stateInfo); in handleSubchannelState()
237 @Nullable private final Subchannel subchannel; field in LoadBalancer.PickResult
246 private PickResult( in PickResult()
323 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel()
334 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
498 Subchannel subchannel, EquivalentAddressGroup addrs) { in updateSubchannelAddresses()
513 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
/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/test/java/io/grpc/internal/
DManagedChannelImplTest.java345 AbstractSubchannel subchannel = in channelzMembership_subchannel() local
384 AbstractSubchannel subchannel = (AbstractSubchannel) oob.getSubchannel(); in channelzMembership_oob() local
438 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestCallsAndShutdown() local
637 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in callOptionsExecutor() local
853 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in firstResolvedServerFailedToConnect() local
998 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in allServersFailedToConnect() local
1352 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in subtestRefreshNameResolutionWhenConnectionFailed() local
1420 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in informationPropagatedToNewStreamAndCallCredentials() local
1495 Subchannel subchannel = helper.createSubchannel(addressGroup, Attributes.EMPTY); in pickerReturnsStreamTracer_noDelay() local
1533 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
DDelayedClientTransportTest.java455 AbstractSubchannel subchannel = mock(AbstractSubchannel.class); in reprocess_NoPendingStream() local
DAutoConfiguredLoadBalancerFactoryTest.java284 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java62 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) {} in handleSubchannelState()
115 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
DOobChannel.java69 private InternalSubchannel subchannel; field in OobChannel
142 void setSubchannel(final InternalSubchannel subchannel) { in setSubchannel()
DManagedChannelImpl.java1031 final SubchannelImpl subchannel = new SubchannelImpl(attrs); in createSubchannel() local
1144 LoadBalancer.Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
1374 InternalSubchannel subchannel; field in ManagedChannelImpl.SubchannelImpl
/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/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java301 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerNoDrop() local
339 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithDrop() local
1342 Subchannel subchannel = subchannels.get(i); in fallbackTestVerifyUseOfBackendLists() local
1491 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
DChannelzProtoUtilTest.java117 private final TestChannel subchannel = new TestChannel(); field in ChannelzProtoUtilTest
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java257 Subchannel subchannel = loadBalancer.getSubchannels().iterator().next(); in pickAfterStateChange() local
296 Subchannel subchannel = mock(Subchannel.class); in pickerRoundRobin() local
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzProtoUtil.java410 static Subchannel toSubchannel(InternalInstrumented<ChannelStats> subchannel) { in toSubchannel()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc78 const grpc_lb_address& address, grpc_subchannel* subchannel, in PickFirstSubchannelData()

12