Home
last modified time | relevance | path

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

/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DProtocolNegotiators.java361 final ObjectPool<? extends Executor> executorPool) { in serverTls() argument
364 if (executorPool != null) { in serverTls()
369 executor = executorPool.getObject(); in serverTls()
377 ChannelHandler sth = new ServerTlsHandler(gnh, sslContext, executorPool); in serverTls()
383 if (executorPool != null && executor != null) { in serverTls()
384 executorPool.returnObject(executor); in serverTls()
411 final ObjectPool<? extends Executor> executorPool) {
414 if (executorPool != null) {
415 this.executor = executorPool.getObject();
546 ObjectPool<? extends Executor> executorPool) {
[all …]
DNettyChannelBuilder.java566 ObjectPool<? extends Executor> executorPool) { in createProtocolNegotiatorByType() argument
573 return ProtocolNegotiators.tls(sslContext, executorPool); in createProtocolNegotiatorByType()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java77 private final ObjectPool<? extends Executor> executorPool; field in OobChannel
105 String authority, ObjectPool<? extends Executor> executorPool, in OobChannel() argument
111 this.executorPool = checkNotNull(executorPool, "executorPool"); in OobChannel()
112 this.executor = checkNotNull(executorPool.getObject(), "executor"); in OobChannel()
295 executorPool.returnObject(executor); in handleSubchannelTerminated()
DServerImplBuilder.java85 ObjectPool<? extends Executor> executorPool = DEFAULT_EXECUTOR_POOL; field in ServerImplBuilder
125 this.executorPool = executor != null ? new FixedObjectPool<>(executor) : DEFAULT_EXECUTOR_POOL; in executor()
342 return this.executorPool; in getExecutorPool()
DServerImpl.java99 private final ObjectPool<? extends Executor> executorPool; field in ServerImpl
145 this.executorPool = Preconditions.checkNotNull(builder.executorPool, "executorPool"); in ServerImpl()
186 executor = Preconditions.checkNotNull(executorPool.getObject(), "executor"); in start()
360 executor = executorPool.returnObject(executor); in checkForTermination()
DManagedChannelImplBuilder.java107 ObjectPool<? extends Executor> executorPool = DEFAULT_EXECUTOR_POOL; field in ManagedChannelImplBuilder
323 this.executorPool = new FixedObjectPool<>(executor); in executor()
325 this.executorPool = DEFAULT_EXECUTOR_POOL; in executor()
DManagedChannelImpl.java172 private final ObjectPool<? extends Executor> executorPool; field in ManagedChannelImpl
590 this.executorPool = checkNotNull(builder.executorPool, "executorPool"); in ManagedChannelImpl()
591 this.executor = checkNotNull(executorPool.getObject(), "executor"); in ManagedChannelImpl()
1267 executorPool.returnObject(executor);
2178 ExecutorHolder(ObjectPool<? extends Executor> executorPool) {
2179 this.pool = checkNotNull(executorPool, "executorPool");
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyChannelBuilderTest.java209 TrackingObjectPoolForTest executorPool = new TrackingObjectPoolForTest(); in createProtocolNegotiatorByType_tlsWithExecutor() local
210 assertEquals(false, executorPool.isInUse()); in createProtocolNegotiatorByType_tlsWithExecutor()
214 localSslContext, executorPool); in createProtocolNegotiatorByType_tlsWithExecutor()
215 assertEquals(true, executorPool.isInUse()); in createProtocolNegotiatorByType_tlsWithExecutor()
218 assertEquals(false, executorPool.isInUse()); in createProtocolNegotiatorByType_tlsWithExecutor()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java770 private final ObjectPool<Executor> executorPool; field in OkHttpChannelBuilder.OkHttpTransportFactory
792 ObjectPool<Executor> executorPool, in OkHttpTransportFactory() argument
807 this.executorPool = executorPool; in OkHttpTransportFactory()
808 this.executor = executorPool.getObject(); in OkHttpTransportFactory()
873 executorPool, in swapChannelCredentials()
898 executorPool.returnObject(executor); in close()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplBuilderTest.java159 assertNotNull(builder.executorPool); in executor_default()
166 assertEquals(executor, builder.executorPool.getObject()); in executor_normal()
171 ObjectPool<? extends Executor> defaultValue = builder.executorPool; in executor_null()
174 assertEquals(defaultValue, builder.executorPool); in executor_null()
180 assertEquals(MoreExecutors.directExecutor(), builder.executorPool.getObject()); in directExecutor()
DServerImplTest.java169 private ObjectPool<Executor> executorPool; field in ServerImplTest
217 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in startUp()
271 verifyNoMoreInteractions(executorPool); in stopImmediate()
413 verifyNoMoreInteractions(executorPool); in transportServerFailsStartup()
1547 builder.executorPool = executorPool; in createServer()
1552 verify(executorPool).getObject(); in verifyExecutorsAcquired()
1553 verifyNoMoreInteractions(executorPool); in verifyExecutorsAcquired()
1557 verify(executorPool, never()).returnObject(any(Executor.class)); in verifyExecutorsNotReturned()
1561 verify(executorPool).returnObject(same(executor.getScheduledExecutorService())); in verifyExecutorsReturned()
1562 verifyNoMoreInteractions(executorPool); in verifyExecutorsReturned()
DServiceConfigErrorHandlingTest.java151 private ObjectPool<Executor> executorPool; field in ServiceConfigErrorHandlingTest
200 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in setUp()
211 channelBuilder.executorPool = executorPool; in setUp()
DManagedChannelImplIdlenessTest.java116 private final ObjectPool<Executor> executorPool = field in ManagedChannelImplIdlenessTest
174 builder.executorPool = executorPool; in setUp()
DManagedChannelImplTest.java265 private ObjectPool<Executor> executorPool; field in ManagedChannelImplTest
320 when(executorPool.getObject()).thenReturn(executor.getScheduledExecutorService()); in setUp()
337 channelBuilder.executorPool = executorPool; in configureBuilder()
612 verify(executorPool).getObject(); in shutdownWithNoTransportsEverCreated()
613 verify(executorPool, never()).returnObject(any()); in shutdownWithNoTransportsEverCreated()
617 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in shutdownWithNoTransportsEverCreated()
768 verify(executorPool).getObject(); in subtestCallsAndShutdown()
895 verify(executorPool, never()).returnObject(any()); in subtestCallsAndShutdown()
898 verify(executorPool).returnObject(executor.getScheduledExecutorService()); in subtestCallsAndShutdown()
3736 customBuilder.executorPool = executorPool; in badServiceConfigIsRecoverable()