| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | DnsNameResolverProvider.java | 67 args.getSynchronizationContext()), in newNameResolver()
68 args.getSynchronizationContext()); in newNameResolver()
|
| D | PickFirstLoadBalancer.java | 208 helper.getSynchronizationContext().execute(new Runnable() { in pickSubchannel()
|
| /external/grpc-grpc-java/api/src/test/java/io/grpc/ |
| D | NameResolverTest.java | 50 assertThat(args.getSynchronizationContext()).isSameInstanceAs(syncContext); in args()
60 assertThat(args2.getSynchronizationContext()).isSameInstanceAs(syncContext); in args()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | ForwardingLoadBalancerHelper.java | 119 public SynchronizationContext getSynchronizationContext() { in getSynchronizationContext() method in ForwardingLoadBalancerHelper
120 return delegate().getSynchronizationContext(); in getSynchronizationContext()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | CachedSubchannelPool.java | 81 helper.getSynchronizationContext().execute(new Runnable() { in takeOrCreateSubchannel()
115 helper.getSynchronizationContext().schedule( in returnSubchannel()
|
| /external/grpc-grpc-java/rls/src/main/java/io/grpc/rls/ |
| D | LbPolicyConfiguration.java | 301 helper.getSynchronizationContext().execute( in ChildPolicyWrapper()
331 helper.getSynchronizationContext().execute( in refreshState()
342 helper.getSynchronizationContext().execute( in shutdown()
|
| /external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/ |
| D | CdsLoadBalancerProviderTest.java | 74 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| D | ClusterResolverLoadBalancerProviderTest.java | 72 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| D | WeightedRoundRobinLoadBalancerProviderTest.java | 67 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| D | LeastRequestLoadBalancerProviderTest.java | 66 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| D | RingHashLoadBalancerProviderTest.java | 69 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| D | WrrLocalityLoadBalancerTest.java | 99 when(mockHelper.getSynchronizationContext()).thenReturn(syncContext); in setUp()
|
| /external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/ |
| D | XdsNameResolverProvider.java | 83 args.getServiceConfigParser(), args.getSynchronizationContext(), in newNameResolver()
|
| D | ClusterManagerLoadBalancer.java | 65 this.syncContext = checkNotNull(helper.getSynchronizationContext(), "syncContext"); in ClusterManagerLoadBalancer()
|
| D | CdsLoadBalancer2.java | 75 this.syncContext = checkNotNull(helper.getSynchronizationContext(), "syncContext"); in CdsLoadBalancer2()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplIdlenessTest.java | 585 helper.getSynchronizationContext().execute(
614 helper.getSynchronizationContext().execute(
625 helper.getSynchronizationContext().execute(
636 helper.getSynchronizationContext().execute(
|
| D | PickFirstLoadBalancerTest.java | 115 when(mockHelper.getSynchronizationContext()).thenReturn(syncContext); in setUp()
305 when(mockHelper.getSynchronizationContext()).thenReturn(syncContext); in pickAfterStateChangeAfterResolution()
322 verify(mockHelper, atLeast(0)).getSynchronizationContext(); // Don't care in pickAfterStateChangeAfterResolution()
340 when(mockHelper.getSynchronizationContext()).thenReturn(syncContext); in pickAfterResolutionAfterTransientValue()
|
| D | ServiceConfigErrorHandlingTest.java | 569 args.getSynchronizationContext()), in newNameResolver()
570 args.getSynchronizationContext()); in newNameResolver()
|
| D | ManagedChannelImplTest.java | 427 helper.getSynchronizationContext().execute( in createSubchannel_channelBuilderOverrideAuthority()
1395 helper.getSynchronizationContext().execute(new Runnable() { in subchannels()
2001 helper.getSynchronizationContext().schedule(task, 110, TimeUnit.NANOSECONDS, ses); in lbHelper_getScheduledExecutorService()
2029 assertThat(args.getSynchronizationContext()) in lbHelper_getNameResolverArgs()
2030 .isSameInstanceAs(helper.getSynchronizationContext()); in lbHelper_getNameResolverArgs()
4378 helper.getSynchronizationContext().execute( in createSubchannelSafely()
4396 helper.getSynchronizationContext().execute( in createUnstartedSubchannel()
4411 helper.getSynchronizationContext().execute( in requestConnectionSafely()
4422 helper.getSynchronizationContext().execute( in updateBalancingStateSafely()
4432 helper.getSynchronizationContext().execute( in refreshNameResolutionSafely()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | OutlierDetectionLoadBalancerProviderTest.java | 73 when(helper.getSynchronizationContext()).thenReturn(syncContext); in providesLoadBalancer()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/customloadbalance/ |
| D | ShufflingPickFirstLoadBalancer.java | 194 helper.getSynchronizationContext().execute(new Runnable() { in pickSubchannel()
|
| /external/grpc-grpc-java/rls/src/test/java/io/grpc/rls/ |
| D | LbPolicyConfigurationTest.java | 94 .when(helper).getSynchronizationContext(); in setUp()
|
| /external/grpc-grpc-java/googleapis/src/main/java/io/grpc/googleapis/ |
| D | GoogleCloudToProdNameResolver.java | 114 syncContext = checkNotNull(args, "args").getSynchronizationContext(); in GoogleCloudToProdNameResolver()
|
| /external/grpc-grpc-java/api/src/main/java/io/grpc/ |
| D | NameResolver.java | 317 public SynchronizationContext getSynchronizationContext() { in getSynchronizationContext() method in NameResolver.Args
|
| /external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/ |
| D | OrcaOobUtilTest.java | 237 verify(origHelper, atLeast(0)).getSynchronizationContext(); in singlePolicyTypicalWorkflow()
321 verify(origHelper, atLeast(0)).getSynchronizationContext(); in twoLevelPoliciesTypicalWorkflow()
931 public SynchronizationContext getSynchronizationContext() { in getSynchronizationContext() method in OrcaOobUtilTest.FakeHelper
|