Fix compilation
This commit is contained in:
Andrea Cavalli
parent
4df3593271
commit
5a69263bd1
14
pom.xml
14
pom.xml
@ -19,7 +19,7 @@
|
||||
<mainClass>it.cavallium.rockserver.core.Main</mainClass>
|
||||
<protobuf-plugin.version>0.6.1</protobuf-plugin.version>
|
||||
<protobuf.version>3.25.3</protobuf.version>
|
||||
<grpc.version>1.65.0</grpc.version>
|
||||
<grpc.version>1.65.1</grpc.version>
|
||||
<rainbowgum.version>0.7.0</rainbowgum.version>
|
||||
</properties>
|
||||
|
||||
@ -114,6 +114,11 @@
|
||||
<artifactId>grpc-netty</artifactId>
|
||||
<version>${grpc.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.netty</groupId>
|
||||
<artifactId>netty-tcnative-boringssl-static</artifactId>
|
||||
<version>2.0.65.Final</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>io.grpc</groupId>
|
||||
<artifactId>grpc-protobuf</artifactId>
|
||||
@ -359,7 +364,12 @@
|
||||
<buildArg>--initialize-at-run-time=org.rocksdb.RocksObject</buildArg>
|
||||
<buildArg>--initialize-at-run-time=org.rocksdb.RocksDBException</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.util.AbstractReferenceCounted</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.ReferenceCountedOpenSslEngine</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.JdkNpnApplicationProtocolNegotiator</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.JdkAlpnApplicationProtocolNegotiator</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.JdkApplicationProtocolNegotiator</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.OpenSslDefaultApplicationProtocolNegotiator</buildArg>
|
||||
<buildArg>--initialize-at-run-time=io.netty.handler.ssl.OpenSslNpnApplicationProtocolNegotiator</buildArg>
|
||||
<buildArg>--report-unsupported-elements-at-runtime</buildArg>
|
||||
|
||||
<buildArg>-dsa</buildArg>
|
||||
<buildArg>--no-fallback</buildArg>
|
||||
|
||||
@ -21,6 +21,12 @@ module rockserver.core {
|
||||
requires org.graalvm.nativeimage;
|
||||
requires io.netty.common;
|
||||
requires proto.google.common.protos;
|
||||
requires io.netty.handler;
|
||||
requires io.netty.buffer;
|
||||
requires io.netty.transport;
|
||||
requires io.netty.codec.http;
|
||||
requires io.netty.codec;
|
||||
requires io.netty.codec.http2;
|
||||
|
||||
exports it.cavallium.rockserver.core.client;
|
||||
exports it.cavallium.rockserver.core.common;
|
||||
|
||||
@ -0,0 +1,33 @@
|
||||
package it.cavallium.rockserver.core.logging;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
|
||||
import io.netty.util.internal.PlatformDependent;
|
||||
|
||||
public final class EmptyByteBufStub {
|
||||
private static final ByteBuffer EMPTY_BYTE_BUFFER = ByteBuffer.allocateDirect(0);
|
||||
private static final long EMPTY_BYTE_BUFFER_ADDRESS;
|
||||
|
||||
static {
|
||||
long emptyByteBufferAddress = 0;
|
||||
try {
|
||||
if (PlatformDependent.hasUnsafe()) {
|
||||
emptyByteBufferAddress = PlatformDependent.directBufferAddress(EMPTY_BYTE_BUFFER);
|
||||
}
|
||||
} catch (Throwable t) {
|
||||
// Ignore
|
||||
}
|
||||
EMPTY_BYTE_BUFFER_ADDRESS = emptyByteBufferAddress;
|
||||
}
|
||||
|
||||
public static ByteBuffer emptyByteBuffer() {
|
||||
return EMPTY_BYTE_BUFFER;
|
||||
}
|
||||
|
||||
public static long emptyByteBufferAddress() {
|
||||
return EMPTY_BYTE_BUFFER_ADDRESS;
|
||||
}
|
||||
|
||||
private EmptyByteBufStub() {
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,648 @@
|
||||
package it.cavallium.rockserver.core.logging;
|
||||
|
||||
import static io.netty.handler.codec.http.HttpHeaderValues.DEFLATE;
|
||||
import static io.netty.handler.codec.http.HttpHeaderValues.GZIP;
|
||||
import static io.netty.handler.codec.http.HttpHeaderValues.X_DEFLATE;
|
||||
import static io.netty.handler.codec.http.HttpHeaderValues.X_GZIP;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.nio.ByteBuffer;
|
||||
import java.security.InvalidAlgorithmParameterException;
|
||||
import java.security.KeyException;
|
||||
import java.security.NoSuchAlgorithmException;
|
||||
import java.security.PrivateKey;
|
||||
import java.security.Provider;
|
||||
import java.security.SecureRandom;
|
||||
import java.security.cert.X509Certificate;
|
||||
import java.security.spec.InvalidKeySpecException;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Queue;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.LinkedBlockingDeque;
|
||||
import java.util.function.BooleanSupplier;
|
||||
|
||||
import javax.crypto.NoSuchPaddingException;
|
||||
import javax.net.ssl.KeyManagerFactory;
|
||||
import javax.net.ssl.SSLEngine;
|
||||
import javax.net.ssl.SSLException;
|
||||
import javax.net.ssl.TrustManagerFactory;
|
||||
|
||||
import com.oracle.svm.core.annotate.Alias;
|
||||
import com.oracle.svm.core.annotate.RecomputeFieldValue;
|
||||
import com.oracle.svm.core.annotate.RecomputeFieldValue.Kind;
|
||||
import com.oracle.svm.core.annotate.Substitute;
|
||||
import com.oracle.svm.core.annotate.TargetClass;
|
||||
|
||||
import io.netty.bootstrap.AbstractBootstrapConfig;
|
||||
import io.netty.bootstrap.ChannelFactory;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.ByteBufAllocator;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.DefaultChannelPromise;
|
||||
import io.netty.channel.embedded.EmbeddedChannel;
|
||||
import io.netty.handler.codec.compression.ZlibCodecFactory;
|
||||
import io.netty.handler.codec.compression.ZlibWrapper;
|
||||
import io.netty.handler.codec.http.HttpHeaderValues;
|
||||
import io.netty.handler.codec.http2.Http2Exception;
|
||||
import io.netty.handler.ssl.ApplicationProtocolConfig;
|
||||
import io.netty.handler.ssl.ApplicationProtocolConfig.SelectorFailureBehavior;
|
||||
import io.netty.handler.ssl.CipherSuiteFilter;
|
||||
import io.netty.handler.ssl.ClientAuth;
|
||||
import io.netty.handler.ssl.JdkAlpnApplicationProtocolNegotiator;
|
||||
import io.netty.handler.ssl.JdkApplicationProtocolNegotiator;
|
||||
import io.netty.handler.ssl.SslContext;
|
||||
import io.netty.handler.ssl.SslContextOption;
|
||||
import io.netty.handler.ssl.SslProvider;
|
||||
import io.netty.util.concurrent.GlobalEventExecutor;
|
||||
import io.netty.util.internal.logging.InternalLoggerFactory;
|
||||
import io.netty.util.internal.logging.JdkLoggerFactory;
|
||||
|
||||
/**
|
||||
* This substitution avoid having loggers added to the build
|
||||
*/
|
||||
@TargetClass(className = "io.netty.util.internal.logging.InternalLoggerFactory")
|
||||
final class Target_io_netty_util_internal_logging_InternalLoggerFactory {
|
||||
|
||||
@Substitute
|
||||
private static InternalLoggerFactory newDefaultFactory(String name) {
|
||||
return JdkLoggerFactory.INSTANCE;
|
||||
}
|
||||
}
|
||||
|
||||
// SSL
|
||||
// This whole section is mostly about removing static analysis references to openssl/tcnative
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.SslProvider")
|
||||
final class Target_io_netty_handler_ssl_SslProvider {
|
||||
@Substitute
|
||||
public static boolean isAlpnSupported(final SslProvider provider) {
|
||||
switch (provider) {
|
||||
case JDK:
|
||||
return Target_io_netty_handler_ssl_JdkAlpnApplicationProtocolNegotiator.isAlpnSupported();
|
||||
case OPENSSL:
|
||||
case OPENSSL_REFCNT:
|
||||
return false;
|
||||
default:
|
||||
throw new Error("SslProvider unsupported on Quarkus " + provider);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkAlpnApplicationProtocolNegotiator")
|
||||
final class Target_io_netty_handler_ssl_JdkAlpnApplicationProtocolNegotiator {
|
||||
@Alias
|
||||
static boolean isAlpnSupported() {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Hardcode io.netty.handler.ssl.OpenSsl as non-available
|
||||
*/
|
||||
@TargetClass(className = "io.netty.handler.ssl.OpenSsl")
|
||||
final class Target_io_netty_handler_ssl_OpenSsl {
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
private static Throwable UNAVAILABILITY_CAUSE = new RuntimeException("OpenSsl unsupported on Quarkus");
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
static List<String> DEFAULT_CIPHERS = Collections.emptyList();
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
static Set<String> AVAILABLE_CIPHER_SUITES = Collections.emptySet();
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
private static Set<String> AVAILABLE_OPENSSL_CIPHER_SUITES = Collections.emptySet();
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
private static Set<String> AVAILABLE_JAVA_CIPHER_SUITES = Collections.emptySet();
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
private static boolean SUPPORTS_KEYMANAGER_FACTORY = false;
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
private static boolean SUPPORTS_OCSP = false;
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = Kind.FromAlias)
|
||||
static Set<String> SUPPORTED_PROTOCOLS_SET = Collections.emptySet();
|
||||
|
||||
@Substitute
|
||||
public static boolean isAvailable() {
|
||||
return false;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public static int version() {
|
||||
return -1;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public static String versionString() {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public static boolean isCipherSuiteAvailable(String cipherSuite) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkSslServerContext")
|
||||
final class Target_io_netty_handler_ssl_JdkSslServerContext {
|
||||
|
||||
@Alias
|
||||
Target_io_netty_handler_ssl_JdkSslServerContext(Provider provider,
|
||||
X509Certificate[] trustCertCollection,
|
||||
TrustManagerFactory trustManagerFactory,
|
||||
X509Certificate[] keyCertChain,
|
||||
PrivateKey key,
|
||||
String keyPassword,
|
||||
KeyManagerFactory keyManagerFactory,
|
||||
Iterable<String> ciphers,
|
||||
CipherSuiteFilter cipherFilter,
|
||||
ApplicationProtocolConfig apn,
|
||||
long sessionCacheSize,
|
||||
long sessionTimeout,
|
||||
ClientAuth clientAuth,
|
||||
String[] protocols,
|
||||
boolean startTls,
|
||||
String keyStore) throws SSLException {
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkSslClientContext")
|
||||
final class Target_io_netty_handler_ssl_JdkSslClientContext {
|
||||
|
||||
@Alias
|
||||
Target_io_netty_handler_ssl_JdkSslClientContext(Provider sslContextProvider, X509Certificate[] trustCertCollection,
|
||||
TrustManagerFactory trustManagerFactory, X509Certificate[] keyCertChain, PrivateKey key,
|
||||
String keyPassword, KeyManagerFactory keyManagerFactory, Iterable<String> ciphers,
|
||||
CipherSuiteFilter cipherFilter, ApplicationProtocolConfig apn, String[] protocols,
|
||||
long sessionCacheSize, long sessionTimeout, String keyStoreType) throws SSLException {
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.SslHandler$SslEngineType")
|
||||
final class Target_io_netty_handler_ssl_SslHandler$SslEngineType {
|
||||
|
||||
@Alias
|
||||
public static Target_io_netty_handler_ssl_SslHandler$SslEngineType JDK;
|
||||
|
||||
@Substitute
|
||||
static Target_io_netty_handler_ssl_SslHandler$SslEngineType forEngine(SSLEngine engine) {
|
||||
return JDK;
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkAlpnApplicationProtocolNegotiator$AlpnWrapper")
|
||||
final class Target_io_netty_handler_ssl_JdkAlpnApplicationProtocolNegotiator_AlpnWrapper {
|
||||
@Substitute
|
||||
public SSLEngine wrapSslEngine(SSLEngine engine, ByteBufAllocator alloc,
|
||||
JdkApplicationProtocolNegotiator applicationNegotiator, boolean isServer) {
|
||||
return (SSLEngine) (Object) new Target_io_netty_handler_ssl_JdkAlpnSslEngine(engine, applicationNegotiator,
|
||||
isServer);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkAlpnSslEngine")
|
||||
final class Target_io_netty_handler_ssl_JdkAlpnSslEngine {
|
||||
@Alias
|
||||
Target_io_netty_handler_ssl_JdkAlpnSslEngine(final SSLEngine engine,
|
||||
final JdkApplicationProtocolNegotiator applicationNegotiator, final boolean isServer) {
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.SslContext")
|
||||
final class Target_io_netty_handler_ssl_SslContext {
|
||||
|
||||
@Substitute
|
||||
static SslContext newServerContextInternal(SslProvider provider,
|
||||
Provider sslContextProvider,
|
||||
X509Certificate[] trustCertCollection,
|
||||
TrustManagerFactory trustManagerFactory,
|
||||
X509Certificate[] keyCertChain,
|
||||
PrivateKey key,
|
||||
String keyPassword,
|
||||
KeyManagerFactory keyManagerFactory,
|
||||
Iterable<String> ciphers,
|
||||
CipherSuiteFilter cipherFilter,
|
||||
ApplicationProtocolConfig apn,
|
||||
long sessionCacheSize,
|
||||
long sessionTimeout,
|
||||
ClientAuth clientAuth,
|
||||
String[] protocols,
|
||||
boolean startTls,
|
||||
boolean enableOcsp,
|
||||
String keyStoreType,
|
||||
Map.Entry<SslContextOption<?>, Object>... ctxOptions) throws SSLException {
|
||||
if (enableOcsp) {
|
||||
throw new IllegalArgumentException("OCSP is not supported with this SslProvider: " + provider);
|
||||
}
|
||||
return (SslContext) (Object) new Target_io_netty_handler_ssl_JdkSslServerContext(sslContextProvider,
|
||||
trustCertCollection, trustManagerFactory, keyCertChain, key, keyPassword,
|
||||
keyManagerFactory, ciphers, cipherFilter, apn, sessionCacheSize, sessionTimeout, clientAuth, protocols,
|
||||
startTls, keyStoreType);
|
||||
}
|
||||
|
||||
@Substitute
|
||||
static SslContext newClientContextInternal(SslProvider provider, Provider sslContextProvider,
|
||||
X509Certificate[] trustCert,
|
||||
TrustManagerFactory trustManagerFactory, X509Certificate[] keyCertChain, PrivateKey key, String keyPassword,
|
||||
KeyManagerFactory keyManagerFactory, Iterable<String> ciphers, CipherSuiteFilter cipherFilter,
|
||||
ApplicationProtocolConfig apn, String[] protocols, long sessionCacheSize, long sessionTimeout,
|
||||
boolean enableOcsp, String keyStoreType, Map.Entry<SslContextOption<?>, Object>... options) throws SSLException {
|
||||
if (enableOcsp) {
|
||||
throw new IllegalArgumentException("OCSP is not supported with this SslProvider: " + provider);
|
||||
}
|
||||
return (SslContext) (Object) new Target_io_netty_handler_ssl_JdkSslClientContext(sslContextProvider,
|
||||
trustCert, trustManagerFactory, keyCertChain, key, keyPassword,
|
||||
keyManagerFactory, ciphers, cipherFilter, apn, protocols, sessionCacheSize,
|
||||
sessionTimeout, keyStoreType);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkDefaultApplicationProtocolNegotiator")
|
||||
final class Target_io_netty_handler_ssl_JdkDefaultApplicationProtocolNegotiator {
|
||||
|
||||
@Alias
|
||||
public static Target_io_netty_handler_ssl_JdkDefaultApplicationProtocolNegotiator INSTANCE;
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.JdkSslContext")
|
||||
final class Target_io_netty_handler_ssl_JdkSslContext {
|
||||
|
||||
@Substitute
|
||||
static JdkApplicationProtocolNegotiator toNegotiator(ApplicationProtocolConfig config, boolean isServer) {
|
||||
if (config == null) {
|
||||
return (JdkApplicationProtocolNegotiator) (Object) Target_io_netty_handler_ssl_JdkDefaultApplicationProtocolNegotiator.INSTANCE;
|
||||
}
|
||||
|
||||
switch (config.protocol()) {
|
||||
case NONE:
|
||||
return (JdkApplicationProtocolNegotiator) (Object) Target_io_netty_handler_ssl_JdkDefaultApplicationProtocolNegotiator.INSTANCE;
|
||||
case ALPN:
|
||||
if (isServer) {
|
||||
// GRAAL RC9 bug: https://github.com/oracle/graal/issues/813
|
||||
// switch(config.selectorFailureBehavior()) {
|
||||
// case FATAL_ALERT:
|
||||
// return new JdkAlpnApplicationProtocolNegotiator(true, config.supportedProtocols());
|
||||
// case NO_ADVERTISE:
|
||||
// return new JdkAlpnApplicationProtocolNegotiator(false, config.supportedProtocols());
|
||||
// default:
|
||||
// throw new UnsupportedOperationException(new StringBuilder("JDK provider does not support ")
|
||||
// .append(config.selectorFailureBehavior()).append(" failure behavior").toString());
|
||||
// }
|
||||
SelectorFailureBehavior behavior = config.selectorFailureBehavior();
|
||||
if (behavior == SelectorFailureBehavior.FATAL_ALERT) {
|
||||
return new JdkAlpnApplicationProtocolNegotiator(true, config.supportedProtocols());
|
||||
} else if (behavior == SelectorFailureBehavior.NO_ADVERTISE) {
|
||||
return new JdkAlpnApplicationProtocolNegotiator(false, config.supportedProtocols());
|
||||
} else {
|
||||
throw new UnsupportedOperationException(new StringBuilder("JDK provider does not support ")
|
||||
.append(config.selectorFailureBehavior()).append(" failure behavior").toString());
|
||||
}
|
||||
} else {
|
||||
switch (config.selectedListenerFailureBehavior()) {
|
||||
case ACCEPT:
|
||||
return new JdkAlpnApplicationProtocolNegotiator(false, config.supportedProtocols());
|
||||
case FATAL_ALERT:
|
||||
return new JdkAlpnApplicationProtocolNegotiator(true, config.supportedProtocols());
|
||||
default:
|
||||
throw new UnsupportedOperationException(new StringBuilder("JDK provider does not support ")
|
||||
.append(config.selectedListenerFailureBehavior()).append(" failure behavior")
|
||||
.toString());
|
||||
}
|
||||
}
|
||||
default:
|
||||
throw new UnsupportedOperationException(
|
||||
new StringBuilder("JDK provider does not support ").append(config.protocol())
|
||||
.append(" protocol")
|
||||
.toString());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/*
|
||||
* This one only prints exceptions otherwise we get a useless bogus
|
||||
* exception message: https://github.com/eclipse-vertx/vert.x/issues/1657
|
||||
*/
|
||||
@TargetClass(className = "io.netty.bootstrap.AbstractBootstrap")
|
||||
final class Target_io_netty_bootstrap_AbstractBootstrap {
|
||||
|
||||
@Alias
|
||||
private ChannelFactory channelFactory;
|
||||
|
||||
@Alias
|
||||
void init(Channel channel) throws Exception {
|
||||
}
|
||||
|
||||
@Alias
|
||||
public AbstractBootstrapConfig config() {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
final ChannelFuture initAndRegister() {
|
||||
Channel channel = null;
|
||||
try {
|
||||
channel = channelFactory.newChannel();
|
||||
init(channel);
|
||||
} catch (Throwable t) {
|
||||
// THE FIX IS HERE:
|
||||
t.printStackTrace();
|
||||
if (channel != null) {
|
||||
// channel can be null if newChannel crashed (eg SocketException("too many open files"))
|
||||
channel.unsafe().closeForcibly();
|
||||
}
|
||||
// as the Channel is not registered yet, we need to force the usage of the GlobalEventExecutor
|
||||
return new DefaultChannelPromise(channel, GlobalEventExecutor.INSTANCE).setFailure(t);
|
||||
}
|
||||
|
||||
ChannelFuture regFuture = config().group().register(channel);
|
||||
if (regFuture.cause() != null) {
|
||||
if (channel.isRegistered()) {
|
||||
channel.close();
|
||||
} else {
|
||||
channel.unsafe().closeForcibly();
|
||||
}
|
||||
}
|
||||
|
||||
// If we are here and the promise is not failed, it's one of the following cases:
|
||||
// 1) If we attempted registration from the event loop, the registration has been completed at this point.
|
||||
// i.e. It's safe to attempt bind() or connect() now because the channel has been registered.
|
||||
// 2) If we attempted registration from the other thread, the registration request has been successfully
|
||||
// added to the event loop's task queue for later execution.
|
||||
// i.e. It's safe to attempt bind() or connect() now:
|
||||
// because bind() or connect() will be executed *after* the scheduled registration task is executed
|
||||
// because register(), bind(), and connect() are all bound to the same thread.
|
||||
|
||||
return regFuture;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.channel.nio.NioEventLoop")
|
||||
final class Target_io_netty_channel_nio_NioEventLoop {
|
||||
|
||||
@Substitute
|
||||
private static Queue<Runnable> newTaskQueue0(int maxPendingTasks) {
|
||||
return new LinkedBlockingDeque<>();
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.buffer.AbstractReferenceCountedByteBuf")
|
||||
final class Target_io_netty_buffer_AbstractReferenceCountedByteBuf {
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = RecomputeFieldValue.Kind.FieldOffset, name = "refCnt")
|
||||
private static long REFCNT_FIELD_OFFSET;
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.util.AbstractReferenceCounted")
|
||||
final class Target_io_netty_util_AbstractReferenceCounted {
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = RecomputeFieldValue.Kind.FieldOffset, name = "refCnt")
|
||||
private static long REFCNT_FIELD_OFFSET;
|
||||
}
|
||||
|
||||
// This class is runtime-initialized by NettyProcessor
|
||||
final class Holder_io_netty_util_concurrent_ScheduledFutureTask {
|
||||
static final long START_TIME = System.nanoTime();
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.util.concurrent.AbstractScheduledEventExecutor")
|
||||
final class Target_io_netty_util_concurrent_AbstractScheduledEventExecutor {
|
||||
|
||||
// The START_TIME field is kept but not used.
|
||||
// All the accesses to it have been replaced with Holder_io_netty_util_concurrent_ScheduledFutureTask
|
||||
|
||||
@Substitute
|
||||
static long initialNanoTime() {
|
||||
return Holder_io_netty_util_concurrent_ScheduledFutureTask.START_TIME;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
static long defaultCurrentTimeNanos() {
|
||||
return System.nanoTime() - Holder_io_netty_util_concurrent_ScheduledFutureTask.START_TIME;
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.channel.ChannelHandlerMask")
|
||||
final class Target_io_netty_channel_ChannelHandlerMask {
|
||||
|
||||
// Netty tries to self-optimized itself, but it requires lots of reflection. We disable this behavior and avoid
|
||||
// misleading DEBUG messages in the log.
|
||||
@Substitute
|
||||
private static boolean isSkippable(final Class<?> handlerType, final String methodName, final Class... paramTypes) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.util.internal.NativeLibraryLoader")
|
||||
final class Target_io_netty_util_internal_NativeLibraryLoader {
|
||||
|
||||
// This method can trick GraalVM into thinking that Classloader#defineClass is getting called
|
||||
@Substitute
|
||||
static Class<?> tryToLoadClass(final ClassLoader loader, final Class<?> helper)
|
||||
throws ClassNotFoundException {
|
||||
return Class.forName(helper.getName(), false, loader);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.buffer.EmptyByteBuf")
|
||||
final class Target_io_netty_buffer_EmptyByteBuf {
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = RecomputeFieldValue.Kind.Reset)
|
||||
private static ByteBuffer EMPTY_BYTE_BUFFER;
|
||||
|
||||
@Alias
|
||||
@RecomputeFieldValue(kind = RecomputeFieldValue.Kind.Reset)
|
||||
private static long EMPTY_BYTE_BUFFER_ADDRESS;
|
||||
|
||||
@Substitute
|
||||
public ByteBuffer nioBuffer() {
|
||||
return EmptyByteBufStub.emptyByteBuffer();
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public ByteBuffer[] nioBuffers() {
|
||||
return new ByteBuffer[] { EmptyByteBufStub.emptyByteBuffer() };
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public ByteBuffer internalNioBuffer(int index, int length) {
|
||||
return EmptyByteBufStub.emptyByteBuffer();
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public boolean hasMemoryAddress() {
|
||||
return EmptyByteBufStub.emptyByteBufferAddress() != 0;
|
||||
}
|
||||
|
||||
@Substitute
|
||||
public long memoryAddress() {
|
||||
if (hasMemoryAddress()) {
|
||||
return EmptyByteBufStub.emptyByteBufferAddress();
|
||||
} else {
|
||||
throw new UnsupportedOperationException();
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.codec.http.HttpContentDecompressor")
|
||||
final class Target_io_netty_handler_codec_http_HttpContentDecompressor {
|
||||
|
||||
@Alias
|
||||
private boolean strict;
|
||||
|
||||
@Alias
|
||||
protected ChannelHandlerContext ctx;
|
||||
|
||||
@Substitute
|
||||
protected EmbeddedChannel newContentDecoder(String contentEncoding) throws Exception {
|
||||
if (GZIP.contentEqualsIgnoreCase(contentEncoding) ||
|
||||
X_GZIP.contentEqualsIgnoreCase(contentEncoding)) {
|
||||
return new EmbeddedChannel(ctx.channel().id(), ctx.channel().metadata().hasDisconnect(),
|
||||
ctx.channel().config(), ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP));
|
||||
}
|
||||
if (DEFLATE.contentEqualsIgnoreCase(contentEncoding) ||
|
||||
X_DEFLATE.contentEqualsIgnoreCase(contentEncoding)) {
|
||||
final ZlibWrapper wrapper = strict ? ZlibWrapper.ZLIB : ZlibWrapper.ZLIB_OR_NONE;
|
||||
// To be strict, 'deflate' means ZLIB, but some servers were not implemented correctly.
|
||||
return new EmbeddedChannel(ctx.channel().id(), ctx.channel().metadata().hasDisconnect(),
|
||||
ctx.channel().config(), ZlibCodecFactory.newZlibDecoder(wrapper));
|
||||
}
|
||||
|
||||
// 'identity' or unsupported
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.codec.http2.DelegatingDecompressorFrameListener")
|
||||
final class Target_io_netty_handler_codec_http2_DelegatingDecompressorFrameListener {
|
||||
|
||||
@Alias
|
||||
boolean strict;
|
||||
|
||||
@Substitute
|
||||
protected EmbeddedChannel newContentDecompressor(ChannelHandlerContext ctx, CharSequence contentEncoding)
|
||||
throws Http2Exception {
|
||||
if (!HttpHeaderValues.GZIP.contentEqualsIgnoreCase(contentEncoding)
|
||||
&& !HttpHeaderValues.X_GZIP.contentEqualsIgnoreCase(contentEncoding)) {
|
||||
if (!HttpHeaderValues.DEFLATE.contentEqualsIgnoreCase(contentEncoding)
|
||||
&& !HttpHeaderValues.X_DEFLATE.contentEqualsIgnoreCase(contentEncoding)) {
|
||||
return null;
|
||||
} else {
|
||||
ZlibWrapper wrapper = this.strict ? ZlibWrapper.ZLIB : ZlibWrapper.ZLIB_OR_NONE;
|
||||
return new EmbeddedChannel(ctx.channel().id(), ctx.channel().metadata().hasDisconnect(),
|
||||
ctx.channel().config(),
|
||||
new ChannelHandler[] { ZlibCodecFactory.newZlibDecoder(wrapper) });
|
||||
}
|
||||
} else {
|
||||
return new EmbeddedChannel(ctx.channel().id(), ctx.channel().metadata().hasDisconnect(), ctx.channel().config(),
|
||||
new ChannelHandler[] { ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP) });
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.SslHandler")
|
||||
final class Target_SslHandler {
|
||||
|
||||
@Substitute
|
||||
private void setOpensslEngineSocketFd(Channel c) {
|
||||
// do nothing.
|
||||
}
|
||||
}
|
||||
|
||||
@TargetClass(className = "io.netty.handler.ssl.PemReader")
|
||||
final class Alias_PemReader {
|
||||
|
||||
@Alias
|
||||
public static ByteBuf readPrivateKey(File keyFile) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Alias
|
||||
public static ByteBuf readPrivateKey(InputStream in) throws KeyException {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* If BouncyCastle is not on the classpath, we must not try to read the PEM file using the BouncyCatle PEM reader.
|
||||
*/
|
||||
@TargetClass(className = "io.netty.handler.ssl.SslContext", onlyWith = IsBouncyNotThere.class)
|
||||
final class Target_SslContext {
|
||||
|
||||
@Substitute
|
||||
protected static PrivateKey toPrivateKey(File keyFile, String keyPassword) throws NoSuchAlgorithmException,
|
||||
NoSuchPaddingException, InvalidKeySpecException,
|
||||
InvalidAlgorithmParameterException,
|
||||
KeyException, IOException {
|
||||
if (keyFile == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return getPrivateKeyFromByteBuffer(Alias_PemReader.readPrivateKey(keyFile), keyPassword);
|
||||
}
|
||||
|
||||
@Substitute
|
||||
protected static PrivateKey toPrivateKey(InputStream keyInputStream, String keyPassword)
|
||||
throws NoSuchAlgorithmException,
|
||||
NoSuchPaddingException, InvalidKeySpecException,
|
||||
InvalidAlgorithmParameterException,
|
||||
KeyException, IOException {
|
||||
if (keyInputStream == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return getPrivateKeyFromByteBuffer(Alias_PemReader.readPrivateKey(keyInputStream), keyPassword);
|
||||
}
|
||||
|
||||
@Alias
|
||||
private static PrivateKey getPrivateKeyFromByteBuffer(ByteBuf encodedKeyBuf, String keyPassword)
|
||||
throws NoSuchAlgorithmException, NoSuchPaddingException, InvalidKeySpecException,
|
||||
InvalidAlgorithmParameterException, KeyException, IOException {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
class IsBouncyNotThere implements BooleanSupplier {
|
||||
|
||||
@Override
|
||||
public boolean getAsBoolean() {
|
||||
try {
|
||||
NettySubstitutions.class.getClassLoader().loadClass("org.bouncycastle.openssl.PEMParser");
|
||||
return false;
|
||||
} catch (Exception e) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
class NettySubstitutions {
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user