Upstream/VIAaaS
1
0
Fork 0
mirror of https://github.com/ViaVersion/VIAaaS.git synced 2024-11-15 10:55:27 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add system property to enable io_uring

Browse Source
This commit is contained in:
creeper123123321 2021-07-26 17:29:02 -03:00
parent 9790661767
commit 910a0dfe44
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/viaversion/aas/codec/CompressionCodec.java
View File

@ -14,9 +14,7 @@ import java.util.List;
public class CompressionCodec extends MessageToMessageCodec<ByteBuf, ByteBuf> {
// stolen from Krypton (GPL) and modified
// https://github.com/astei/krypton/blob/master/src/main/java/me/steinborn/krypton/mod/shared/network/compression/MinecraftCompressEncoder.java
private static final int VANILLA_MAXIMUM_UNCOMPRESSED_SIZE = 8 * 1024 * 1024; // 8MiB
private static final int HARD_MAXIMUM_UNCOMPRESSED_SIZE = 16 * 1024 * 1024; // 16MiB
private static final int UNCOMPRESSED_CAP = java.lang.Boolean.getBoolean("velocity.increased-compression-cap") ? HARD_MAXIMUM_UNCOMPRESSED_SIZE : VANILLA_MAXIMUM_UNCOMPRESSED_SIZE;
private static final int UNCOMPRESSED_CAP = 8 * 1024 * 1024; // 8MiB
private final int threshold;
private VelocityCompressor compressor;

3
src/main/kotlin/com/viaversion/aas/Util.kt
View File

@ -215,7 +215,8 @@ fun sha512Hex(data: ByteArray): String {
fun eventLoopGroup(): EventLoopGroup {
return when {
//IOUring.isAvailable() -> IOUringEventLoopGroup() // experimental
System.getProperty("com.viaversion.aas.io_uring").toBoolean()
&& IOUring.isAvailable() -> IOUringEventLoopGroup() // experimental
Epoll.isAvailable() -> EpollEventLoopGroup()
KQueue.isAvailable() -> KQueueEventLoopGroup()
else -> NioEventLoopGroup()