Home
last modified time | relevance | path

Searched refs:runSerialized (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java96 }).when(helper).runSerialized(any(Runnable.class)); in setUp()
136 verify(helper, times(2)).runSerialized(any(ShutdownSubchannelTask.class)); in subchannelExpireAfterReturned()
180 verify(helper, times(2)).runSerialized(any(ShutdownSubchannelTask.class)); in subchannelReused()
209 verify(helper, never()).runSerialized(any(ShutdownSubchannelTask.class)); in returnDuplicateAddressSubchannel()
229 verify(helper, never()).runSerialized(any(ShutdownSubchannelTask.class)); in clear()
DGrpclbLoadBalancerTest.java240 }).when(helper).runSerialized(any(Runnable.class)); in setUp()
781 verify(helper, never()).runSerialized(any(Runnable.class)); in grpclbThenNameResolutionFails()
785 verify(helper, times(2)).runSerialized(any(Runnable.class)); in grpclbThenNameResolutionFails()
1073 inOrder.verify(helper, atLeast(0)).runSerialized(any(Runnable.class)); in subtestGrpclbFallbackInitialTimeout()
1243 inOrder.verify(helper, atLeast(0)).runSerialized(any(Runnable.class)); in subtestGrpclbFallbackConnectionLost()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java399 helper.runSerialized(new Runnable() { in run()
427 helper.runSerialized(new Runnable() { in run()
457 helper.runSerialized(new Runnable() { in run()
490 helper.runSerialized(new Runnable() { in onNext()
499 helper.runSerialized(new Runnable() { in onError()
509 helper.runSerialized(new Runnable() { in onCompleted()
DCachedSubchannelPool.java107 helper.runSerialized(task); in run()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java323 public void runSerialized(Runnable task) { in runSerialized() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
324 delegate().runSerialized(task); in runSerialized()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java1090 runSerialized(new Runnable() { in createSubchannel()
1117 runSerialized( in updateBalancingState()
1207 runSerialized(new Runnable() { in createOobChannel()
1241 public void runSerialized(Runnable task) { in runSerialized() method in ManagedChannelImpl.LbHelperImpl
1312 helper.runSerialized(new NamesResolved()); in onAddresses()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java570 public abstract void runSerialized(Runnable task); in runSerialized() method in LoadBalancer.Helper
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java212 @Override public void runSerialized(Runnable task) {} in runSerialized() method in LoadBalancerTest.NoopHelper