andreacavalli/rockserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add netty epoll

Browse Source
This commit is contained in:
Andrea Cavalli 2024-09-27 00:11:04 +02:00
parent df98b40884
commit 1621bb73ca
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/it/cavallium/rockserver/core/server/GrpcServer.java
View File

@ -71,13 +71,18 @@ public class GrpcServer extends Server {
this.grpc = new GrpcServerImpl(this.getClient()); this.grpc = new GrpcServerImpl(this.getClient());
EventLoopGroup elg; EventLoopGroup elg;
Class<? extends ServerChannel> channelType; Class<? extends ServerChannel> channelType;
try { if (http2Port != 0) {
elg = new EpollEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2);
channelType = EpollServerDomainSocketChannel.class;
} catch (Throwable ex) {
LOG.warn("Can't load Epoll event loop group, the server will be slower", ex);
elg = new NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2); elg = new NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2);
channelType = NioServerSocketChannel.class; channelType = NioServerSocketChannel.class;
} else {
try {
elg = new EpollEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2);
channelType = EpollServerDomainSocketChannel.class;
} catch (Throwable ex) {
LOG.warn("Can't load Epoll event loop group, the server will be slower", ex);
elg = new NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2);
channelType = NioServerSocketChannel.class;
}
} }
this.elg = elg; this.elg = elg;
this.executor = Executors.newWorkStealingPool(Runtime.getRuntime().availableProcessors() * 2); this.executor = Executors.newWorkStealingPool(Runtime.getRuntime().availableProcessors() * 2);