Home
last modified time | relevance | path

Searched defs:eventLoopGroup (Results 1 – 25 of 42) sorted by relevance

12

/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/
H A DNettyNioAsyncHttpClient.java144 private SdkEventLoopGroup eventLoopGroup(DefaultBuilder builder) { in eventLoopGroup() method in NettyNioAsyncHttpClient
191 private SdkEventLoopGroup nonManagedEventLoopGroup(SdkEventLoopGroup eventLoopGroup) { in nonManagedEventLoopGroup()
203 …private void closeEventLoopUninterruptibly(EventLoopGroup eventLoopGroup) throws ExecutionExceptio… in closeEventLoopUninterruptibly()
347 Builder eventLoopGroup(SdkEventLoopGroup eventLoopGroup); in eventLoopGroup() method
499 private SdkEventLoopGroup eventLoopGroup; field in NettyNioAsyncHttpClient.DefaultBuilder
618 public Builder eventLoopGroup(SdkEventLoopGroup eventLoopGroup) { in eventLoopGroup() method in NettyNioAsyncHttpClient.DefaultBuilder
623 public void setEventLoopGroup(SdkEventLoopGroup eventLoopGroup) { in setEventLoopGroup()
H A DSdkEventLoopGroup.java67 private final EventLoopGroup eventLoopGroup; field in SdkEventLoopGroup
71 …SdkEventLoopGroup(EventLoopGroup eventLoopGroup, ChannelFactory<? extends Channel> channelFactory)… in SdkEventLoopGroup()
91 public EventLoopGroup eventLoopGroup() { in eventLoopGroup() method in SdkEventLoopGroup
117 …public static SdkEventLoopGroup create(EventLoopGroup eventLoopGroup, ChannelFactory<? extends Cha… in create()
131 public static SdkEventLoopGroup create(EventLoopGroup eventLoopGroup) { in create()
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
H A DRequestContext.java29 private final EventLoopGroup eventLoopGroup; field in RequestContext
36 EventLoopGroup eventLoopGroup, in RequestContext()
50 public EventLoopGroup eventLoopGroup() { in eventLoopGroup() method in RequestContext
H A DHealthCheckedChannelPool.java46 private final EventLoopGroup eventLoopGroup; field in HealthCheckedChannelPool
50 public HealthCheckedChannelPool(EventLoopGroup eventLoopGroup, in HealthCheckedChannelPool()
H A DListenerInvokingChannelPool.java76 public ListenerInvokingChannelPool(EventLoopGroup eventLoopGroup, in ListenerInvokingChannelPool()
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/
H A DNettyNioAsyncHttpClientWireMockTest.java264 EventLoopGroup eventLoopGroup = spy(new NioEventLoopGroup(0, threadFactory)); in customEventLoopGroup_NotClosedWhenClientIsClosed() local
300 SdkEventLoopGroup eventLoopGroup = SdkEventLoopGroup.builder().build(); in closeClient_shouldCloseUnderlyingResources() local
330 … SdkEventLoopGroup eventLoopGroup = SdkEventLoopGroup.create(customEventLoopGroup, channelFactory); in responseConnectionReused_shouldReleaseChannel() local
354 … SdkEventLoopGroup eventLoopGroup = SdkEventLoopGroup.create(customEventLoopGroup, channelFactory); in connectionInactive_shouldReleaseChannel() local
398 … SdkEventLoopGroup eventLoopGroup = SdkEventLoopGroup.create(customEventLoopGroup, channelFactory); in responseConnectionClosed_shouldCloseAndReleaseChannel() local
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/
H A DChannelResolver.java65 …atic ChannelFactory<? extends Channel> resolveSocketChannelFactory(EventLoopGroup eventLoopGroup) { in resolveSocketChannelFactory()
93 …elFactory<? extends DatagramChannel> resolveDatagramChannelFactory(EventLoopGroup eventLoopGroup) { in resolveDatagramChannelFactory()
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/
H A DHttp2MultiplexedChannelPool.java92 private final EventLoopGroup eventLoopGroup; field in Http2MultiplexedChannelPool
102 EventLoopGroup eventLoopGroup, in Http2MultiplexedChannelPool()
112 EventLoopGroup eventLoopGroup, in Http2MultiplexedChannelPool()
/aosp_15_r20/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
H A DHttpClientTestFixture.java23 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createHTTP2ConnectionPoolManager()
39 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createHTTP1ConnectionPoolManager()
H A DCredentialsProviderTest.java95 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in testCreateDestroyDefaultChain()
113 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in testGetCredentialsDefaultChain()
408 EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in testCreateDestroySts_InvalidRole()
H A DProxyTest.java181 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in buildProxiedConnectionManager()
380 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in buildProxiedX509CredentialsProvider()
433 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in buildDirectMqttConnection()
H A DShutdownTest.java38 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createConnectionManager()
H A DHttpClientConnectionTest.java75 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in testConnectionWithAllCiphers()
/aosp_15_r20/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/io/
H A DExponentialBackoffRetryOptions.java45 private EventLoopGroup eventLoopGroup; field in ExponentialBackoffRetryOptions
62 public ExponentialBackoffRetryOptions withEventLoopGroup(EventLoopGroup eventLoopGroup) { in withEventLoopGroup()
H A DServerBootstrap.java11 private EventLoopGroup eventLoopGroup = null; field in ServerBootstrap
/aosp_15_r20/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
H A DHandshakerServiceChannel.java96 private final EventLoopGroup eventLoopGroup; field in HandshakerServiceChannel.EventLoopHoldingChannel
98 public EventLoopHoldingChannel(ManagedChannel delegate, EventLoopGroup eventLoopGroup) { in EventLoopHoldingChannel()
/aosp_15_r20/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
H A DNettyChannelBuilder.java327 public NettyChannelBuilder eventLoopGroup(@Nullable EventLoopGroup eventLoopGroup) { in eventLoopGroup() method in NettyChannelBuilder
/aosp_15_r20/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
H A DHttp2NettyLocalChannelTest.java39 private DefaultEventLoopGroup eventLoopGroup = new DefaultEventLoopGroup(); field in Http2NettyLocalChannelTest
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
H A DCancellableAcquireChannelPoolTest.java44 private static final EventLoopGroup eventLoopGroup = new NioEventLoopGroup(); field in CancellableAcquireChannelPoolTest
H A DFutureCancelHandlerTest.java65 private EventLoopGroup eventLoopGroup; field in FutureCancelHandlerTest
H A DNettyRequestExecutorTest.java57 private EventLoopGroup eventLoopGroup; field in NettyRequestExecutorTest
H A DHealthCheckedChannelPoolTest.java53 private EventLoopGroup eventLoopGroup = Mockito.mock(EventLoopGroup.class); field in HealthCheckedChannelPoolTest
H A DIdleConnectionCountingChannelPoolTest.java42 private EventLoopGroup eventLoopGroup; field in IdleConnectionCountingChannelPoolTest
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/utils/
H A DBetterFixedChannelPoolTest.java50 private static EventLoopGroup eventLoopGroup; field in BetterFixedChannelPoolTest
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/
H A DHttpOrHttp2ChannelPoolTest.java57 private static EventLoopGroup eventLoopGroup; field in HttpOrHttp2ChannelPoolTest

12