public class io.quarkus.vertx.core.runtime.VertxCoreRecorder extends java.lang.Object
{
private static final org.jboss.logging.Logger LOGGER;
public static final java.lang.String VERTX_CACHE;
static volatile io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx;
static volatile int blockingThreadPoolSize;
private static volatile java.lang.String webDeploymentId;
private static final java.util.Set devModeThreads;
private static volatile java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader;
public void <init>()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public java.util.function.Supplier configureVertx(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.quarkus.runtime.LaunchMode, io.quarkus.runtime.ShutdownContext, java.util.List, java.util.concurrent.ExecutorService)
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier v, v, v, v, v;
io.vertx.core.Vertx v;
io.quarkus.runtime.LaunchMode v, v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
java.util.List v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$1 v;
io.quarkus.runtime.ShutdownContext v;
java.util.concurrent.ExecutorService v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$2 v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.quarkus.runtime.LaunchMode;
v := @parameter: io.quarkus.runtime.ShutdownContext;
v := @parameter: java.util.List;
v := @parameter: java.util.concurrent.ExecutorService;
<io.quarkus.vertx.core.runtime.QuarkusExecutorFactory: java.util.concurrent.ExecutorService sharedExecutor> = v;
v = <io.quarkus.runtime.LaunchMode: io.quarkus.runtime.LaunchMode DEVELOPMENT>;
if v == v goto label;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: void <init>(io.quarkus.runtime.LaunchMode,io.quarkus.vertx.core.runtime.config.VertxConfiguration,java.util.List,io.quarkus.runtime.ShutdownContext)>(v, v, v, v);
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx> = v;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$1;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$1: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
interfaceinvoke v.<io.quarkus.runtime.ShutdownContext: void addLastShutdownTask(java.lang.Runnable)>(v);
goto label;
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
if v != null goto label;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: void <init>(io.quarkus.runtime.LaunchMode,io.quarkus.vertx.core.runtime.config.VertxConfiguration,java.util.List,io.quarkus.runtime.ShutdownContext)>(v, v, v, v);
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx> = v;
goto label;
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
v = v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: io.vertx.core.Vertx v>;
if v == null goto label;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder: void tryCleanTccl()>();
label:
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$2;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$2: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
interfaceinvoke v.<io.quarkus.runtime.ShutdownContext: void addLastShutdownTask(java.lang.Runnable)>(v);
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
return v;
}
private void tryCleanTccl()
{
java.lang.Throwable v;
java.util.Iterator v;
java.util.Set v, v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
java.lang.Thread v;
java.lang.Object v;
java.lang.ClassLoader v;
boolean v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ClassLoader getContextClassLoader()>();
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
entermonitor v;
label:
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader> = v;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<java.lang.Thread: void setContextClassLoader(java.lang.ClassLoader)>(v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public io.quarkus.runtime.IOThreadDetector detector()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$3 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$3;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$3: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
return v;
}
static void shutdownDevMode()
{
java.lang.Throwable v, v, v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier v, v;
io.vertx.core.Vertx v;
java.util.Set v, v, v, v;
java.lang.RuntimeException v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$4 v;
java.util.concurrent.CountDownLatch v;
java.lang.InterruptedException v;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
if v == null goto label;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
v = virtualinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: io.vertx.core.Vertx get()>();
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$4;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$4: void <init>(java.util.concurrent.CountDownLatch)>(v);
interfaceinvoke v.<io.vertx.core.Vertx: void close(io.vertx.core.Handler)>(v);
label:
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
entermonitor v;
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
interfaceinvoke v.<java.util.Set: void clear()>();
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader> = null;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
entermonitor v;
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
interfaceinvoke v.<java.util.Set: void clear()>();
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader> = null;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public static java.util.function.Supplier getVertx()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier v;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
return v;
}
public static io.vertx.core.Vertx initialize(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxOptionsCustomizer, io.quarkus.runtime.ShutdownContext, io.quarkus.runtime.LaunchMode)
{
io.quarkus.vertx.core.runtime.VertxMDC v;
io.quarkus.runtime.LaunchMode v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxOptionsCustomizer v;
java.util.concurrent.CompletableFuture v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$5 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$7 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$6 v;
io.quarkus.runtime.ShutdownContext v;
boolean v;
io.vertx.core.Vertx v;
io.vertx.core.VertxOptions v;
io.vertx.core.impl.VertxBuilder v, v, v, v, v, v, v, v;
java.util.Optional v;
java.lang.Object v;
io.quarkus.vertx.core.runtime.QuarkusExecutorFactory v, v;
io.quarkus.vertx.core.runtime.config.ClusterConfiguration v, v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxOptionsCustomizer;
v := @parameter: io.quarkus.runtime.ShutdownContext;
v := @parameter: io.quarkus.runtime.LaunchMode;
v = new io.vertx.core.VertxOptions;
specialinvoke v.<io.vertx.core.VertxOptions: void <init>()>();
if v == null goto label;
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.vertx.core.VertxOptions convertToVertxOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.vertx.core.VertxOptions,boolean,io.quarkus.runtime.ShutdownContext)>(v, v, 1, v);
label:
if v == null goto label;
virtualinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxOptionsCustomizer: io.vertx.core.VertxOptions customize(io.vertx.core.VertxOptions)>(v);
label:
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Optional setupThreadFactoryTccl(io.quarkus.runtime.LaunchMode)>(v);
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$5;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$5: void <init>(io.quarkus.runtime.LaunchMode,java.util.Optional)>(v, v);
if v == null goto label;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: io.quarkus.vertx.core.runtime.config.ClusterConfiguration cluster>;
if v == null goto label;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: io.quarkus.vertx.core.runtime.config.ClusterConfiguration cluster>;
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: boolean clustered>;
if v == 0 goto label;
v = new java.util.concurrent.CompletableFuture;
specialinvoke v.<java.util.concurrent.CompletableFuture: void <init>()>();
v = new io.vertx.core.impl.VertxBuilder;
specialinvoke v.<io.vertx.core.impl.VertxBuilder: void <init>(io.vertx.core.VertxOptions)>(v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder threadFactory(io.vertx.core.spi.VertxThreadFactory)>(v);
v = new io.quarkus.vertx.core.runtime.QuarkusExecutorFactory;
specialinvoke v.<io.quarkus.vertx.core.runtime.QuarkusExecutorFactory: void <init>(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.quarkus.runtime.LaunchMode)>(v, v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder executorServiceFactory(io.vertx.core.spi.ExecutorServiceFactory)>(v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder init()>();
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$6;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$6: void <init>(java.util.concurrent.CompletableFuture)>(v);
virtualinvoke v.<io.vertx.core.impl.VertxBuilder: void clusteredVertx(io.vertx.core.Handler)>(v);
v = virtualinvoke v.<java.util.concurrent.CompletableFuture: java.lang.Object join()>();
goto label;
label:
v = new io.vertx.core.impl.VertxBuilder;
specialinvoke v.<io.vertx.core.impl.VertxBuilder: void <init>(io.vertx.core.VertxOptions)>(v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder threadFactory(io.vertx.core.spi.VertxThreadFactory)>(v);
v = new io.quarkus.vertx.core.runtime.QuarkusExecutorFactory;
specialinvoke v.<io.quarkus.vertx.core.runtime.QuarkusExecutorFactory: void <init>(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.quarkus.runtime.LaunchMode)>(v, v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder executorServiceFactory(io.vertx.core.spi.ExecutorServiceFactory)>(v);
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.impl.VertxBuilder init()>();
v = virtualinvoke v.<io.vertx.core.impl.VertxBuilder: io.vertx.core.Vertx vertx()>();
label:
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$7;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$7: void <init>()>();
interfaceinvoke v.<io.vertx.core.Vertx: io.vertx.core.Vertx exceptionHandler(io.vertx.core.Handler)>(v);
v = <io.quarkus.vertx.core.runtime.VertxMDC: io.quarkus.vertx.core.runtime.VertxMDC INSTANCE>;
staticinvoke <io.quarkus.vertx.mdc.provider.LateBoundMDCProvider: void setMDCProviderDelegate(org.jboss.logmanager.MDCProvider)>(v);
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.vertx.core.Vertx logVertxInitialization(io.vertx.core.Vertx)>(v);
return v;
}
private static java.util.Optional setupThreadFactoryTccl(io.quarkus.runtime.LaunchMode)
{
java.lang.Thread v, v;
io.quarkus.runtime.LaunchMode v, v;
java.util.Optional v;
java.lang.ClassLoader v, v;
v := @parameter: io.quarkus.runtime.LaunchMode;
v = <io.quarkus.runtime.LaunchMode: io.quarkus.runtime.LaunchMode DEVELOPMENT>;
if v != v goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ClassLoader getContextClassLoader()>();
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader> = v;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
goto label;
label:
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ClassLoader getContextClassLoader()>();
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
label:
return v;
}
private static io.vertx.core.impl.VertxThread createVertxThread(java.lang.Runnable, java.lang.String, boolean, long, java.util.concurrent.TimeUnit, io.quarkus.runtime.LaunchMode, java.util.Optional)
{
java.lang.Throwable v;
io.vertx.core.impl.VertxThread v;
io.vertx.core.spi.VertxThreadFactory v;
io.quarkus.runtime.LaunchMode v, v;
java.util.Set v, v;
long v;
java.lang.Runnable v;
java.util.concurrent.TimeUnit v;
java.util.Optional v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: io.quarkus.runtime.LaunchMode;
v := @parameter: java.util.Optional;
v = <io.vertx.core.spi.VertxThreadFactory: io.vertx.core.spi.VertxThreadFactory INSTANCE>;
v = interfaceinvoke v.<io.vertx.core.spi.VertxThreadFactory: io.vertx.core.impl.VertxThread newVertxThread(java.lang.Runnable,java.lang.String,boolean,long,java.util.concurrent.TimeUnit)>(v, v, v, v, v);
v = <io.quarkus.runtime.LaunchMode: io.quarkus.runtime.LaunchMode DEVELOPMENT>;
if v != v goto label;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
entermonitor v;
label:
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: void setNewThreadTccl(io.vertx.core.impl.VertxThread)>(v);
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
virtualinvoke v.<io.vertx.core.impl.VertxThread: void setContextClassLoader(java.lang.ClassLoader)>(v);
label:
return v;
catch java.lang.Throwable from label to label with label;
}
private static io.vertx.core.Vertx logVertxInitialization(io.vertx.core.Vertx)
{
org.jboss.logging.Logger v;
io.vertx.core.Vertx v;
java.lang.Boolean v;
boolean v;
v := @parameter: io.vertx.core.Vertx;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: org.jboss.logging.Logger LOGGER>;
v = interfaceinvoke v.<io.vertx.core.Vertx: boolean isNativeTransportEnabled()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.jboss.logging.Logger: void debugf(java.lang.String,java.lang.Object)>("Vertx has Native Transport Enabled: %s", v);
return v;
}
private static io.vertx.core.VertxOptions convertToVertxOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.vertx.core.VertxOptions, boolean, io.quarkus.runtime.ShutdownContext)
{
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
java.util.Locale v;
java.time.Duration v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
io.vertx.core.VertxOptions v;
org.jboss.logging.Logger v, v, v;
long v, v, v, v;
java.util.OptionalInt v, v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$8 v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
io.quarkus.runtime.ShutdownContext v;
io.vertx.core.file.FileSystemOptions v, v, v;
java.io.File v, v;
java.util.concurrent.TimeUnit v, v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.vertx.core.VertxOptions;
v := @parameter: boolean;
v := @parameter: io.quarkus.runtime.ShutdownContext;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean useAsyncDNS>;
if v != 0 goto label;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("vertx.disableDnsResolver", "true");
label:
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: void setAddressResolverOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.vertx.core.VertxOptions)>(v, v);
if v == 0 goto label;
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: void setEventBusOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.vertx.core.VertxOptions)>(v, v);
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: void initializeClusterOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration,io.vertx.core.VertxOptions)>(v, v);
label:
v = new io.vertx.core.file.FileSystemOptions;
specialinvoke v.<io.vertx.core.file.FileSystemOptions: void <init>()>();
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean caching>;
v = virtualinvoke v.<io.vertx.core.file.FileSystemOptions: io.vertx.core.file.FileSystemOptions setFileCachingEnabled(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean classpathResolving>;
v = virtualinvoke v.<io.vertx.core.file.FileSystemOptions: io.vertx.core.file.FileSystemOptions setClassPathResolvingEnabled(boolean)>(v);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("vertx.cacheDirBase");
if v != null goto label;
v = new java.io.File;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("java.io.tmpdir", ".");
v = <java.io.File: java.lang.String separator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001vertx-cache");
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean caching>;
if v != 0 goto label;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean classpathResolving>;
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v != 0 goto label;
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean mkdirs()>();
if v != 0 goto label;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: org.jboss.logging.Logger LOGGER>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
virtualinvoke v.<org.jboss.logging.Logger: void warnf(java.lang.String,java.lang.Object)>("Unable to create Vert.x cache directory : %s", v);
label:
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("os.name");
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("windows");
if v != 0 goto label;
v = virtualinvoke v.<java.io.File: boolean setReadable(boolean,boolean)>(1, 0);
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean setWritable(boolean,boolean)>(1, 0);
if v != 0 goto label;
label:
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: org.jboss.logging.Logger LOGGER>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
virtualinvoke v.<org.jboss.logging.Logger: void warnf(java.lang.String,java.lang.Object)>("Unable to make the Vert.x cache directory (%s) world readable and writable", v);
label:
if v == 0 goto label;
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.io.File getRandomDirectory(java.io.File)>(v);
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: org.jboss.logging.Logger LOGGER>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
virtualinvoke v.<org.jboss.logging.Logger: void debugf(java.lang.String,java.lang.Object)>("Vert.x Cache configured to: %s", v);
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
virtualinvoke v.<io.vertx.core.file.FileSystemOptions: io.vertx.core.file.FileSystemOptions setFileCacheDir(java.lang.String)>(v);
if v == null goto label;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$8;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$8: void <init>(java.io.File)>(v);
interfaceinvoke v.<io.quarkus.runtime.ShutdownContext: void addLastShutdownTask(java.lang.Runnable)>(v);
label:
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setFileSystemOptions(io.vertx.core.file.FileSystemOptions)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: int workerPoolSize>;
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setWorkerPoolSize(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: int internalBlockingPoolSize>;
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setInternalBlockingPoolSize(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: int internalBlockingPoolSize>;
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: int blockingThreadPoolSize> = v;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.time.Duration warningExceptionTime>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setBlockedThreadCheckInterval(long)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.util.OptionalInt eventLoopsPoolSize>;
v = virtualinvoke v.<java.util.OptionalInt: boolean isPresent()>();
if v == 0 goto label;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.util.OptionalInt eventLoopsPoolSize>;
v = virtualinvoke v.<java.util.OptionalInt: int getAsInt()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setEventLoopPoolSize(int)>(v);
goto label;
label:
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: int calculateDefaultIOThreads()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setEventLoopPoolSize(int)>(v);
label:
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.time.Duration maxEventLoopExecuteTime>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setMaxEventLoopExecuteTime(long)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setMaxEventLoopExecuteTimeUnit(java.util.concurrent.TimeUnit)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.time.Duration maxWorkerExecuteTime>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setMaxWorkerExecuteTime(long)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setMaxWorkerExecuteTimeUnit(java.util.concurrent.TimeUnit)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.time.Duration warningExceptionTime>;
v = virtualinvoke v.<java.time.Duration: long toNanos()>();
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setWarningExceptionTime(long)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: boolean preferNativeTransport>;
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setPreferNativeTransport(boolean)>(v);
return v;
}
private static java.io.File getRandomDirectory(java.io.File)
{
long v, v;
java.util.UUID v;
java.io.File v, v, v;
java.lang.String v;
boolean v;
v := @parameter: java.io.File;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: long getMostSignificantBits()>();
v = staticinvoke <java.lang.Math: long abs(long)>(v);
v = new java.io.File;
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v == 0 goto label;
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.io.File getRandomDirectory(java.io.File)>(v);
return v;
label:
return v;
}
private static int calculateDefaultIOThreads()
{
java.lang.Runtime v;
int v;
long v, v, v, v, v;
v = staticinvoke <org.wildfly.common.cpu.ProcessorInfo: int availableProcessors()>();
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = virtualinvoke v.<java.lang.Runtime: long maxMemory()>();
v = v / 1048576L;
v = v / 10L;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = staticinvoke <java.lang.Math: long max(long,long)>(2L, v);
return v;
}
void destroy()
{
java.lang.IllegalStateException v, v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier v, v, v;
io.vertx.core.Vertx v, v;
java.util.concurrent.atomic.AtomicReference v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
java.util.concurrent.CountDownLatch v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$9 v;
java.lang.InterruptedException v;
java.lang.Thread v;
java.lang.Object v, v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
if v == null goto label;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
v = v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: io.vertx.core.Vertx v>;
if v == null goto label;
staticinvoke <io.netty.util.concurrent.FastThreadLocal: void destroy()>();
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx>;
v = v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: io.vertx.core.Vertx v>;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$9;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$9: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder,java.util.concurrent.atomic.AtomicReference,java.util.concurrent.CountDownLatch)>(v, v, v);
interfaceinvoke v.<io.vertx.core.Vertx: void close(io.vertx.core.Handler)>(v);
label:
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Error when closing Vert.x instance", v);
throw v;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Exception when closing Vert.x instance", v);
throw v;
label:
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx> = null;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
private static void initializeClusterOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.vertx.core.VertxOptions)
{
long v, v;
java.util.OptionalInt v, v, v, v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
java.time.Duration v, v;
int v, v;
io.vertx.core.eventbus.EventBusOptions v, v, v, v, v, v;
java.lang.String v, v;
boolean v, v, v;
io.vertx.core.VertxOptions v;
java.util.Optional v, v;
java.lang.Object v;
io.quarkus.vertx.core.runtime.config.ClusterConfiguration v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.vertx.core.VertxOptions;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: io.quarkus.vertx.core.runtime.config.ClusterConfiguration cluster>;
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.time.Duration pingReplyInterval>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setClusterPingReplyInterval(long)>(v);
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.time.Duration pingInterval>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setClusterPingInterval(long)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.lang.String host>;
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.lang.String host>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setHost(java.lang.String)>(v);
label:
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.OptionalInt port>;
v = virtualinvoke v.<java.util.OptionalInt: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.OptionalInt port>;
v = virtualinvoke v.<java.util.OptionalInt: int getAsInt()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setPort(int)>(v);
label:
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.Optional publicHost>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.Optional publicHost>;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setClusterPublicHost(java.lang.String)>(v);
label:
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.OptionalInt publicPort>;
v = virtualinvoke v.<java.util.OptionalInt: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.eventbus.EventBusOptions getEventBusOptions()>();
v = v.<io.quarkus.vertx.core.runtime.config.ClusterConfiguration: java.util.OptionalInt publicPort>;
v = virtualinvoke v.<java.util.OptionalInt: int getAsInt()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setPort(int)>(v);
label:
return;
}
private static void setEventBusOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.vertx.core.VertxOptions)
{
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
java.time.Duration v, v;
boolean v, v, v, v, v, v, v;
io.vertx.core.VertxOptions v;
io.quarkus.vertx.core.runtime.config.PfxConfiguration v, v;
io.quarkus.vertx.core.runtime.config.PemKeyCertConfiguration v;
java.util.Optional v, v;
io.quarkus.vertx.core.runtime.config.PemTrustCertConfiguration v;
long v, v, v, v, v, v;
io.quarkus.vertx.core.runtime.config.JksConfiguration v, v;
java.util.OptionalInt v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v;
io.vertx.core.eventbus.EventBusOptions v;
java.lang.String v, v;
io.quarkus.vertx.core.runtime.config.EventBusConfiguration v;
io.vertx.core.http.ClientAuth v;
java.lang.Object v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.vertx.core.VertxOptions;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: io.quarkus.vertx.core.runtime.config.EventBusConfiguration eventbus>;
v = new io.vertx.core.eventbus.EventBusOptions;
specialinvoke v.<io.vertx.core.eventbus.EventBusOptions: void <init>()>();
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.OptionalInt acceptBacklog>;
v = (int) -1;
v = virtualinvoke v.<java.util.OptionalInt: int orElse(int)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setAcceptBacklog(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.lang.String clientAuth>;
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = staticinvoke <io.vertx.core.http.ClientAuth: io.vertx.core.http.ClientAuth valueOf(java.lang.String)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setClientAuth(io.vertx.core.http.ClientAuth)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.time.Duration connectTimeout>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(2147483647L, v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setConnectTimeout(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.Optional idleTimeout>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.Optional idleTimeout>;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.time.Duration: long getSeconds()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(2147483647L, v);
v = staticinvoke <java.lang.Math: long max(long,long)>(1L, v);
goto label;
label:
v = 0;
label:
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setIdleTimeout(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.OptionalInt sendBufferSize>;
v = (int) -1;
v = virtualinvoke v.<java.util.OptionalInt: int orElse(int)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setSendBufferSize(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.OptionalInt soLinger>;
v = (int) -1;
v = virtualinvoke v.<java.util.OptionalInt: int orElse(int)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setSoLinger(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean ssl>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setSsl(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.OptionalInt receiveBufferSize>;
v = (int) -1;
v = virtualinvoke v.<java.util.OptionalInt: int orElse(int)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setReceiveBufferSize(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: int reconnectAttempts>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setReconnectAttempts(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.time.Duration reconnectInterval>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setReconnectInterval(long)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean reuseAddress>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setReuseAddress(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean reusePort>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setReusePort(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: java.util.OptionalInt trafficClass>;
v = (int) -1;
v = virtualinvoke v.<java.util.OptionalInt: int orElse(int)>(v);
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setTrafficClass(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean tcpKeepAlive>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setTcpKeepAlive(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean tcpNoDelay>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setTcpNoDelay(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: boolean trustAll>;
virtualinvoke v.<io.vertx.core.eventbus.EventBusOptions: io.vertx.core.eventbus.EventBusOptions setTrustAll(boolean)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.PemKeyCertConfiguration keyCertificatePem>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configurePemKeyCertOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.PemKeyCertConfiguration)>(v, v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.JksConfiguration keyCertificateJks>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configureJksKeyCertOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.JksConfiguration)>(v, v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.PfxConfiguration keyCertificatePfx>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configurePfxKeyCertOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.PfxConfiguration)>(v, v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.PemTrustCertConfiguration trustCertificatePem>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configurePemTrustOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.PemTrustCertConfiguration)>(v, v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.JksConfiguration trustCertificateJks>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configureJksKeyCertOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.JksConfiguration)>(v, v);
v = v.<io.quarkus.vertx.core.runtime.config.EventBusConfiguration: io.quarkus.vertx.core.runtime.config.PfxConfiguration trustCertificatePfx>;
staticinvoke <io.quarkus.vertx.core.runtime.SSLConfigHelper: void configurePfxTrustOptions(io.vertx.core.net.TCPSSLOptions,io.quarkus.vertx.core.runtime.config.PfxConfiguration)>(v, v);
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setEventBusOptions(io.vertx.core.eventbus.EventBusOptions)>(v);
return;
}
private static void setAddressResolverOptions(io.quarkus.vertx.core.runtime.config.VertxConfiguration, io.vertx.core.VertxOptions)
{
io.vertx.core.VertxOptions v;
long v;
io.vertx.core.dns.AddressResolverOptions v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration v;
java.time.Duration v;
int v, v, v, v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v := @parameter: io.vertx.core.VertxOptions;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration resolver>;
v = new io.vertx.core.dns.AddressResolverOptions;
specialinvoke v.<io.vertx.core.dns.AddressResolverOptions: void <init>()>();
v = v.<io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration: int cacheMaxTimeToLive>;
virtualinvoke v.<io.vertx.core.dns.AddressResolverOptions: io.vertx.core.dns.AddressResolverOptions setCacheMaxTimeToLive(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration: int cacheMinTimeToLive>;
virtualinvoke v.<io.vertx.core.dns.AddressResolverOptions: io.vertx.core.dns.AddressResolverOptions setCacheMinTimeToLive(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration: int cacheNegativeTimeToLive>;
virtualinvoke v.<io.vertx.core.dns.AddressResolverOptions: io.vertx.core.dns.AddressResolverOptions setCacheNegativeTimeToLive(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration: int maxQueries>;
virtualinvoke v.<io.vertx.core.dns.AddressResolverOptions: io.vertx.core.dns.AddressResolverOptions setMaxQueries(int)>(v);
v = v.<io.quarkus.vertx.core.runtime.config.AddressResolverConfiguration: java.time.Duration queryTimeout>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
virtualinvoke v.<io.vertx.core.dns.AddressResolverOptions: io.vertx.core.dns.AddressResolverOptions setQueryTimeout(long)>(v);
virtualinvoke v.<io.vertx.core.VertxOptions: io.vertx.core.VertxOptions setAddressResolverOptions(io.vertx.core.dns.AddressResolverOptions)>(v);
return;
}
public java.util.function.Supplier bossSupplier()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$10 v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$10;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$10: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
return v;
}
public java.util.function.Supplier mainSupplier()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$11 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$11;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$11: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
return v;
}
public java.util.function.Supplier calculateEventLoopThreads(io.quarkus.vertx.core.runtime.config.VertxConfiguration)
{
int v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$12 v;
java.util.OptionalInt v, v;
boolean v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.util.OptionalInt eventLoopsPoolSize>;
v = virtualinvoke v.<java.util.OptionalInt: boolean isPresent()>();
if v == 0 goto label;
v = v.<io.quarkus.vertx.core.runtime.config.VertxConfiguration: java.util.OptionalInt eventLoopsPoolSize>;
v = virtualinvoke v.<java.util.OptionalInt: int getAsInt()>();
goto label;
label:
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: int calculateDefaultIOThreads()>();
label:
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$12;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$12: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder,int)>(v, v);
return v;
}
public java.util.concurrent.ThreadFactory createThreadFactory(io.quarkus.runtime.LaunchMode)
{
java.util.concurrent.atomic.AtomicInteger v;
io.quarkus.runtime.LaunchMode v;
java.util.Optional v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder$13 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v := @parameter: io.quarkus.runtime.LaunchMode;
v = staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Optional setupThreadFactoryTccl(io.quarkus.runtime.LaunchMode)>(v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$13;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$13: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder,java.util.concurrent.atomic.AtomicInteger,io.quarkus.runtime.LaunchMode,java.util.Optional)>(v, v, v, v);
return v;
}
private static void setNewThreadTccl(io.vertx.core.impl.VertxThread)
{
io.vertx.core.impl.VertxThread v;
java.lang.Class v;
java.lang.ClassLoader v;
v := @parameter: io.vertx.core.impl.VertxThread;
v = <io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.ClassLoader currentDevModeNewThreadCreationClassLoader>;
if v != null goto label;
v = class "Lio/quarkus/vertx/core/runtime/VertxCoreRecorder;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
label:
virtualinvoke v.<io.vertx.core.impl.VertxThread: void setContextClassLoader(java.lang.ClassLoader)>(v);
return;
}
public org.jboss.threads.ContextHandler executionContextHandler()
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$14 v;
io.quarkus.vertx.core.runtime.VertxCoreRecorder v;
v := @this: io.quarkus.vertx.core.runtime.VertxCoreRecorder;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$14;
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$14: void <init>(io.quarkus.vertx.core.runtime.VertxCoreRecorder)>(v);
return v;
}
public static java.util.function.Supplier recoverFailedStart(io.quarkus.vertx.core.runtime.config.VertxConfiguration)
{
io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier v;
java.util.List v;
io.quarkus.runtime.LaunchMode v;
io.quarkus.vertx.core.runtime.config.VertxConfiguration v;
v := @parameter: io.quarkus.vertx.core.runtime.config.VertxConfiguration;
v = new io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier;
v = <io.quarkus.runtime.LaunchMode: io.quarkus.runtime.LaunchMode DEVELOPMENT>;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier: void <init>(io.quarkus.runtime.LaunchMode,io.quarkus.vertx.core.runtime.config.VertxConfiguration,java.util.List,io.quarkus.runtime.ShutdownContext)>(v, v, v, null);
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: io.quarkus.vertx.core.runtime.VertxCoreRecorder$VertxSupplier vertx> = v;
return v;
}
public static void setWebDeploymentId(java.lang.String)
{
java.lang.String v;
v := @parameter: java.lang.String;
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.lang.String webDeploymentId> = v;
return;
}
private static void deleteDirectory(java.io.File)
{
int v, v;
java.io.File[] v;
java.io.File v, v;
v := @parameter: java.io.File;
v = virtualinvoke v.<java.io.File: java.io.File[] listFiles()>();
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
staticinvoke <io.quarkus.vertx.core.runtime.VertxCoreRecorder: void deleteDirectory(java.io.File)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.io.File: boolean delete()>();
return;
}
static void <clinit>()
{
java.util.HashSet v;
org.jboss.logging.Logger v;
java.lang.Class v;
java.lang.String v;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("vertx.disableTCCL", "true");
v = class "Lio/quarkus/vertx/core/runtime/VertxCoreRecorder;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = staticinvoke <org.jboss.logging.Logger: org.jboss.logging.Logger getLogger(java.lang.String)>(v);
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: org.jboss.logging.Logger LOGGER> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
<io.quarkus.vertx.core.runtime.VertxCoreRecorder: java.util.Set devModeThreads> = v;
return;
}
}