Home
last modified time | relevance | path

Searched defs:picker (Results 1 – 25 of 80) sorted by relevance

1234

/external/tensorflow/tensorflow/core/lib/random/
Dweighted_picker_test.cc42 WeightedPicker picker(0); in TEST() local
48 WeightedPicker picker(1); in TEST() local
56 WeightedPicker picker(0); in TEST() local
65 WeightedPicker picker(1); in TEST() local
74 WeightedPicker picker(1); in TEST() local
96 WeightedPicker picker(2); in TEST() local
126 WeightedPicker picker(size); in TestPicker() local
139 WeightedPicker picker(size); in TestPicker() local
151 WeightedPicker picker(size); in TestPicker() local
157 WeightedPicker picker(size / 3); in TestPicker() local
[all …]
/external/grpc-grpc-java/rls/src/main/java/io/grpc/rls/
DChildLoadBalancerHelper.java37 private final SubchannelPicker picker; field in ChildLoadBalancerHelper
43 SubchannelPicker picker) { in ChildLoadBalancerHelper()
65 super.updateBalancingState(subchannelStateManager.getAggregatedState(), picker); in updateBalancingState() local
71 private final SubchannelPicker picker; field in ChildLoadBalancerHelper.ChildLoadBalancerHelperProvider
74 Helper helper, SubchannelStateManager subchannelStateManager, SubchannelPicker picker) { in ChildLoadBalancerHelperProvider()
/external/grpc-grpc/test/core/client_channel/lb_policy/
Dweighted_round_robin_test.cc238 LoadBalancingPolicy::SubchannelPicker* picker, in ExpectWeightedRoundRobinPicks()
261 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker>* picker, in WaitForWeightedRoundRobinPicks()
336 auto picker = SendInitialUpdateAndWaitForConnected(kAddresses); in TEST_F() local
364 auto picker = SendInitialUpdateAndWaitForConnected(kAddresses); in TEST_F() local
398 auto picker = SendInitialUpdateAndWaitForConnected(kAddresses); in TEST_F() local
432 auto picker = SendInitialUpdateAndWaitForConnected( in TEST_F() local
454 auto picker = SendInitialUpdateAndWaitForConnected( in TEST_F() local
483 auto picker = SendInitialUpdateAndWaitForConnected(kAddresses); in TEST_F() local
495 auto picker = SendInitialUpdateAndWaitForConnected( in TEST_F() local
532 auto picker = SendInitialUpdateAndWaitForConnected( in TEST_F() local
[all …]
Dxds_override_host_test.cc176 LoadBalancingPolicy::SubchannelPicker* picker, in ExpectOverridePicks()
202 LoadBalancingPolicy::SubchannelPicker* picker, in ExpectRoundRobinPicksWithAttribute()
245 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
256 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
265 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
292 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
336 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
369 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
425 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
456 auto picker = ExpectStartupWithRoundRobin(kAddresses); in TEST_F() local
[all …]
Dpick_first_test.cc121 auto picker = WaitForConnected(); in GetOrderAddressesArePicked() local
166 auto picker = WaitForConnected(); in TEST_F() local
208 auto picker = WaitForConnected(); in TEST_F() local
268 auto picker = WaitForConnected(); in TEST_F() local
312 auto picker = WaitForConnected(); in TEST_F() local
357 auto picker = ExpectState(GRPC_CHANNEL_READY); in TEST_F() local
410 auto picker = ExpectState(GRPC_CHANNEL_READY); in TEST_F() local
448 auto picker = WaitForConnected(); in TEST_F() local
560 auto picker = WaitForConnected(); in TEST_F() local
679 auto picker = ExpectState(GRPC_CHANNEL_READY); in TEST_F() local
[all …]
Doutlier_detection_test.cc156 LoadBalancingPolicy::SubchannelPicker* picker) { in DoPickWithFailedCall()
193 auto picker = WaitForConnected(); in TEST_F() local
216 auto picker = ExpectRoundRobinStartup(kAddresses); in TEST_F() local
266 auto picker = ExpectRoundRobinStartup(kEndpoints); in TEST_F() local
364 auto picker = ExpectRoundRobinStartup(kEndpoints); in TEST_F() local
444 auto picker = WaitForConnected(); in TEST_F() local
Dring_hash_test.cc88 auto picker = ExpectState(GRPC_CHANNEL_IDLE); in TEST_F() local
111 auto picker = ExpectState(GRPC_CHANNEL_IDLE); in TEST_F() local
139 auto picker = ExpectState(GRPC_CHANNEL_IDLE); in TEST_F() local
Dlb_policy_test_lib.h428 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker> picker; member
506 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker> picker) in PickerWrapper()
576 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker> picker) override { in UpdateState()
971 auto picker = variable
1065 auto picker = ExpectState(expected_state, expected_status, location); variable
1270 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker> picker; variable
1310 RefCountedPtr<LoadBalancingPolicy::SubchannelPicker> picker; variable
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DGracefulSwitchLoadBalancerTest.java94 SubchannelPicker picker = mock(SubchannelPicker.class); in canHandleEmptyAddressListFromNameResolutionForwardedToLatestPolicy() local
123 SubchannelPicker picker = mock(SubchannelPicker.class); in handleResolvedAddressesAndNameResolutionErrorForwardedToLatestPolicy() local
163 SubchannelPicker picker = mock(SubchannelPicker.class); in shutdownTriggeredWhenSwitchAndForwardedWhenSwitchLbShutdown() local
194 SubchannelPicker picker = mock(SubchannelPicker.class); in requestConnectionForwardedToLatestPolicies() local
231 SubchannelPicker picker = mock(SubchannelPicker.class); in createSubchannelForwarded() local
257 SubchannelPicker picker = mock(SubchannelPicker.class); in updateBalancingStateIsGraceful() local
308 SubchannelPicker picker = mock(SubchannelPicker.class); in switchWhileOldPolicyIsNotReady() local
336 SubchannelPicker picker = mock(SubchannelPicker.class); in switchWhileOldPolicyGoesFromReadyToNotReady() local
367 SubchannelPicker picker = mock(SubchannelPicker.class); in switchWhileOldPolicyGoesFromReadyToNotReadyWhileNewPolicyStillIdle() local
396 SubchannelPicker picker = mock(SubchannelPicker.class); in newPolicyNameTheSameAsPendingPolicy_shouldHaveNoEffect() local
[all …]
DRoundRobinLoadBalancerTest.java215 SubchannelPicker picker = pickerCaptor.getValue(); in pickAfterResolvedUpdatedHosts() local
386 ReadyPicker picker = new ReadyPicker(Collections.unmodifiableList( in pickerRoundRobin() local
400 SubchannelPicker picker = new EmptyPicker(Status.UNKNOWN); in pickerEmptyList() local
534 private static List<Subchannel> getList(SubchannelPicker picker) { in getList()
/external/grpc-grpc-java/rls/src/test/java/io/grpc/rls/
DRlsLoadBalancerTest.java175 SubchannelPicker picker = pickerCaptor.getValue(); in lb_serverStatusCodeConversion() local
205 SubchannelPicker picker = pickerCaptor.getValue(); in lb_working_withDefaultTarget_rlsResponding() local
265 SubchannelPicker picker = pickerCaptor.getValue(); in lb_working_withDefaultTarget_noRlsResponse() local
331 SubchannelPicker picker = pickerCaptor.getValue(); in lb_working_withoutDefaultTarget() local
400 SubchannelPicker picker = pickerCaptor.getValue(); in lb_nameResolutionFailed() local
DChildLoadBalancerHelperTest.java37 private final SubchannelPicker picker = mock(SubchannelPicker.class); field in ChildLoadBalancerHelperTest
/external/perfetto/src/trace_processor/containers/
Drow_map_unittest.cc361 RowMap picker(4, 7); in TEST() local
372 RowMap picker(1u, 3u); in TEST() local
382 RowMap picker(2, 5); in TEST() local
393 RowMap picker(BitVector{true, false, false, true}); in TEST() local
403 RowMap picker(BitVector{false, true}); in TEST() local
412 RowMap picker(BitVector{false, true, true}); in TEST() local
422 RowMap picker(BitVector{true, false, false, true}); in TEST() local
432 RowMap picker(BitVector{false, true}); in TEST() local
441 RowMap picker(BitVector{false, true, true}); in TEST() local
451 RowMap picker(BitVector{true, false, false, true}); in TEST() local
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancer.java215 private void updateBalancingState(ConnectivityState state, RoundRobinPicker picker) { in updateBalancingState()
284 public abstract boolean isEquivalentTo(RoundRobinPicker picker); in isEquivalentTo()
329 public boolean isEquivalentTo(RoundRobinPicker picker) { in isEquivalentTo()
355 public boolean isEquivalentTo(RoundRobinPicker picker) { in isEquivalentTo()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DClusterManagerLoadBalancerTest.java125 SubchannelPicker picker = pickerCaptor.getValue(); in handleResolvedAddressesUpdatesChannelPicker() local
176 SubchannelPicker picker = pickerCaptor.getValue(); in updateBalancingStateFromChildBalancers() local
291 private static PickResult pickSubchannel(SubchannelPicker picker, String clusterName) { in pickSubchannel()
374 SubchannelPicker picker = new SubchannelPicker() { in deliverSubchannelState() local
DLeastRequestLoadBalancerTest.java223 SubchannelPicker picker = pickerCaptor.getValue(); in pickAfterResolvedUpdatedHosts() local
450 ReadyPicker picker = (ReadyPicker) pickerCaptor.getValue(); in pickerLeastRequest() local
488 SubchannelPicker picker = new EmptyPicker(Status.UNKNOWN); in pickerEmptyList() local
629 private static List<Subchannel> getList(SubchannelPicker picker) { in getList()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java389 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocessSemantics() local
504 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocess_NoPendingStream() local
531 SubchannelPicker picker = mock(SubchannelPicker.class); in reprocess_newStreamRacesWithReprocess() local
626 SubchannelPicker picker = new SubchannelPicker() { in newStream_racesWithReprocessIdleMode() local
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
DLeastRequestLoadBalancer.java233 private void updateBalancingState(ConnectivityState state, LeastRequestPicker picker) { in updateBalancingState()
299 abstract boolean isEquivalentTo(LeastRequestPicker picker); in isEquivalentTo()
348 boolean isEquivalentTo(LeastRequestPicker picker) { in isEquivalentTo()
375 boolean isEquivalentTo(LeastRequestPicker picker) { in isEquivalentTo()
DPriorityLoadBalancer.java190 @Nullable String priority, ConnectivityState state, SubchannelPicker picker) { in updateOverallState()
213 SubchannelPicker picker = BUFFER_PICKER; field in PriorityLoadBalancer.ChildLbState
/external/robolectric/robolectric/src/test/java/org/robolectric/shadows/
DShadowNumberPickerTest.java18 NumberPicker picker = new NumberPicker(ApplicationProvider.getApplicationContext()); in shouldFireListeners() local
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DPickFirstLoadBalancer.java132 SubchannelPicker picker; in processSubchannelState() local
155 private void updateBalancingState(ConnectivityState state, SubchannelPicker picker) { in updateBalancingState()
/external/grpc-grpc/src/core/load_balancing/weighted_target/
Dweighted_target.cc173 RefCountedPtr<SubchannelPicker> picker() const { return picker_; } in picker() function in grpc_core::__anon4495eca60111::WeightedTargetLb::WeightedChild
462 RefCountedPtr<SubchannelPicker> picker; in UpdateStateLocked() local
643 RefCountedPtr<SubchannelPicker> picker) { in OnConnectivityStateUpdateLocked()
688 RefCountedPtr<SubchannelPicker> picker) { in UpdateState()
/external/sl4a/ScriptingLayerForAndroid/src/com/googlecode/android_scripting/dialog/
DDurationPickerDialog.java40 final DurationPicker picker = new DurationPicker(activity); in getDurationFromDialog() local
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc170 RefCountedPtr<SubchannelPicker> picker() const { return picker_; } in picker() function in grpc_core::__anon99efb9c70111::WeightedTargetLb::WeightedChild
454 RefCountedPtr<SubchannelPicker> picker; in UpdateStateLocked() local
634 RefCountedPtr<SubchannelPicker> picker) { in OnConnectivityStateUpdateLocked()
687 RefCountedPtr<SubchannelPicker> picker) { in UpdateState()
/external/grpc-grpc/src/core/load_balancing/xds/
Dxds_cluster_manager.cc162 RefCountedPtr<SubchannelPicker> picker() const { return picker_; } in picker() function in grpc_core::__anon89e007310111::XdsClusterManagerLb::ClusterChild
394 auto picker = MakeRefCounted<ClusterPicker>(std::move(cluster_map)); in UpdateStateLocked() local
561 RefCountedPtr<SubchannelPicker> picker) { in UpdateState()

1234