Searched refs:executorPool (Results 1 – 9 of 9) sorted by relevance
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | OobChannel.java | 77 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()
|
| D | AbstractServerImplBuilder.java | 97 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()
|
| D | AbstractManagedChannelImplBuilder.java | 98 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()
|
| D | ServerImpl.java | 86 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()
|
| D | ManagedChannelImpl.java | 123 private final ObjectPool<? extends Executor> executorPool; field in ManagedChannelImpl
539 this.executorPool = checkNotNull(builder.executorPool, "executorPool"); in ManagedChannelImpl()
541 this.executor = checkNotNull(executorPool.getObject(), "executor"); in ManagedChannelImpl()
837 executorPool.returnObject(executor); in maybeTerminateChannel()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractManagedChannelImplBuilderTest.java | 75 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()
|
| D | ServerImplTest.java | 161 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()
|
| D | ManagedChannelImplIdlenessTest.java | 98 private final ObjectPool<Executor> executorPool = field in ManagedChannelImplIdlenessTest
143 builder.executorPool = executorPool; in setUp()
|
| D | ManagedChannelImplTest.java | 201 private ObjectPool<Executor> executorPool; field in ManagedChannelImplTest
256 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in setUp()
264 channelBuilder.executorPool = executorPool; in setUp()
318 verify(executorPool).getObject(); in shutdownWithNoTransportsEverCreated()
319 verify(executorPool, never()).returnObject(anyObject()); in shutdownWithNoTransportsEverCreated()
325 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in shutdownWithNoTransportsEverCreated()
429 verify(executorPool).getObject(); in subtestCallsAndShutdown()
542 verify(executorPool, never()).returnObject(anyObject()); in subtestCallsAndShutdown()
545 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in subtestCallsAndShutdown()
2753 this.executorPool = ManagedChannelImplTest.this.executorPool; in badServiceConfigIsRecoverable()
|