Home
last modified time | relevance | path

Searched refs:runSerialized (Results 1 – 9 of 9) 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.java239 }).when(helper).runSerialized(any(Runnable.class)); in setUp()
780 verify(helper, never()).runSerialized(any(Runnable.class)); in grpclbThenNameResolutionFails()
784 verify(helper, times(2)).runSerialized(any(Runnable.class)); in grpclbThenNameResolutionFails()
1072 inOrder.verify(helper, atLeast(0)).runSerialized(any(Runnable.class)); in subtestGrpclbFallbackInitialTimeout()
1204 inOrder.verify(helper, atLeast(0)).runSerialized(any(Runnable.class)); in grpclbFallback_breakLbStreamBeforeFallbackTimerExpires()
1274 inOrder.verify(helper, atLeast(0)).runSerialized(any(Runnable.class)); in subtestGrpclbFallbackConnectionLost()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DForwardingLoadBalancerHelper.java77 public void runSerialized(Runnable task) { in runSerialized() method in ForwardingLoadBalancerHelper
78 delegate().runSerialized(task); in runSerialized()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java395 helper.runSerialized(new Runnable() { in run()
421 helper.runSerialized(new Runnable() { in run()
451 helper.runSerialized(new Runnable() { in run()
484 helper.runSerialized(new Runnable() { in onNext()
493 helper.runSerialized(new Runnable() { in onError()
503 helper.runSerialized(new Runnable() { in onCompleted()
DCachedSubchannelPool.java107 helper.runSerialized(task); in run()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java1102 runSerialized(new AddSubchannel()); in createSubchannel()
1134 runSerialized(new UpdateBalancingState()); in updateBalancingState()
1218 runSerialized(new AddOobChannel()); in createOobChannel()
1240 public void runSerialized(Runnable task) { in runSerialized() method in ManagedChannelImpl.LbHelperImpl
1311 helper.runSerialized(new NamesResolved()); in onAddresses()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java401 public void runSerialized(Runnable task) { in runSerialized() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
402 delegate().runSerialized(task); in runSerialized()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java576 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