Home
last modified time | relevance | path

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

123456

/aosp_15_r20/external/grpc-grpc/test/core/client_channel/lb_policy/
H A Dpick_first_test.cc89 auto* subchannel = FindSubchannel(address); in GetOrderAddressesArePicked() local
96 SubchannelState* subchannel = nullptr; in GetOrderAddressesArePicked() local
149 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
182 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
229 auto* subchannel = FindSubchannel(kEndpoint1Addresses[0]); in TEST_F() local
282 auto* subchannel = CreateSubchannel(kAddresses[0]); in TEST_F() local
325 auto* subchannel = CreateSubchannel(kAddresses[0]); in TEST_F() local
370 auto* subchannel = CreateSubchannel(kAddresses[0]); in TEST_F() local
431 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
522 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
[all …]
H A Dweighted_round_robin_test.cc132 auto* subchannel = FindSubchannel(addresses[i]); local
226 auto* subchannel = FindSubchannel(p.first); in ReportOobBackendMetrics() local
522 auto* subchannel = FindSubchannel(address); in TEST_F() local
566 auto* subchannel = FindSubchannel(address); in TEST_F() local
610 auto* subchannel = FindSubchannel(address); in TEST_F() local
635 auto* subchannel = FindSubchannel(address); in TEST_F() local
768 auto* subchannel = FindSubchannel(kAddresses[2]); in TEST_F() local
H A Dring_hash_test.cc93 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
116 auto* subchannel = FindSubchannel(kAddresses[0]); in TEST_F() local
145 auto* subchannel = FindSubchannel(kEndpoint1Addresses[0]); in TEST_F() local
/aosp_15_r20/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
H A DManagedChannelImplTest.java390 Subchannel subchannel = in createSubchannel_resolverOverrideAuthority() local
416 final Subchannel subchannel = in createSubchannel_channelBuilderOverrideAuthority() local
491 Subchannel subchannel = in startCallBeforeNameResolution() local
573 Subchannel subchannel = in newCallWithConfigSelector() local
671 AbstractSubchannel subchannel = in channelzMembership_subchannel() local
718 AbstractSubchannel subchannel = (AbstractSubchannel) oob.getSubchannel(); in channelzMembership_oob() local
776 Subchannel subchannel = in subtestCallsAndShutdown() local
1006 Subchannel subchannel = in callOptionsExecutor() local
1095 Subchannel subchannel = in delayedNameResolution() local
1174 Subchannel subchannel = in firstResolvedServerFailedToConnect() local
[all …]
H A DManagedChannelImplIdlenessTest.java335 Subchannel subchannel = createSubchannelSafely(helper, addressGroup, Attributes.EMPTY); in realTransportsHoldsOffIdleness() local
382 Subchannel subchannel = createSubchannelSafely(helper, addressGroup, Attributes.EMPTY); in enterIdleWhileRealTransportInProgress() local
419 Subchannel subchannel = createSubchannelSafely(helper, servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_newAddressConnects() local
443 Subchannel subchannel = createSubchannelSafely(helper, servers.get(0), Attributes.EMPTY); in updateSubchannelAddresses_existingAddressDoesNotConnect() local
/aosp_15_r20/external/grpc-grpc/src/core/load_balancing/xds/
H A Dxds_override_host.cc159 auto subchannel = in Clone() local
170 WeakRefCountedPtr<SubchannelWrapper> subchannel) in ConnectivityStateWatcher()
230 void SetOwnedSubchannel(RefCountedPtr<SubchannelWrapper> subchannel) in SetOwnedSubchannel()
329 RefCountedPtr<SubchannelWrapper> subchannel) in SubchannelConnectionRequester()
500 auto subchannel = it->second->GetSubchannelRef(); in PickOverridenHost() local
973 RefCountedPtr<SubchannelInterface> subchannel) { in AdoptSubchannel()
1003 auto subchannel = channel_control_helper()->CreateSubchannel( in CreateSubchannelForAddress() local
1034 auto subchannel = p.second->TakeOwnedSubchannel(); in CleanupSubchannels() local
1071 auto subchannel = parent()->channel_control_helper()->CreateSubchannel( in CreateSubchannel() local
1093 RefCountedPtr<SubchannelInterface> subchannel, in SubchannelWrapper()
[all …]
/aosp_15_r20/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
H A DHealthCheckingLoadBalancerFactoryTest.java281 FakeSubchannel subchannel = subchannels[i]; in typicalWorkflow() local
339 FakeSubchannel subchannel = subchannels[i]; in typicalWorkflow() local
451 FakeSubchannel subchannel = unwrap(createSubchannel(0, Attributes.EMPTY)); in backoffRetriesWhenServerErroneouslyClosesRpcBeforeAnyResponse() local
523 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serverRespondResetsBackoff() local
659 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigDisablesHealthCheckWhenRpcActive() local
703 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigDisablesHealthCheckWhenRetryPending() local
756 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigDisablesHealthCheckWhenRpcInactive() local
802 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigChangesServiceNameWhenRpcActive() local
862 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigChangesServiceNameWhenRetryPending() local
933 Subchannel subchannel = createSubchannel(0, Attributes.EMPTY); in serviceConfigChangesServiceNameWhenRpcInactive() local
[all …]
/aosp_15_r20/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
H A DCachedSubchannelPool.java61 final Subchannel subchannel; in takeOrCreateSubchannel() local
92 Subchannel subchannel, ConnectivityStateInfo newStateInfo) { in updateCachedSubchannelState()
102 public void returnSubchannel(Subchannel subchannel, ConnectivityStateInfo lastKnownState) { in returnSubchannel()
133 private final Subchannel subchannel; field in CachedSubchannelPool.ShutdownSubchannelTask
135 private ShutdownSubchannelTask(Subchannel subchannel) { in ShutdownSubchannelTask()
149 final Subchannel subchannel; field in CachedSubchannelPool.CacheEntry
153 CacheEntry(Subchannel subchannel, ScheduledHandle shutdownTimer, ConnectivityStateInfo state) { in CacheEntry()
H A DGrpclbState.java229 void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState()
464 private void returnSubchannelToPool(Subchannel subchannel) { in returnSubchannelToPool()
492 Subchannel subchannel = newSubchannelMap.get(eagAsList); in updateServerList() local
521 final Subchannel subchannel; in updateServerList() local
873 Subchannel subchannel = entry.subchannel; in maybeUpdatePicker() local
991 final Subchannel subchannel; field in GrpclbState.BackendEntry
1000 BackendEntry(Subchannel subchannel, GrpclbClientLoadRecorder loadRecorder, String token) { in BackendEntry()
1010 BackendEntry(Subchannel subchannel) { in BackendEntry()
1019 BackendEntry(Subchannel subchannel, TokenAttachingTracerFactory tracerFactory) { in BackendEntry()
1059 private final Subchannel subchannel; field in GrpclbState.IdleSubchannelEntry
[all …]
/aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
H A DRingHashLoadBalancer.java127 final Subchannel subchannel = helper.createSubchannel( in acceptResolvedAddresses() local
370 private void processSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in processSubchannelState()
381 private void updateConnectivityState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in updateConnectivityState()
395 private static void shutdownSubchannel(Subchannel subchannel) { in shutdownSubchannel()
419 Subchannel subchannel) { in getSubchannelStateInfoRef()
439 Subchannel subchannel = entry.getValue(); in RingHashPicker() local
492 SubchannelView subchannel = pickableSubchannels.get(addrKey); in pickSubchannel() local
527 private PickResult pickSubchannelsNonReady(SubchannelView subchannel) { in pickSubchannelsNonReady()
552 private final Subchannel subchannel; field in RingHashLoadBalancer.SubchannelView
555 private SubchannelView(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in SubchannelView()
H A DLeastRequestLoadBalancer.java126 final Subchannel subchannel = checkNotNull( in acceptResolvedAddresses() local
166 private void processSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in processSubchannelState()
186 private void shutdownSubchannel(Subchannel subchannel) { in shutdownSubchannel()
278 Subchannel subchannel) { in getSubchannelStateInfoRef()
282 private static AtomicInteger getInFlights(Subchannel subchannel) { in getInFlights()
287 static boolean isReady(Subchannel subchannel) { in isReady()
317 final Subchannel subchannel = nextSubchannel(); in pickSubchannel() local
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_override_host.cc146 WeakRefCountedPtr<SubchannelWrapper> subchannel) in ConnectivityStateWatcher()
187 RefCountedPtr<SubchannelWrapper> subchannel) in SubchannelConnectionRequester()
246 void SetSubchannel(SubchannelWrapper* subchannel) { in SetSubchannel()
259 [](XdsOverrideHostLb::SubchannelWrapper* subchannel) { in GetSubchannel()
262 [](RefCountedPtr<XdsOverrideHostLb::SubchannelWrapper> subchannel) { in GetSubchannel()
269 auto subchannel = GetSubchannel(); in SetEdsHealthStatus() local
352 auto subchannel = policy_->GetSubchannelByAddress( in PickOverridenHost() local
555 ServerAddress address, RefCountedPtr<SubchannelInterface> subchannel) { in AdoptSubchannel()
571 SubchannelWrapper* subchannel) { in UnsetSubchannel()
621 auto subchannel = in CreateSubchannel() local
[all …]
/aosp_15_r20/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/customloadbalance/
H A DShufflingPickFirstLoadBalancer.java45 private Subchannel subchannel; field in ShufflingPickFirstLoadBalancer
82 final Subchannel subchannel = helper.createSubchannel( in acceptResolvedAddresses() local
112 private void processSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in processSubchannelState()
184 private final Subchannel subchannel; field in ShufflingPickFirstLoadBalancer.RequestConnectionPicker
187 RequestConnectionPicker(Subchannel subchannel) { in RequestConnectionPicker()
/aosp_15_r20/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/
H A DOrcaOobUtilTest.java259 FakeSubchannel subchannel = subchannels[i]; in singlePolicyTypicalWorkflow() local
297 FakeSubchannel subchannel = subchannels[i]; in singlePolicyTypicalWorkflow() local
343 FakeSubchannel subchannel = subchannels[i]; in twoLevelPoliciesTypicalWorkflow() local
384 FakeSubchannel subchannel = subchannels[i]; in twoLevelPoliciesTypicalWorkflow() local
410 FakeSubchannel subchannel = subchannels[0]; in orcReportingDisabledWhenServiceNotImplemented() local
446 FakeSubchannel subchannel = subchannels[0]; in orcaReportingStreamClosedAndRetried() local
794 final Subchannel subchannel, in setOrcaReportConfig()
919 FakeSubchannel subchannel = new FakeSubchannel(index, args, channels[index]); in createSubchannel() local
/aosp_15_r20/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
H A DPickFirstLoadBalancer.java45 private Subchannel subchannel; field in PickFirstLoadBalancer
75 final Subchannel subchannel = helper.createSubchannel( in acceptResolvedAddresses() local
109 private void processSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in processSubchannelState()
198 private final Subchannel subchannel; field in PickFirstLoadBalancer.RequestConnectionPicker
201 RequestConnectionPicker(Subchannel subchannel) { in RequestConnectionPicker()
/aosp_15_r20/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
H A DRoundRobinLoadBalancer.java108 final Subchannel subchannel = checkNotNull( in acceptResolvedAddresses() local
148 private void processSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in processSubchannelState()
168 private void shutdownSubchannel(Subchannel subchannel) { in shutdownSubchannel()
267 Subchannel subchannel) { in getSubchannelStateInfoRef()
272 static boolean isReady(Subchannel subchannel) { in isReady()
/aosp_15_r20/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
H A DOutlierDetectionLoadBalancerTest.java830 OutlierDetectionSubchannel subchannel = oldAddressTracker.getSubchannels() in subchannelUpdateAddress_singleReplaced() local
872 OutlierDetectionSubchannel subchannel = oldAddressTracker.getSubchannels() in subchannelUpdateAddress_singleReplacedWithMultiple() local
921 OutlierDetectionSubchannel subchannel = oldAddressTracker.getSubchannels() in subchannelUpdateAddress_multipleReplacedWithSingle() local
1066 private void deliverSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in deliverSubchannelState()
1095 Subchannel subchannel = ((OutlierDetectionSubchannel) pickResult.getSubchannel()).delegate(); in generateLoad() local
1138 Subchannel subchannel = helper.createSubchannel(CreateSubchannelArgs.newBuilder() in acceptResolvedAddresses() local
H A DRoundRobinLoadBalancerTest.java257 Subchannel subchannel = loadBalancer.getSubchannels().iterator().next(); in pickAfterStateChange() local
339 Subchannel subchannel = loadBalancer.getSubchannels().iterator().next(); in stayTransientFailureUntilReady() local
382 Subchannel subchannel = mock(Subchannel.class); in pickerRoundRobin() local
539 private void deliverSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in deliverSubchannelState()
/aosp_15_r20/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
H A DClusterImplLoadBalancerTest.java246 Subchannel subchannel = leafBalancer.helper.createSubchannel( in recordLoadStats() local
302 Subchannel subchannel = leafBalancer.helper.createSubchannel( in dropRpcsWithRespectToLbConfigDropCategories() local
377 Subchannel subchannel = leafBalancer.helper.createSubchannel( in subtest_maxConcurrentRequests_appliedByLbConfig() local
465 Subchannel subchannel = leafBalancer.helper.createSubchannel( in subtest_maxConcurrentRequests_appliedWithDefaultValue() local
517 Subchannel subchannel = leafBalancer.helper.createSubchannel(args); in endpointAddressesAttachedWithClusterName() local
565 Subchannel subchannel = leafBalancer.helper.createSubchannel(args); in subtest_endpointAddressesAttachedWithTlsConfig() local
743 void deliverSubchannelState(final Subchannel subchannel, ConnectivityState state) { in deliverSubchannelState()
H A DRingHashLoadBalancerTest.java165 Subchannel subchannel = Iterables.getOnlyElement(subchannels.values()); in subchannelLazyConnectUntilPicked() local
196 Subchannel subchannel = Iterables.getOnlyElement(subchannels.values()); in subchannelNotAutoReconnectAfterReenteringIdle() local
475 Subchannel subchannel = result.getSubchannel(); in deterministicPickWithHostsPartiallyRemoved() local
522 Subchannel subchannel = result.getSubchannel(); in deterministicPickWithNewHostsAdded() local
1106 private void deliverSubchannelState(Subchannel subchannel, ConnectivityStateInfo state) { in deliverSubchannelState()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h99 SubchannelInterface* subchannel() const { return subchannel_.get(); } in subchannel() function
193 SubchannelDataType* subchannel(size_t index) { in subchannel() function
292 RefCountedPtr<SubchannelInterface> subchannel) in SubchannelData()
402 RefCountedPtr<SubchannelInterface> subchannel = in SubchannelList() local
/aosp_15_r20/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
H A DGrpclbLoadBalancerTest.java276 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerNoDrop() local
314 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithDrop() local
368 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithIdleEntry_noDrop() local
391 Subchannel subchannel = mock(Subchannel.class); in roundRobinPickerWithIdleEntry_andDrop() local
1716 Subchannel subchannel = subchannels.get(i); in fallbackTestVerifyUseOfBackendLists() local
1931 Subchannel subchannel = mockSubchannels.poll(); in grpclbWorking_pickFirstMode() local
2052 Subchannel subchannel = mockSubchannels.poll(); in grpclbWorking_pickFirstMode_lbSendsEmptyAddress() local
2189 Subchannel subchannel = mockSubchannels.poll(); in pickFirstModeFallback() local
2705 final Subchannel subchannel, final ConnectivityStateInfo newState) { in deliverSubchannelState()
2913 FakeSubchannel subchannel = in createSubchannel() local
/aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/orca/
H A DOrcaOobUtil.java203 public static void setListener(Subchannel subchannel, OrcaOobReportListener listener, in setListener()
243 Subchannel subchannel = super.createSubchannel(args); in createSubchannel() local
266 @Nullable private Subchannel subchannel; field in OrcaOobUtil.OrcaReportingHelper.OrcaReportingState
293 void init(Subchannel subchannel, SubchannelStateListener stateListener) { in init()
/aosp_15_r20/external/grpc-grpc-java/api/src/main/java/io/grpc/
H A DLoadBalancer.java359 Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState()
485 @Nullable private final Subchannel subchannel; field in LoadBalancer.PickResult
494 private PickResult( in PickResult()
574 Subchannel subchannel, @Nullable ClientStreamTracer.Factory streamTracerFactory) { in withSubchannel()
585 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/ring_hash/
Dring_hash.cc157 RefCountedPtr<SubchannelInterface> subchannel) in RingHashSubchannelData()
293 void AddSubchannel(RefCountedPtr<SubchannelInterface> subchannel) { in AddSubchannel()
303 for (auto& subchannel : self->subchannels_) { in RunInExecCtx() local
318 RefCountedPtr<SubchannelInterface> subchannel; member
389 [&](RefCountedPtr<SubchannelInterface> subchannel) { in Pick()

123456