| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 66 }, executor.getScheduledExecutorService(), CONNECTING); in registerCallbackBeforeStateChanged()
88 }, executor.getScheduledExecutorService(), IDLE); in registerCallbackAfterStateChanged()
105 }, executor.getScheduledExecutorService(), IDLE); in callbackOnlyCalledOnTransition()
121 state.notifyWhenStateChanged(callback, executor.getScheduledExecutorService(), IDLE); in callbacksAreOneShot()
136 callback, executor.getScheduledExecutorService(), TRANSIENT_FAILURE); in callbacksAreOneShot()
157 }, executor.getScheduledExecutorService(), IDLE); in multipleCallbacks()
164 }, executor.getScheduledExecutorService(), IDLE); in multipleCallbacks()
171 }, executor.getScheduledExecutorService(), READY); in multipleCallbacks()
206 state.notifyWhenStateChanged(newRecursiveCallback(executor.getScheduledExecutorService()),
207 executor.getScheduledExecutorService(), state.getState());
|
| D | FakeClockTest.java | 40 ScheduledExecutorService scheduledExecutorService1 = fakeClock.getScheduledExecutorService(); in testScheduledExecutorService_sameInstance()
41 ScheduledExecutorService scheduledExecutorService2 = fakeClock.getScheduledExecutorService(); in testScheduledExecutorService_sameInstance()
48 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_isDone()
61 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_cancel()
74 ScheduledFuture<?> future = fakeClock.getScheduledExecutorService() in testScheduledExecutorService_getDelay()
85 ScheduledFuture<?> unused = fakeClock.getScheduledExecutorService().schedule( in testScheduledExecutorService_result()
130 ScheduledExecutorService scheduledExecutorService = fakeClock.getScheduledExecutorService(); in testPendingAndDueTasks()
164 ScheduledExecutorService scheduledExecutorService = fakeClock.getScheduledExecutorService(); in testTaskFilter()
|
| D | ServerImplTest.java | 201 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in startUp()
1102 executor.getScheduledExecutorService(), in messageRead_errorCancelsCall()
1103 executor.getScheduledExecutorService(), in messageRead_errorCancelsCall()
1127 executor.getScheduledExecutorService(), in messageRead_runtimeExceptionCancelsCall()
1128 executor.getScheduledExecutorService(), in messageRead_runtimeExceptionCancelsCall()
1152 executor.getScheduledExecutorService(), in halfClosed_errorCancelsCall()
1153 executor.getScheduledExecutorService(), in halfClosed_errorCancelsCall()
1175 executor.getScheduledExecutorService(), in halfClosed_runtimeExceptionCancelsCall()
1176 executor.getScheduledExecutorService(), in halfClosed_runtimeExceptionCancelsCall()
1198 executor.getScheduledExecutorService(), in onReady_errorCancelsCall()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 99 new FixedObjectPool<Executor>(executor.getScheduledExecutorService());
101 new FixedObjectPool<Executor>(oobExecutor.getScheduledExecutorService());
121 when(mockTransportFactory.getScheduledExecutorService()) in setUp()
122 .thenReturn(timer.getScheduledExecutorService()); in setUp()
|
| D | ReschedulerTest.java | 40 scheduler.getScheduledExecutorService(),
|
| D | ManagedChannelImplTest.java | 255 when(mockTransportFactory.getScheduledExecutorService()) in setUp()
256 .thenReturn(timer.getScheduledExecutorService()); in setUp()
257 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in setUp()
258 when(oobExecutorPool.getObject()).thenReturn(oobExecutor.getScheduledExecutorService()); in setUp()
321 verify(mockTransportFactory).getScheduledExecutorService(); in shutdownWithNoTransportsEverCreated()
326 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in shutdownWithNoTransportsEverCreated()
546 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in subtestCallsAndShutdown()
632 CallOptions.DEFAULT.withExecutor(callExecutor.getScheduledExecutorService()); in callOptionsExecutor()
1229 verify(oobExecutorPool).returnObject(oobExecutor.getScheduledExecutorService()); in oobchannels()
1260 verify(oobExecutorPool).returnObject(oobExecutor.getScheduledExecutorService()); in oobchannels()
[all …]
|
| D | FakeClock.java | 193 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in FakeClock
|
| D | DelayedClientTransportTest.java | 104 fakeExecutor.getScheduledExecutorService(), new ChannelExecutor());
333 wfr3Executor.getScheduledExecutorService()); in reprocessSemantics()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/ |
| D | InProcessChannelBuilderTest.java | 41 clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
44 TIMER_SERVICE, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
52 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
59 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
|
| D | InProcessServerTest.java | 48 final ScheduledExecutorService ses = new FakeClock().getScheduledExecutorService(); in serverHoldsRefToScheduler()
|
| D | InProcessServerBuilderTest.java | 76 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpChannelBuilderTest.java | 142 clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
145 TIMER_SERVICE, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
153 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
160 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | MaxConnectionIdleManagerTest.java | 59 maxConnectionIdleManager.start(ctx, fakeClock.getScheduledExecutorService()); in maxIdleReached()
71 maxConnectionIdleManager.start(ctx, fakeClock.getScheduledExecutorService()); in maxIdleNotReachedAndReached()
96 maxConnectionIdleManager.start(ctx, fakeClock.getScheduledExecutorService()); in shutdownThenMaxIdleReached()
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetChannelBuilderTest.java | 90 clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
93 TIMER_SERVICE, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_default()
106 assertSame(scheduledExecutorService, clientTransportFactory.getScheduledExecutorService()); in scheduledExecutorService_custom()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | CallCredentialsApplyingTransportFactory.java | 51 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in CallCredentialsApplyingTransportFactory
52 return delegate.getScheduledExecutorService(); in getScheduledExecutorService()
|
| D | ManagedChannelImpl.java | 512 getCallExecutor(callOptions), transportFactory.getScheduledExecutorService(),
600 transportFactory.getScheduledExecutorService(), in ManagedChannelImpl()
821 terminated ? null : transportFactory.getScheduledExecutorService(), in newCall()
1043 transportFactory.getScheduledExecutorService(), in createSubchannel()
1161 authority, oobExecutorPool, transportFactory.getScheduledExecutorService(), in createOobChannel()
1175 transportFactory.getScheduledExecutorService(), stopwatchSupplier, channelExecutor, in createOobChannel()
1358 .getScheduledExecutorService() in onError()
1422 delayedShutdownTask = transportFactory.getScheduledExecutorService().schedule( in shutdown()
|
| D | ServerTransport.java | 46 ScheduledExecutorService getScheduledExecutorService(); in getScheduledExecutorService() method
|
| D | ClientTransportFactory.java | 50 ScheduledExecutorService getScheduledExecutorService(); in getScheduledExecutorService() method
|
| D | ServerImpl.java | 381 handshakeTimeoutFuture = transport.getScheduledExecutorService() in init()
509 timeoutNanos, NANOSECONDS, transport.getScheduledExecutorService()); in createContext()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessChannelBuilder.java | 181 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in InProcessChannelBuilder.InProcessClientTransportFactory
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetChannelBuilder.java | 239 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in CronetChannelBuilder.CronetTransportFactory
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerTransport.java | 146 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in NettyServerTransport
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ContextsTest.java | 218 .withDeadlineAfter(100, TimeUnit.NANOSECONDS, fakeClock.getScheduledExecutorService()); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | CachedSubchannelPoolTest.java | 97 pool.init(helper, clock.getScheduledExecutorService()); in setUp()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpChannelBuilder.java | 551 public ScheduledExecutorService getScheduledExecutorService() { in getScheduledExecutorService() method in OkHttpChannelBuilder.OkHttpTransportFactory
|