| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | HonorCloseOnReleaseChannelPoolTest.java | 35 ChannelPool channelPool = Mockito.mock(ChannelPool.class); in releaseDoesntCloseIfNotFlagged() local
50 ChannelPool channelPool = Mockito.mock(ChannelPool.class); in releaseClosesIfFlagged() local
72 … HonorCloseOnReleaseChannelPool channelPool = new HonorCloseOnReleaseChannelPool(mockDelegatePool); in release_delegateReleaseFails_futureFailed() local
|
| D | AwaitCloseChannelPoolMapTest.java | 185 SimpleChannelPoolAwareChannelPool channelPool = channelPoolMap.newPool(targetUri); in usingProxy_usesCachedValueWhenPresent() local
266 …ChannelPool channelPool = channelPoolMap.newPool(URI.create("https://localhost:" + mockProxy.port(… in usesProvidedKeyManagersProvider() local
282 …ChannelPool channelPool = channelPoolMap.newPool(URI.create("https://localhost:" + mockProxy.port(… in acquireChannel_autoReadDisabled() local
300 …ChannelPool channelPool = channelPoolMap.newPool(URI.create("https://localhost:" + mockProxy.port(… in releaseChannel_autoReadEnabled() local
|
| D | HandlerRemovingChannelPoolListenerTest.java | 44 private SdkChannelPool channelPool; field in HandlerRemovingChannelPoolListenerTest
|
| D | FutureCancelHandlerTest.java | 57 private SdkChannelPool channelPool; field in FutureCancelHandlerTest
|
| D | HealthCheckedChannelPoolTest.java | 65 private HealthCheckedChannelPool channelPool = new HealthCheckedChannelPool(eventLoopGroup, field in HealthCheckedChannelPoolTest
|
| D | PublisherAdapterTest.java | 69 private SdkChannelPool channelPool; field in PublisherAdapterTest
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | RequestContext.java | 28 private final SdkChannelPool channelPool; field in RequestContext
35 public RequestContext(SdkChannelPool channelPool, in RequestContext()
46 public SdkChannelPool channelPool() { in channelPool() method in RequestContext
|
| D | AwaitCloseChannelPoolMap.java | 231 private SdkChannelPool wrapBaseChannelPool(Bootstrap bootstrap, ChannelPool channelPool) { in wrapBaseChannelPool()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/ |
| D | BetterFixedChannelPool.java | 402 private SdkChannelPool channelPool; field in BetterFixedChannelPool.Builder
412 public Builder channelPool(SdkChannelPool channelPool) { in channelPool() argument
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2GoAwayEventListener.java | 44 …Http2MultiplexedChannelPool channelPool = parentChannel.attr(ChannelAttributeKey.HTTP2_MULTIPLEXED… in onGoAwayReceived() local
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2SettingsFrameHandlerTest.java | 53 private ChannelPool channelPool; field in Http2SettingsFrameHandlerTest
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/utils/ |
| D | BetterFixedChannelPoolTest.java | 52 private BetterFixedChannelPool channelPool; field in BetterFixedChannelPoolTest
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiator.java | 377 private final ObjectPool<Channel> channelPool; field in AltsProtocolNegotiator.LazyChannel
381 LazyChannel(ObjectPool<Channel> channelPool) { in LazyChannel()
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/ |
| D | ChannelPoolTest.java | 615 ChannelPool channelPool = ChannelPool.create(channelPoolSettings, factory); in testReleasingClientCallCancelEarly() local
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/ |
| D | NettyNioAsyncHttpClientWireMockTest.java | 301 SdkChannelPool channelPool = mock(SdkChannelPool.class); in closeClient_shouldCloseUnderlyingResources() local
|