| /external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/ |
| D | BinderChannelBuilder.java | 250 private final ObjectPool<? extends Executor> offloadExecutorPool; field in BinderChannelBuilder.TransportFactory
263 ObjectPool<? extends Executor> offloadExecutorPool, in TransportFactory() argument
270 this.offloadExecutorPool = offloadExecutorPool; in TransportFactory()
276 offloadExecutor = offloadExecutorPool.getObject(); in TransportFactory()
291 offloadExecutorPool, in newClientTransport()
311 offloadExecutor = offloadExecutorPool.returnObject(offloadExecutor); in close()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | InternalNettyServerCredentials.java | 61 ObjectPool<? extends Executor> offloadExecutorPool) { in toNegotiator() argument
63 result.negotiator.newNegotiator(offloadExecutorPool)); in toNegotiator()
|
| D | ProtocolNegotiator.java | 64 ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool); in newNegotiator() argument
|
| D | InternalProtocolNegotiator.java | 65 @Override ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool); in newNegotiator() argument
|
| D | ProtocolNegotiators.java | 309 public ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool) { in newNegotiator() argument
332 public ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool) { in newNegotiator() argument
351 public ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool) { in newNegotiator() argument
352 return serverTls(sslContext, offloadExecutorPool); in newNegotiator()
|
| /external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/internal/ |
| D | BinderTransport.java | 555 private final ObjectPool<? extends Executor> offloadExecutorPool; field in BinderTransport.BinderClientTransport
575 ObjectPool<? extends Executor> offloadExecutorPool, in BinderClientTransport() argument
583 this.offloadExecutorPool = offloadExecutorPool; in BinderClientTransport()
585 this.offloadExecutor = offloadExecutorPool.getObject(); in BinderClientTransport()
601 offloadExecutorPool.returnObject(offloadExecutor); in releaseExecutors()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelImplBuilder.java | 109 ObjectPool<? extends Executor> offloadExecutorPool = DEFAULT_EXECUTOR_POOL; field in ManagedChannelImplBuilder
333 this.offloadExecutorPool = new FixedObjectPool<>(executor); in offloadExecutor()
335 this.offloadExecutorPool = DEFAULT_EXECUTOR_POOL; in offloadExecutor()
758 return this.offloadExecutorPool;
|
| D | ManagedChannelImpl.java | 595 new ExecutorHolder(checkNotNull(builder.offloadExecutorPool, "offloadExecutorPool")); in ManagedChannelImpl()
|
| /external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/internal/security/ |
| D | SecurityProtocolNegotiators.java | 90 public ProtocolNegotiator newNegotiator(ObjectPool<? extends Executor> offloadExecutorPool) { in newNegotiator() argument
92 fallbackProtocolNegotiator.newNegotiator(offloadExecutorPool)); in newNegotiator()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplBuilderTest.java | 187 assertEquals(executor, builder.offloadExecutorPool.getObject()); in offloadExecutor_normal()
192 ObjectPool<? extends Executor> defaultValue = builder.offloadExecutorPool; in offloadExecutor_null()
195 assertEquals(defaultValue, builder.offloadExecutorPool); in offloadExecutor_null()
|
| /external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/ |
| D | FilterChainMatchingProtocolNegotiators.java | 375 final ObjectPool<? extends Executor> offloadExecutorPool) { in newNegotiator() argument
390 delegate.newNegotiator(offloadExecutorPool)); in newNegotiator()
|