| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/io/ |
| D | EventLoopGroup.java | 17 public final class EventLoopGroup extends CrtResource { class
26 public EventLoopGroup(int numThreads) throws CrtRuntimeException { in EventLoopGroup() method in EventLoopGroup
37 public EventLoopGroup(int cpuGroup, int numThreads) throws CrtRuntimeException { in EventLoopGroup() method in EventLoopGroup
86 synchronized (EventLoopGroup.class) { in setStaticDefaultNumThreads()
96 synchronized (EventLoopGroup.class) { in closeStaticDefault()
116 static EventLoopGroup getOrCreateStaticDefault() { in getOrCreateStaticDefault()
117 EventLoopGroup elg = null; in getOrCreateStaticDefault()
118 synchronized (EventLoopGroup.class) { in getOrCreateStaticDefault()
120 staticDefaultEventLoopGroup = new EventLoopGroup(staticDefaultNumThreads); in getOrCreateStaticDefault()
130 private static EventLoopGroup staticDefaultEventLoopGroup;
[all …]
|
| D | ClientBootstrap.java | 25 EventLoopGroup elg = EventLoopGroup.getOrCreateStaticDefault(); in ClientBootstrap()
30 addReferenceTo(EventLoopGroup.getOrCreateStaticDefault()); in ClientBootstrap()
40 public ClientBootstrap(EventLoopGroup elg, HostResolver hr) throws CrtRuntimeException { in ClientBootstrap()
42 elg = EventLoopGroup.getOrCreateStaticDefault(); in ClientBootstrap()
|
| D | ExponentialBackoffRetryOptions.java | 45 private EventLoopGroup eventLoopGroup;
62 public ExponentialBackoffRetryOptions withEventLoopGroup(EventLoopGroup eventLoopGroup) { in withEventLoopGroup()
70 public EventLoopGroup getEventLoopGroup() { in getEventLoopGroup()
|
| D | HostResolver.java | 20 public HostResolver(EventLoopGroup elg) throws CrtRuntimeException { in HostResolver()
29 public HostResolver(EventLoopGroup elg, int maxEntries) throws CrtRuntimeException { in HostResolver()
98 …staticDefaultResolver = new HostResolver(EventLoopGroup.getOrCreateStaticDefault(), staticDefaultM… in getOrCreateStaticDefault()
|
| D | ServerBootstrap.java | 11 private EventLoopGroup eventLoopGroup = null;
16 public ServerBootstrap(final EventLoopGroup elg) { in ServerBootstrap()
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | EventLoopGroupTest.java | 13 import software.amazon.awssdk.crt.io.EventLoopGroup;
20 try (EventLoopGroup elg = new EventLoopGroup(1)) { in testCreateDestroy()
30 try (EventLoopGroup elg = new EventLoopGroup(0,2)) { in testCreateDestroyWithCpuGroup()
|
| D | HttpClientTestFixture.java | 12 import software.amazon.awssdk.crt.io.EventLoopGroup;
23 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createHTTP2ConnectionPoolManager()
39 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createHTTP1ConnectionPoolManager()
|
| D | ServerBootstrapTest.java | 4 import software.amazon.awssdk.crt.io.EventLoopGroup;
16 EventLoopGroup elg = new EventLoopGroup(1); in testCreateDestroy()
|
| D | ServerListenerTest.java | 6 import software.amazon.awssdk.crt.io.EventLoopGroup;
38 EventLoopGroup elGroup = new EventLoopGroup(1); in testSetupAndTearDown()
65 EventLoopGroup elGroup = new EventLoopGroup(1); in testSetupWith0PortAndTearDown()
94 EventLoopGroup elGroup = new EventLoopGroup(1); in testBindErrorPropagates()
137 EventLoopGroup elGroup = new EventLoopGroup(1); in testConnectionHandling()
205 EventLoopGroup elGroup = new EventLoopGroup(1); in testConnectionProtocolMessageHandling()
318 EventLoopGroup elGroup = new EventLoopGroup(1); in testContinuationMessageHandling()
|
| D | ClientBootstrapTest.java | 12 import software.amazon.awssdk.crt.io.EventLoopGroup;
24 EventLoopGroup elg = new EventLoopGroup(1); in testCreateDestroy()
|
| D | ShutdownTest.java | 12 import software.amazon.awssdk.crt.io.EventLoopGroup;
38 try (EventLoopGroup eventLoopGroup = new EventLoopGroup(1); in createConnectionManager()
|
| D | S3ClientTest.java | 78 try (EventLoopGroup elg = new EventLoopGroup(cpuGroup, numThreads)) { in createS3Client()
83 private S3Client createS3Client(S3ClientOptions options, EventLoopGroup elg) { in createS3Client()
133 try (EventLoopGroup elg = new EventLoopGroup(0, 1); in testS3ClientCreateDestroyWithCredentialsProvider()
150 try (EventLoopGroup elg = new EventLoopGroup(0, 1); in testS3ClientCreateDestroyWithoutSigningConfig()
167 …try (EventLoopGroup elg = new EventLoopGroup(0, 1); EventLoopGroup retry_elg = new EventLoopGroup(… in testS3ClientCreateDestroyRetryOptions()
188 try (EventLoopGroup elg = new EventLoopGroup(0, 1)) { in testS3ClientCreateDestroyRetryOptionsUnspecifiedELG()
208 …try (EventLoopGroup elg = new EventLoopGroup(0, 1); EventLoopGroup retry_elg = new EventLoopGroup(… in testS3ClientCreateDestroyTcpKeepAliveOptions()
230 …try (EventLoopGroup elg = new EventLoopGroup(0, 1); EventLoopGroup retry_elg = new EventLoopGroup(… in testS3ClientCreateDestroyMonitoringOptions()
249 try (EventLoopGroup elg = new EventLoopGroup(0, 1); in testS3ClientCreateDestroyHttpProxyOptions()
250 EventLoopGroup retry_elg = new EventLoopGroup(0, 1); in testS3ClientCreateDestroyHttpProxyOptions()
[all …]
|
| D | MqttClientConnectionMethodTest.java | 22 import software.amazon.awssdk.crt.io.EventLoopGroup;
211 try (EventLoopGroup elg = new EventLoopGroup(1); in ConnWS_Cred_UC2()
237 try (EventLoopGroup elg = new EventLoopGroup(1); in ConnWS_Cred_UC3()
269 try (EventLoopGroup elg = new EventLoopGroup(1); in ConnWS_Cred_UC4()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerBuilderTest.java | 25 import io.netty.channel.EventLoopGroup;
137 EventLoopGroup mockEventLoopGroup = mock(EventLoopGroup.class); in assertEventLoopsAndChannelType_onlyBossGroupProvided()
148 EventLoopGroup mockEventLoopGroup = mock(EventLoopGroup.class); in assertEventLoopsAndChannelType_onlyWorkerGroupProvided()
174 EventLoopGroup mockEventLoopGroup = mock(EventLoopGroup.class); in assertEventLoopsAndChannelType_allProvided()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/ |
| D | SdkEventLoopGroup.java | 20 import io.netty.channel.EventLoopGroup;
67 private final EventLoopGroup eventLoopGroup;
71 …SdkEventLoopGroup(EventLoopGroup eventLoopGroup, ChannelFactory<? extends Channel> channelFactory)… in SdkEventLoopGroup()
91 public EventLoopGroup eventLoopGroup() { in eventLoopGroup()
117 …public static SdkEventLoopGroup create(EventLoopGroup eventLoopGroup, ChannelFactory<? extends Cha… in create()
131 public static SdkEventLoopGroup create(EventLoopGroup eventLoopGroup) { in create()
139 private EventLoopGroup resolveEventLoopGroup(DefaultBuilder builder) { in resolveEventLoopGroup()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | RequestContext.java | 18 import io.netty.channel.EventLoopGroup;
29 private final EventLoopGroup eventLoopGroup;
36 EventLoopGroup eventLoopGroup, in RequestContext()
50 public EventLoopGroup eventLoopGroup() { in eventLoopGroup()
|
| D | DelegatingEventLoopGroup.java | 25 import io.netty.channel.EventLoopGroup;
42 public abstract class DelegatingEventLoopGroup implements EventLoopGroup {
44 private final EventLoopGroup delegate;
46 protected DelegatingEventLoopGroup(EventLoopGroup delegate) { in DelegatingEventLoopGroup()
53 public EventLoopGroup getDelegate() { in getDelegate()
|
| D | NonManagedEventLoopGroup.java | 20 import io.netty.channel.EventLoopGroup;
32 public NonManagedEventLoopGroup(EventLoopGroup delegate) { in NonManagedEventLoopGroup()
|
| D | HealthCheckedChannelPool.java | 21 import io.netty.channel.EventLoopGroup;
46 private final EventLoopGroup eventLoopGroup;
50 public HealthCheckedChannelPool(EventLoopGroup eventLoopGroup, in HealthCheckedChannelPool()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | HandshakerServiceChannel.java | 26 import io.netty.channel.EventLoopGroup;
57 EventLoopGroup eventGroup = in create()
96 private final EventLoopGroup eventLoopGroup;
98 public EventLoopHoldingChannel(ManagedChannel delegate, EventLoopGroup eventLoopGroup) { in EventLoopHoldingChannel()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | Utils.java | 44 import io.netty.channel.EventLoopGroup;
88 public static final Resource<EventLoopGroup> NIO_BOSS_EVENT_LOOP_GROUP
90 public static final Resource<EventLoopGroup> NIO_WORKER_EVENT_LOOP_GROUP
93 public static final Resource<EventLoopGroup> DEFAULT_BOSS_EVENT_LOOP_GROUP;
94 public static final Resource<EventLoopGroup> DEFAULT_WORKER_EVENT_LOOP_GROUP;
111 private static final Constructor<? extends EventLoopGroup> EPOLL_EVENT_LOOP_GROUP_CONSTRUCTOR;
345 private static Constructor<? extends EventLoopGroup> epollEventLoopGroupConstructor() { in epollEventLoopGroupConstructor()
348 .forName("io.netty.channel.epoll.EpollEventLoopGroup").asSubclass(EventLoopGroup.class) in epollEventLoopGroupConstructor()
370 private static EventLoopGroup createEpollEventLoopGroup( in createEpollEventLoopGroup()
417 private static final class DefaultEventLoopGroupResource implements Resource<EventLoopGroup> {
[all …]
|
| D | NettyServerBuilder.java | 49 import io.netty.channel.EventLoopGroup;
84 private static final ObjectPool<? extends EventLoopGroup> DEFAULT_BOSS_EVENT_LOOP_GROUP_POOL =
86 private static final ObjectPool<? extends EventLoopGroup> DEFAULT_WORKER_EVENT_LOOP_GROUP_POOL =
97 private ObjectPool<? extends EventLoopGroup> bossEventLoopGroupPool =
99 private ObjectPool<? extends EventLoopGroup> workerEventLoopGroupPool =
290 public NettyServerBuilder bossEventLoopGroup(EventLoopGroup group) { in bossEventLoopGroup()
299 ObjectPool<? extends EventLoopGroup> bossEventLoopGroupPool) { in bossEventLoopGroupPool()
328 public NettyServerBuilder workerEventLoopGroup(EventLoopGroup group) { in workerEventLoopGroup()
337 ObjectPool<? extends EventLoopGroup> workerEventLoopGroupPool) { in workerEventLoopGroupPool()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 31 import io.netty.channel.EventLoopGroup;
93 final EventLoopGroup boss; in newServer()
94 final EventLoopGroup worker; in newServer()
112 (EventLoopGroup) in newServer()
117 (EventLoopGroup) in newServer()
135 (EventLoopGroup) in newServer()
140 (EventLoopGroup) in newServer()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/ |
| D | ChannelResolver.java | 22 import io.netty.channel.EventLoopGroup;
65 …public static ChannelFactory<? extends Channel> resolveSocketChannelFactory(EventLoopGroup eventLo… in resolveSocketChannelFactory()
93 …nnelFactory<? extends DatagramChannel> resolveDatagramChannelFactory(EventLoopGroup eventLoopGroup… in resolveDatagramChannelFactory()
|
| /external/aws-sdk-java-v2/services/s3/src/it/java/software/amazon/awssdk/services/ |
| D | BlockHoundInstalledTest.java | 26 import io.netty.channel.EventLoopGroup;
66 EventLoopGroup bossGroup;
67 EventLoopGroup workerGroup;
|