Home
last modified time | relevance | path

Searched refs:executorPool (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java77 private final ObjectPool<? extends Executor> executorPool; field in OobChannel
104 String authority, ObjectPool<? extends Executor> executorPool, in OobChannel() argument
109 this.executorPool = checkNotNull(executorPool, "executorPool"); in OobChannel()
110 this.executor = checkNotNull(executorPool.getObject(), "executor"); in OobChannel()
278 executorPool.returnObject(executor); in handleSubchannelTerminated()
DAbstractServerImplBuilder.java97 ObjectPool<? extends Executor> executorPool = DEFAULT_EXECUTOR_POOL; field in AbstractServerImplBuilder
128 this.executorPool = new FixedObjectPool<Executor>(executor); in executor()
130 this.executorPool = DEFAULT_EXECUTOR_POOL; in executor()
DServerImpl.java86 private final ObjectPool<? extends Executor> executorPool; field in ServerImpl
131 this.executorPool = Preconditions.checkNotNull(builder.executorPool, "executorPool"); in ServerImpl()
167 executor = Preconditions.checkNotNull(executorPool.getObject(), "executor"); in start()
320 executor = executorPool.returnObject(executor); in checkForTermination()
DAbstractManagedChannelImplBuilder.java98 ObjectPool<? extends Executor> executorPool = DEFAULT_EXECUTOR_POOL; field in AbstractManagedChannelImplBuilder
207 this.executorPool = new FixedObjectPool<Executor>(executor); in executor()
209 this.executorPool = DEFAULT_EXECUTOR_POOL; in executor()
DManagedChannelImpl.java123 private final ObjectPool<? extends Executor> executorPool; field in ManagedChannelImpl
560 this.executorPool = checkNotNull(builder.executorPool, "executorPool"); in ManagedChannelImpl()
562 this.executor = checkNotNull(executorPool.getObject(), "executor"); in ManagedChannelImpl()
849 executorPool.returnObject(executor); in maybeTerminateChannel()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractManagedChannelImplBuilderTest.java75 assertNotNull(builder.executorPool); in executor_default()
82 assertEquals(executor, builder.executorPool.getObject()); in executor_normal()
87 ObjectPool<? extends Executor> defaultValue = builder.executorPool; in executor_null()
90 assertEquals(defaultValue, builder.executorPool); in executor_null()
96 assertEquals(MoreExecutors.directExecutor(), builder.executorPool.getObject()); in directExecutor()
DServerImplTest.java161 private ObjectPool<Executor> executorPool; field in ServerImplTest
201 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in startUp()
239 verifyNoMoreInteractions(executorPool); in stopImmediate()
381 verifyNoMoreInteractions(executorPool); in transportServerFailsStartup()
1328 builder.executorPool = executorPool; in createServer()
1333 verify(executorPool).getObject(); in verifyExecutorsAcquired()
1334 verifyNoMoreInteractions(executorPool); in verifyExecutorsAcquired()
1338 verify(executorPool, never()).returnObject(any(Executor.class)); in verifyExecutorsNotReturned()
1342 verify(executorPool).returnObject(same(executor.getScheduledExecutorService())); in verifyExecutorsReturned()
1343 verifyNoMoreInteractions(executorPool); in verifyExecutorsReturned()
DManagedChannelImplIdlenessTest.java98 private final ObjectPool<Executor> executorPool = field in ManagedChannelImplIdlenessTest
143 builder.executorPool = executorPool; in setUp()
DManagedChannelImplTest.java202 private ObjectPool<Executor> executorPool; field in ManagedChannelImplTest
257 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in setUp()
265 channelBuilder.executorPool = executorPool; in setUp()
319 verify(executorPool).getObject(); in shutdownWithNoTransportsEverCreated()
320 verify(executorPool, never()).returnObject(anyObject()); in shutdownWithNoTransportsEverCreated()
326 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in shutdownWithNoTransportsEverCreated()
430 verify(executorPool).getObject(); in subtestCallsAndShutdown()
543 verify(executorPool, never()).returnObject(anyObject()); in subtestCallsAndShutdown()
546 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in subtestCallsAndShutdown()
2752 this.executorPool = ManagedChannelImplTest.this.executorPool; in badServiceConfigIsRecoverable()