public class io.vertx.core.impl.VertxImpl implements io.vertx.core.impl.VertxInternal, io.vertx.core.spi.metrics.MetricsProvider
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.impl.VertxImpl
super_class: java.lang.Object
{
private static final io.vertx.core.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.String CLUSTER_MAP_NAME;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "__vertx.haInfo"
private static final java.lang.String NETTY_IO_RATIO_PROPERTY_NAME;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "vertx.nettyIORatio"
private static final int NETTY_IO_RATIO;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.file.FileSystem fileSystem;
descriptor: Lio/vertx/core/file/FileSystem;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.shareddata.SharedData sharedData;
descriptor: Lio/vertx/core/shareddata/SharedData;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.metrics.VertxMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/VertxMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.ConcurrentMap<java.lang.Long, io.vertx.core.impl.VertxImpl$InternalTimerHandler> timeouts;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/Long;Lio/vertx/core/impl/VertxImpl$InternalTimerHandler;>;
private final java.util.concurrent.atomic.AtomicLong timeoutCounter;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.cluster.ClusterManager clusterManager;
descriptor: Lio/vertx/core/spi/cluster/ClusterManager;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.cluster.NodeSelector nodeSelector;
descriptor: Lio/vertx/core/spi/cluster/NodeSelector;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.DeploymentManager deploymentManager;
descriptor: Lio/vertx/core/impl/DeploymentManager;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.VerticleManager verticleManager;
descriptor: Lio/vertx/core/impl/VerticleManager;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.file.impl.FileResolver fileResolver;
descriptor: Lio/vertx/core/file/impl/FileResolver;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<io.vertx.core.net.impl.ServerID, io.vertx.core.http.impl.HttpServerImpl> sharedHttpServers;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lio/vertx/core/net/impl/ServerID;Lio/vertx/core/http/impl/HttpServerImpl;>;
private final java.util.Map<io.vertx.core.net.impl.ServerID, io.vertx.core.net.impl.NetServerImpl> sharedNetServers;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lio/vertx/core/net/impl/ServerID;Lio/vertx/core/net/impl/NetServerImpl;>;
final io.vertx.core.impl.WorkerPool workerPool;
descriptor: Lio/vertx/core/impl/WorkerPool;
flags: (0x0010) ACC_FINAL
final io.vertx.core.impl.WorkerPool internalBlockingPool;
descriptor: Lio/vertx/core/impl/WorkerPool;
flags: (0x0010) ACC_FINAL
private final java.util.concurrent.ThreadFactory eventLoopThreadFactory;
descriptor: Ljava/util/concurrent/ThreadFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.netty.channel.EventLoopGroup eventLoopGroup;
descriptor: Lio/netty/channel/EventLoopGroup;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.netty.channel.EventLoopGroup acceptorEventLoopGroup;
descriptor: Lio/netty/channel/EventLoopGroup;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.BlockedThreadChecker checker;
descriptor: Lio/vertx/core/impl/BlockedThreadChecker;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.AddressResolver addressResolver;
descriptor: Lio/vertx/core/impl/AddressResolver;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.dns.AddressResolverOptions addressResolverOptions;
descriptor: Lio/vertx/core/dns/AddressResolverOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.eventbus.impl.EventBusInternal eventBus;
descriptor: Lio/vertx/core/eventbus/impl/EventBusInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile io.vertx.core.impl.HAManager haManager;
descriptor: Lio/vertx/core/impl/HAManager;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private boolean closed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private volatile io.vertx.core.Handler<java.lang.Throwable> exceptionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
private final java.util.Map<java.lang.String, io.vertx.core.impl.VertxImpl$SharedWorkerPool> namedWorkerPools;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;>;
private final int defaultWorkerPoolSize;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final long maxWorkerExecTime;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.TimeUnit maxWorkerExecTimeUnit;
descriptor: Ljava/util/concurrent/TimeUnit;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final long maxEventLoopExecTime;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.TimeUnit maxEventLoopExecTimeUnit;
descriptor: Ljava/util/concurrent/TimeUnit;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.CloseHooks closeHooks;
descriptor: Lio/vertx/core/impl/CloseHooks;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.impl.transport.Transport transport;
descriptor: Lio/vertx/core/net/impl/transport/Transport;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.spi.tracing.VertxTracer tracer;
descriptor: Lio/vertx/core/spi/tracing/VertxTracer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.ThreadLocal<java.lang.ref.WeakReference<io.vertx.core.impl.AbstractContext>> stickyContext;
descriptor: Ljava/lang/ThreadLocal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/ThreadLocal<Ljava/lang/ref/WeakReference<Lio/vertx/core/impl/AbstractContext;>;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc Lio/vertx/core/impl/VertxImpl;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.core.impl.VertxImpl.log:Lio/vertx/core/impl/logging/Logger;
1: ldc "vertx.nettyIORatio"
bipush 50
invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
putstatic io.vertx.core.impl.VertxImpl.NETTY_IO_RATIO:I
2: ldc "io.netty.leakDetection.level"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
ifnonnull 4
3: ldc "io.netty.leakDetectionLevel"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
ifnull 5
4: StackMap locals:
StackMap stack:
getstatic io.netty.util.ResourceLeakDetector$Level.DISABLED:Lio/netty/util/ResourceLeakDetector$Level;
invokestatic io.netty.util.ResourceLeakDetector.setLevel:(Lio/netty/util/ResourceLeakDetector$Level;)V
5: StackMap locals:
StackMap stack:
ldc "io.netty.noJdkZlibDecoder"
ldc "false"
invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
pop
6: return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.VertxOptions, io.vertx.core.spi.cluster.ClusterManager, io.vertx.core.spi.cluster.NodeSelector, io.vertx.core.spi.metrics.VertxMetrics, io.vertx.core.spi.tracing.VertxTracer<?, ?>, io.vertx.core.net.impl.transport.Transport, io.vertx.core.file.impl.FileResolver);
descriptor: (Lio/vertx/core/VertxOptions;Lio/vertx/core/spi/cluster/ClusterManager;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/spi/metrics/VertxMetrics;Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/core/net/impl/transport/Transport;Lio/vertx/core/file/impl/FileResolver;)V
flags: (0x0000)
Code:
stack=16, locals=14, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getFileSystem:()Lio/vertx/core/file/FileSystem;
putfield io.vertx.core.impl.VertxImpl.fileSystem:Lio/vertx/core/file/FileSystem;
2: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.core.impl.VertxImpl.timeouts:Ljava/util/concurrent/ConcurrentMap;
3: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
lconst_0
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
putfield io.vertx.core.impl.VertxImpl.timeoutCounter:Ljava/util/concurrent/atomic/AtomicLong;
4: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.core.impl.VertxImpl.sharedHttpServers:Ljava/util/Map;
5: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.core.impl.VertxImpl.sharedNetServers:Ljava/util/Map;
6: aload 0
new java.lang.ThreadLocal
dup
invokespecial java.lang.ThreadLocal.<init>:()V
putfield io.vertx.core.impl.VertxImpl.stickyContext:Ljava/lang/ThreadLocal;
7: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
ifnull 9
8: getstatic io.vertx.core.impl.VertxImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "You're already on a Vert.x context, are you sure you want to create a new Vertx instance?"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
9: StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.VertxOptions io.vertx.core.spi.cluster.ClusterManager io.vertx.core.spi.cluster.NodeSelector io.vertx.core.spi.metrics.VertxMetrics io.vertx.core.spi.tracing.VertxTracer io.vertx.core.net.impl.transport.Transport io.vertx.core.file.impl.FileResolver
StackMap stack:
aload 0
new io.vertx.core.impl.CloseHooks
dup
getstatic io.vertx.core.impl.VertxImpl.log:Lio/vertx/core/impl/logging/Logger;
invokespecial io.vertx.core.impl.CloseHooks.<init>:(Lio/vertx/core/impl/logging/Logger;)V
putfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
10: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxEventLoopExecuteTime:()J
putfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTime:J
11: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxEventLoopExecuteTimeUnit:()Ljava/util/concurrent/TimeUnit;
putfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTimeUnit:Ljava/util/concurrent/TimeUnit;
12: aload 0
new io.vertx.core.impl.BlockedThreadChecker
dup
aload 1
invokevirtual io.vertx.core.VertxOptions.getBlockedThreadCheckInterval:()J
aload 1
invokevirtual io.vertx.core.VertxOptions.getBlockedThreadCheckIntervalUnit:()Ljava/util/concurrent/TimeUnit;
aload 1
invokevirtual io.vertx.core.VertxOptions.getWarningExceptionTime:()J
aload 1
invokevirtual io.vertx.core.VertxOptions.getWarningExceptionTimeUnit:()Ljava/util/concurrent/TimeUnit;
invokespecial io.vertx.core.impl.BlockedThreadChecker.<init>:(JLjava/util/concurrent/TimeUnit;JLjava/util/concurrent/TimeUnit;)V
putfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
13: aload 0
new io.vertx.core.impl.VertxThreadFactory
dup
ldc "vert.x-eventloop-thread-"
aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
iconst_0
aload 0
getfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTime:J
aload 0
getfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTimeUnit:Ljava/util/concurrent/TimeUnit;
invokespecial io.vertx.core.impl.VertxThreadFactory.<init>:(Ljava/lang/String;Lio/vertx/core/impl/BlockedThreadChecker;ZJLjava/util/concurrent/TimeUnit;)V
putfield io.vertx.core.impl.VertxImpl.eventLoopThreadFactory:Ljava/util/concurrent/ThreadFactory;
14: aload 0
aload 6
iconst_1
aload 1
invokevirtual io.vertx.core.VertxOptions.getEventLoopPoolSize:()I
aload 0
getfield io.vertx.core.impl.VertxImpl.eventLoopThreadFactory:Ljava/util/concurrent/ThreadFactory;
getstatic io.vertx.core.impl.VertxImpl.NETTY_IO_RATIO:I
invokevirtual io.vertx.core.net.impl.transport.Transport.eventLoopGroup:(IILjava/util/concurrent/ThreadFactory;I)Lio/netty/channel/EventLoopGroup;
putfield io.vertx.core.impl.VertxImpl.eventLoopGroup:Lio/netty/channel/EventLoopGroup;
15: new io.vertx.core.impl.VertxThreadFactory
dup
ldc "vert.x-acceptor-thread-"
aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
iconst_0
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxEventLoopExecuteTime:()J
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxEventLoopExecuteTimeUnit:()Ljava/util/concurrent/TimeUnit;
invokespecial io.vertx.core.impl.VertxThreadFactory.<init>:(Ljava/lang/String;Lio/vertx/core/impl/BlockedThreadChecker;ZJLjava/util/concurrent/TimeUnit;)V
astore 8
start local 8 16: aload 0
aload 6
iconst_0
iconst_1
aload 8
bipush 100
invokevirtual io.vertx.core.net.impl.transport.Transport.eventLoopGroup:(IILjava/util/concurrent/ThreadFactory;I)Lio/netty/channel/EventLoopGroup;
putfield io.vertx.core.impl.VertxImpl.acceptorEventLoopGroup:Lio/netty/channel/EventLoopGroup;
17: aload 1
invokevirtual io.vertx.core.VertxOptions.getWorkerPoolSize:()I
istore 9
start local 9 18: new java.util.concurrent.ThreadPoolExecutor
dup
iload 9
iload 9
19: lconst_0
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
new java.util.concurrent.LinkedTransferQueue
dup
invokespecial java.util.concurrent.LinkedTransferQueue.<init>:()V
20: new io.vertx.core.impl.VertxThreadFactory
dup
ldc "vert.x-worker-thread-"
aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
iconst_1
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTime:()J
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTimeUnit:()Ljava/util/concurrent/TimeUnit;
invokespecial io.vertx.core.impl.VertxThreadFactory.<init>:(Ljava/lang/String;Lio/vertx/core/impl/BlockedThreadChecker;ZJLjava/util/concurrent/TimeUnit;)V
21: invokespecial java.util.concurrent.ThreadPoolExecutor.<init>:(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V
astore 10
start local 10 22: aload 4
ifnull 23
aload 4
ldc "worker"
ldc "vert.x-worker-thread"
aload 1
invokevirtual io.vertx.core.VertxOptions.getWorkerPoolSize:()I
invokeinterface io.vertx.core.spi.metrics.VertxMetrics.createPoolMetrics:(Ljava/lang/String;Ljava/lang/String;I)Lio/vertx/core/spi/metrics/PoolMetrics;
goto 24
StackMap locals: java.util.concurrent.ThreadFactory int java.util.concurrent.ExecutorService
StackMap stack:
23: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.spi.metrics.PoolMetrics
24: astore 11
start local 11 25: aload 1
invokevirtual io.vertx.core.VertxOptions.getInternalBlockingPoolSize:()I
26: new io.vertx.core.impl.VertxThreadFactory
dup
ldc "vert.x-internal-blocking-"
aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
iconst_1
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTime:()J
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTimeUnit:()Ljava/util/concurrent/TimeUnit;
invokespecial io.vertx.core.impl.VertxThreadFactory.<init>:(Ljava/lang/String;Lio/vertx/core/impl/BlockedThreadChecker;ZJLjava/util/concurrent/TimeUnit;)V
27: invokestatic java.util.concurrent.Executors.newFixedThreadPool:(ILjava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ExecutorService;
astore 12
start local 12 28: aload 4
ifnull 29
aload 4
ldc "worker"
ldc "vert.x-internal-blocking"
aload 1
invokevirtual io.vertx.core.VertxOptions.getInternalBlockingPoolSize:()I
invokeinterface io.vertx.core.spi.metrics.VertxMetrics.createPoolMetrics:(Ljava/lang/String;Ljava/lang/String;I)Lio/vertx/core/spi/metrics/PoolMetrics;
goto 30
StackMap locals: io.vertx.core.spi.metrics.PoolMetrics java.util.concurrent.ExecutorService
StackMap stack:
29: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.spi.metrics.PoolMetrics
30: astore 13
start local 13 31: aload 0
new io.vertx.core.impl.WorkerPool
dup
aload 12
aload 13
invokespecial io.vertx.core.impl.WorkerPool.<init>:(Ljava/util/concurrent/ExecutorService;Lio/vertx/core/spi/metrics/PoolMetrics;)V
putfield io.vertx.core.impl.VertxImpl.internalBlockingPool:Lio/vertx/core/impl/WorkerPool;
32: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.core.impl.VertxImpl.namedWorkerPools:Ljava/util/Map;
33: aload 0
new io.vertx.core.impl.WorkerPool
dup
aload 10
aload 11
invokespecial io.vertx.core.impl.WorkerPool.<init>:(Ljava/util/concurrent/ExecutorService;Lio/vertx/core/spi/metrics/PoolMetrics;)V
putfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
34: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getWorkerPoolSize:()I
putfield io.vertx.core.impl.VertxImpl.defaultWorkerPoolSize:I
35: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTime:()J
putfield io.vertx.core.impl.VertxImpl.maxWorkerExecTime:J
36: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getMaxWorkerExecuteTimeUnit:()Ljava/util/concurrent/TimeUnit;
putfield io.vertx.core.impl.VertxImpl.maxWorkerExecTimeUnit:Ljava/util/concurrent/TimeUnit;
37: aload 0
aload 4
putfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
38: aload 0
aload 6
putfield io.vertx.core.impl.VertxImpl.transport:Lio/vertx/core/net/impl/transport/Transport;
39: aload 0
aload 7
putfield io.vertx.core.impl.VertxImpl.fileResolver:Lio/vertx/core/file/impl/FileResolver;
40: aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getAddressResolverOptions:()Lio/vertx/core/dns/AddressResolverOptions;
putfield io.vertx.core.impl.VertxImpl.addressResolverOptions:Lio/vertx/core/dns/AddressResolverOptions;
41: aload 0
new io.vertx.core.impl.AddressResolver
dup
aload 0
aload 1
invokevirtual io.vertx.core.VertxOptions.getAddressResolverOptions:()Lio/vertx/core/dns/AddressResolverOptions;
invokespecial io.vertx.core.impl.AddressResolver.<init>:(Lio/vertx/core/Vertx;Lio/vertx/core/dns/AddressResolverOptions;)V
putfield io.vertx.core.impl.VertxImpl.addressResolver:Lio/vertx/core/impl/AddressResolver;
42: aload 0
aload 5
putfield io.vertx.core.impl.VertxImpl.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
43: aload 0
aload 2
putfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
44: aload 0
aload 3
putfield io.vertx.core.impl.VertxImpl.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
45: aload 0
aload 2
ifnull 46
new io.vertx.core.eventbus.impl.clustered.ClusteredEventBus
dup
aload 0
aload 1
aload 2
aload 3
invokespecial io.vertx.core.eventbus.impl.clustered.ClusteredEventBus.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/VertxOptions;Lio/vertx/core/spi/cluster/ClusterManager;Lio/vertx/core/spi/cluster/NodeSelector;)V
goto 47
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.VertxOptions io.vertx.core.spi.cluster.ClusterManager io.vertx.core.spi.cluster.NodeSelector io.vertx.core.spi.metrics.VertxMetrics io.vertx.core.spi.tracing.VertxTracer io.vertx.core.net.impl.transport.Transport io.vertx.core.file.impl.FileResolver java.util.concurrent.ThreadFactory int java.util.concurrent.ExecutorService io.vertx.core.spi.metrics.PoolMetrics java.util.concurrent.ExecutorService io.vertx.core.spi.metrics.PoolMetrics
StackMap stack: io.vertx.core.impl.VertxImpl
46: new io.vertx.core.eventbus.impl.EventBusImpl
dup
aload 0
invokespecial io.vertx.core.eventbus.impl.EventBusImpl.<init>:(Lio/vertx/core/impl/VertxInternal;)V
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.VertxOptions io.vertx.core.spi.cluster.ClusterManager io.vertx.core.spi.cluster.NodeSelector io.vertx.core.spi.metrics.VertxMetrics io.vertx.core.spi.tracing.VertxTracer io.vertx.core.net.impl.transport.Transport io.vertx.core.file.impl.FileResolver java.util.concurrent.ThreadFactory int java.util.concurrent.ExecutorService io.vertx.core.spi.metrics.PoolMetrics java.util.concurrent.ExecutorService io.vertx.core.spi.metrics.PoolMetrics
StackMap stack: io.vertx.core.impl.VertxImpl io.vertx.core.eventbus.impl.EventBusImpl
47: putfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
48: aload 0
new io.vertx.core.shareddata.impl.SharedDataImpl
dup
aload 0
aload 2
invokespecial io.vertx.core.shareddata.impl.SharedDataImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/spi/cluster/ClusterManager;)V
putfield io.vertx.core.impl.VertxImpl.sharedData:Lio/vertx/core/shareddata/SharedData;
49: aload 0
new io.vertx.core.impl.DeploymentManager
dup
aload 0
invokespecial io.vertx.core.impl.DeploymentManager.<init>:(Lio/vertx/core/impl/VertxInternal;)V
putfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
50: aload 0
new io.vertx.core.impl.VerticleManager
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
invokespecial io.vertx.core.impl.VerticleManager.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/impl/DeploymentManager;)V
putfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
51: return
end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 52 0 this Lio/vertx/core/impl/VertxImpl;
0 52 1 options Lio/vertx/core/VertxOptions;
0 52 2 clusterManager Lio/vertx/core/spi/cluster/ClusterManager;
0 52 3 nodeSelector Lio/vertx/core/spi/cluster/NodeSelector;
0 52 4 metrics Lio/vertx/core/spi/metrics/VertxMetrics;
0 52 5 tracer Lio/vertx/core/spi/tracing/VertxTracer<**>;
0 52 6 transport Lio/vertx/core/net/impl/transport/Transport;
0 52 7 fileResolver Lio/vertx/core/file/impl/FileResolver;
16 52 8 acceptorEventLoopThreadFactory Ljava/util/concurrent/ThreadFactory;
18 52 9 workerPoolSize I
22 52 10 workerExec Ljava/util/concurrent/ExecutorService;
25 52 11 workerPoolMetrics Lio/vertx/core/spi/metrics/PoolMetrics;
28 52 12 internalBlockingExec Ljava/util/concurrent/ExecutorService;
31 52 13 internalBlockingPoolMetrics Lio/vertx/core/spi/metrics/PoolMetrics;
Signature: (Lio/vertx/core/VertxOptions;Lio/vertx/core/spi/cluster/ClusterManager;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/spi/metrics/VertxMetrics;Lio/vertx/core/spi/tracing/VertxTracer<**>;Lio/vertx/core/net/impl/transport/Transport;Lio/vertx/core/file/impl/FileResolver;)V
MethodParameters:
Name Flags
options
clusterManager
nodeSelector
metrics
tracer
transport
fileResolver
void init();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
invokeinterface io.vertx.core.eventbus.impl.EventBusInternal.start:(Lio/vertx/core/Promise;)V
1: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
ifnull 3
2: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
aload 0
invokeinterface io.vertx.core.spi.metrics.VertxMetrics.vertxCreated:(Lio/vertx/core/Vertx;)V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
void initClustered(io.vertx.core.VertxOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.Vertx>>);
descriptor: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
invokeinterface io.vertx.core.spi.cluster.NodeSelector.init:(Lio/vertx/core/Vertx;Lio/vertx/core/spi/cluster/ClusterManager;)V
1: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
invokeinterface io.vertx.core.spi.cluster.ClusterManager.init:(Lio/vertx/core/Vertx;Lio/vertx/core/spi/cluster/NodeSelector;)V
2: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 3: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 2
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$0(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 4
start local 4 5: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 1
aload 3
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$2(Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
aload 4
invokeinterface io.vertx.core.spi.cluster.ClusterManager.join:(Lio/vertx/core/Promise;)V
7: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/impl/VertxImpl;
0 8 1 options Lio/vertx/core/VertxOptions;
0 8 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/Vertx;>;>;
3 8 3 initPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
5 8 4 joinPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/Vertx;>;>;)V
MethodParameters:
Name Flags
options
resultHandler
private void createHaManager(io.vertx.core.VertxOptions, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/VertxOptions;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$3(Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 0
aload 2
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$4(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
2: invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 options Lio/vertx/core/VertxOptions;
0 4 2 initPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
options
initPromise
private void startEventBus(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 2
start local 2 1: aload 0
getfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
aload 2
invokeinterface io.vertx.core.eventbus.impl.EventBusInternal.start:(Lio/vertx/core/Promise;)V
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$5(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 initPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
1 4 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
initPromise
private void initializeHaManager(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$6(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 1
2: invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 initPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
initPromise
protected io.vertx.core.file.FileSystem getFileSystem();
descriptor: ()Lio/vertx/core/file/FileSystem;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: invokestatic io.vertx.core.impl.Utils.isWindows:()Z
ifeq 1
new io.vertx.core.file.impl.WindowsFileSystem
dup
aload 0
invokespecial io.vertx.core.file.impl.WindowsFileSystem.<init>:(Lio/vertx/core/impl/VertxInternal;)V
goto 2
StackMap locals:
StackMap stack:
1: new io.vertx.core.file.impl.FileSystemImpl
dup
aload 0
invokespecial io.vertx.core.file.impl.FileSystemImpl.<init>:(Lio/vertx/core/impl/VertxInternal;)V
StackMap locals:
StackMap stack: io.vertx.core.file.impl.FileSystemImpl
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
public long maxEventLoopExecTime();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTime:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public java.util.concurrent.TimeUnit maxEventLoopExecTimeUnit();
descriptor: ()Ljava/util/concurrent/TimeUnit;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.maxEventLoopExecTimeUnit:Ljava/util/concurrent/TimeUnit;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.datagram.DatagramSocket createDatagramSocket(io.vertx.core.datagram.DatagramSocketOptions);
descriptor: (Lio/vertx/core/datagram/DatagramSocketOptions;)Lio/vertx/core/datagram/DatagramSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.vertx.core.datagram.impl.DatagramSocketImpl.create:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/datagram/DatagramSocketOptions;)Lio/vertx/core/datagram/impl/DatagramSocketImpl;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 options Lio/vertx/core/datagram/DatagramSocketOptions;
MethodParameters:
Name Flags
options
public io.vertx.core.datagram.DatagramSocket createDatagramSocket();
descriptor: ()Lio/vertx/core/datagram/DatagramSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.datagram.DatagramSocketOptions
dup
invokespecial io.vertx.core.datagram.DatagramSocketOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createDatagramSocket:(Lio/vertx/core/datagram/DatagramSocketOptions;)Lio/vertx/core/datagram/DatagramSocket;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.net.NetServer createNetServer(io.vertx.core.net.NetServerOptions);
descriptor: (Lio/vertx/core/net/NetServerOptions;)Lio/vertx/core/net/NetServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.vertx.core.net.impl.NetServerImpl
dup
aload 0
aload 1
invokespecial io.vertx.core.net.impl.NetServerImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/net/NetServerOptions;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 options Lio/vertx/core/net/NetServerOptions;
MethodParameters:
Name Flags
options
public io.vertx.core.net.NetServer createNetServer();
descriptor: ()Lio/vertx/core/net/NetServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.net.NetServerOptions
dup
invokespecial io.vertx.core.net.NetServerOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createNetServer:(Lio/vertx/core/net/NetServerOptions;)Lio/vertx/core/net/NetServer;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.net.NetClient createNetClient(io.vertx.core.net.NetClientOptions, io.vertx.core.impl.CloseFuture);
descriptor: (Lio/vertx/core/net/NetClientOptions;Lio/vertx/core/impl/CloseFuture;)Lio/vertx/core/net/NetClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.core.net.impl.NetClientImpl
dup
aload 0
aload 1
aload 2
invokespecial io.vertx.core.net.impl.NetClientImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/net/NetClientOptions;Lio/vertx/core/impl/CloseFuture;)V
astore 3
start local 3 1: aload 2
aload 3
invokevirtual io.vertx.core.impl.CloseFuture.init:(Lio/vertx/core/Closeable;)V
2: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 options Lio/vertx/core/net/NetClientOptions;
0 3 2 closeFuture Lio/vertx/core/impl/CloseFuture;
1 3 3 client Lio/vertx/core/net/impl/NetClientImpl;
MethodParameters:
Name Flags
options
closeFuture
public io.vertx.core.net.NetClient createNetClient(io.vertx.core.net.NetClientOptions);
descriptor: (Lio/vertx/core/net/NetClientOptions;)Lio/vertx/core/net/NetClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new io.vertx.core.impl.CloseFuture
dup
invokespecial io.vertx.core.impl.CloseFuture.<init>:()V
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.createNetClient:(Lio/vertx/core/net/NetClientOptions;Lio/vertx/core/impl/CloseFuture;)Lio/vertx/core/net/NetClient;
astore 3
start local 3 2: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.resolveHooks:()Lio/vertx/core/impl/CloseHooks;
astore 4
start local 4 3: aload 4
aload 2
invokevirtual io.vertx.core.impl.CloseHooks.add:(Lio/vertx/core/Closeable;)V
4: aload 3
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 options Lio/vertx/core/net/NetClientOptions;
1 5 2 closeFuture Lio/vertx/core/impl/CloseFuture;
2 5 3 client Lio/vertx/core/net/NetClient;
3 5 4 hooks Lio/vertx/core/impl/CloseHooks;
MethodParameters:
Name Flags
options
public io.vertx.core.net.NetClient createNetClient();
descriptor: ()Lio/vertx/core/net/NetClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.net.NetClientOptions
dup
invokespecial io.vertx.core.net.NetClientOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createNetClient:(Lio/vertx/core/net/NetClientOptions;)Lio/vertx/core/net/NetClient;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.net.impl.transport.Transport transport();
descriptor: ()Lio/vertx/core/net/impl/transport/Transport;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.transport:Lio/vertx/core/net/impl/transport/Transport;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public boolean isNativeTransportEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.transport:Lio/vertx/core/net/impl/transport/Transport;
getstatic io.vertx.core.net.impl.transport.Transport.JDK:Lio/vertx/core/net/impl/transport/Transport;
if_acmpeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.file.FileSystem fileSystem();
descriptor: ()Lio/vertx/core/file/FileSystem;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.fileSystem:Lio/vertx/core/file/FileSystem;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.shareddata.SharedData sharedData();
descriptor: ()Lio/vertx/core/shareddata/SharedData;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.sharedData:Lio/vertx/core/shareddata/SharedData;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.http.HttpServer createHttpServer(io.vertx.core.http.HttpServerOptions);
descriptor: (Lio/vertx/core/http/HttpServerOptions;)Lio/vertx/core/http/HttpServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.vertx.core.http.impl.HttpServerImpl
dup
aload 0
aload 1
invokespecial io.vertx.core.http.impl.HttpServerImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/http/HttpServerOptions;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 serverOptions Lio/vertx/core/http/HttpServerOptions;
MethodParameters:
Name Flags
serverOptions
public io.vertx.core.http.HttpServer createHttpServer();
descriptor: ()Lio/vertx/core/http/HttpServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.http.HttpServerOptions
dup
invokespecial io.vertx.core.http.HttpServerOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createHttpServer:(Lio/vertx/core/http/HttpServerOptions;)Lio/vertx/core/http/HttpServer;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.http.HttpClient createHttpClient(io.vertx.core.http.HttpClientOptions, io.vertx.core.impl.CloseFuture);
descriptor: (Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/impl/CloseFuture;)Lio/vertx/core/http/HttpClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.core.http.impl.HttpClientImpl
dup
aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.HttpClientImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/impl/CloseFuture;)V
astore 3
start local 3 1: aload 2
aload 3
invokevirtual io.vertx.core.impl.CloseFuture.init:(Lio/vertx/core/Closeable;)V
2: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 options Lio/vertx/core/http/HttpClientOptions;
0 3 2 closeFuture Lio/vertx/core/impl/CloseFuture;
1 3 3 client Lio/vertx/core/http/impl/HttpClientImpl;
MethodParameters:
Name Flags
options
closeFuture
public io.vertx.core.http.HttpClient createHttpClient(io.vertx.core.http.HttpClientOptions);
descriptor: (Lio/vertx/core/http/HttpClientOptions;)Lio/vertx/core/http/HttpClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new io.vertx.core.impl.CloseFuture
dup
invokespecial io.vertx.core.impl.CloseFuture.<init>:()V
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.createHttpClient:(Lio/vertx/core/http/HttpClientOptions;Lio/vertx/core/impl/CloseFuture;)Lio/vertx/core/http/HttpClient;
astore 3
start local 3 2: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.resolveHooks:()Lio/vertx/core/impl/CloseHooks;
astore 4
start local 4 3: aload 4
aload 2
invokevirtual io.vertx.core.impl.CloseHooks.add:(Lio/vertx/core/Closeable;)V
4: aload 3
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 options Lio/vertx/core/http/HttpClientOptions;
1 5 2 closeFuture Lio/vertx/core/impl/CloseFuture;
2 5 3 client Lio/vertx/core/http/HttpClient;
3 5 4 hooks Lio/vertx/core/impl/CloseHooks;
MethodParameters:
Name Flags
options
public io.vertx.core.http.HttpClient createHttpClient();
descriptor: ()Lio/vertx/core/http/HttpClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.http.HttpClientOptions
dup
invokespecial io.vertx.core.http.HttpClientOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createHttpClient:(Lio/vertx/core/http/HttpClientOptions;)Lio/vertx/core/http/HttpClient;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.eventbus.EventBus eventBus();
descriptor: ()Lio/vertx/core/eventbus/EventBus;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public long setPeriodic(long, io.vertx.core.Handler<java.lang.Long>);
descriptor: (JLio/vertx/core/Handler;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 3
lload 1
iconst_1
invokevirtual io.vertx.core.impl.VertxImpl.scheduleTimeout:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;JZ)J
lreturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 delay J
0 1 3 handler Lio/vertx/core/Handler<Ljava/lang/Long;>;
Signature: (JLio/vertx/core/Handler<Ljava/lang/Long;>;)J
MethodParameters:
Name Flags
delay
handler
public io.vertx.core.TimeoutStream periodicStream(long);
descriptor: (J)Lio/vertx/core/TimeoutStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.core.impl.VertxImpl$TimeoutStreamImpl
dup
aload 0
lload 1
iconst_1
invokespecial io.vertx.core.impl.VertxImpl$TimeoutStreamImpl.<init>:(Lio/vertx/core/impl/VertxImpl;JZ)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 delay J
MethodParameters:
Name Flags
delay
public long setTimer(long, io.vertx.core.Handler<java.lang.Long>);
descriptor: (JLio/vertx/core/Handler;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 3
lload 1
iconst_0
invokevirtual io.vertx.core.impl.VertxImpl.scheduleTimeout:(Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;JZ)J
lreturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 delay J
0 1 3 handler Lio/vertx/core/Handler<Ljava/lang/Long;>;
Signature: (JLio/vertx/core/Handler<Ljava/lang/Long;>;)J
MethodParameters:
Name Flags
delay
handler
public io.vertx.core.TimeoutStream timerStream(long);
descriptor: (J)Lio/vertx/core/TimeoutStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.core.impl.VertxImpl$TimeoutStreamImpl
dup
aload 0
lload 1
iconst_0
invokespecial io.vertx.core.impl.VertxImpl$TimeoutStreamImpl.<init>:(Lio/vertx/core/impl/VertxImpl;JZ)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 delay J
MethodParameters:
Name Flags
delay
public <T> io.vertx.core.impl.future.PromiseInternal<T> promise();
descriptor: ()Lio/vertx/core/impl/future/PromiseInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 1
start local 1 1: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
1 2 1 context Lio/vertx/core/impl/ContextInternal;
Signature: <T:Ljava/lang/Object;>()Lio/vertx/core/impl/future/PromiseInternal<TT;>;
public <T> io.vertx.core.impl.future.PromiseInternal<T> promise(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.vertx.core.impl.future.PromiseInternal
ifeq 2
1: aload 1
checkcast io.vertx.core.impl.future.PromiseInternal
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 3: aload 2
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
3 5 2 promise Lio/vertx/core/impl/future/PromiseInternal<TT;>;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)Lio/vertx/core/impl/future/PromiseInternal<TT;>;
MethodParameters:
Name Flags
handler
public void runOnContext(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 2
start local 2 1: aload 2
aload 1
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 task Lio/vertx/core/Handler<Ljava/lang/Void;>;
1 3 2 context Lio/vertx/core/impl/ContextInternal;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
task
public java.util.concurrent.ExecutorService getWorkerPool();
descriptor: ()Ljava/util/concurrent/ExecutorService;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
invokevirtual io.vertx.core.impl.WorkerPool.executor:()Ljava/util/concurrent/ExecutorService;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.netty.channel.EventLoopGroup getEventLoopGroup();
descriptor: ()Lio/netty/channel/EventLoopGroup;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.eventLoopGroup:Lio/netty/channel/EventLoopGroup;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.netty.channel.EventLoopGroup getAcceptorEventLoopGroup();
descriptor: ()Lio/netty/channel/EventLoopGroup;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.acceptorEventLoopGroup:Lio/netty/channel/EventLoopGroup;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.impl.ContextInternal getOrCreateContext();
descriptor: ()Lio/vertx/core/impl/ContextInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getContext:()Lio/vertx/core/impl/AbstractContext;
astore 1
start local 1 1: aload 1
ifnonnull 4
2: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.createEventLoopContext:()Lio/vertx/core/impl/EventLoopContext;
astore 1
3: aload 0
getfield io.vertx.core.impl.VertxImpl.stickyContext:Ljava/lang/ThreadLocal;
new java.lang.ref.WeakReference
dup
aload 1
invokespecial java.lang.ref.WeakReference.<init>:(Ljava/lang/Object;)V
invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
4: StackMap locals: io.vertx.core.impl.AbstractContext
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
1 5 1 ctx Lio/vertx/core/impl/AbstractContext;
public java.util.Map<io.vertx.core.net.impl.ServerID, io.vertx.core.http.impl.HttpServerImpl> sharedHttpServers();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.sharedHttpServers:Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Ljava/util/Map<Lio/vertx/core/net/impl/ServerID;Lio/vertx/core/http/impl/HttpServerImpl;>;
public java.util.Map<io.vertx.core.net.impl.ServerID, io.vertx.core.net.impl.NetServerImpl> sharedNetServers();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.sharedNetServers:Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Ljava/util/Map<Lio/vertx/core/net/impl/ServerID;Lio/vertx/core/net/impl/NetServerImpl;>;
public <S extends io.vertx.core.net.impl.TCPServerBase> java.util.Map<io.vertx.core.net.impl.ServerID, S> sharedTCPServers(java.lang.Class<S>);
descriptor: (Ljava/lang/Class;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc Lio/vertx/core/net/impl/NetServerImpl;
if_acmpne 2
1: aload 0
getfield io.vertx.core.impl.VertxImpl.sharedNetServers:Ljava/util/Map;
areturn
2: StackMap locals:
StackMap stack:
aload 1
ldc Lio/vertx/core/http/impl/HttpServerImpl;
if_acmpne 4
3: aload 0
getfield io.vertx.core.impl.VertxImpl.sharedHttpServers:Ljava/util/Map;
areturn
4: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 type Ljava/lang/Class<TS;>;
Signature: <S:Lio/vertx/core/net/impl/TCPServerBase;>(Ljava/lang/Class<TS;>;)Ljava/util/Map<Lio/vertx/core/net/impl/ServerID;TS;>;
MethodParameters:
Name Flags
type
public boolean isMetricsEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
ifnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.spi.metrics.Metrics getMetrics();
descriptor: ()Lio/vertx/core/spi/metrics/Metrics;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public boolean cancelTimer(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.timeouts:Ljava/util/concurrent/ConcurrentMap;
lload 1
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.impl.VertxImpl$InternalTimerHandler
astore 3
start local 3 1: aload 3
ifnull 4
2: aload 3
invokevirtual io.vertx.core.impl.VertxImpl$InternalTimerHandler.cancel:()V
3: iconst_1
ireturn
4: StackMap locals: io.vertx.core.impl.VertxImpl$InternalTimerHandler
StackMap stack:
iconst_0
ireturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 id J
1 5 3 handler Lio/vertx/core/impl/VertxImpl$InternalTimerHandler;
MethodParameters:
Name Flags
id
public io.vertx.core.impl.EventLoopContext createEventLoopContext(io.vertx.core.impl.Deployment, io.vertx.core.impl.CloseHooks, io.vertx.core.impl.WorkerPool, java.lang.ClassLoader);
descriptor: (Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Lio/vertx/core/impl/WorkerPool;Ljava/lang/ClassLoader;)Lio/vertx/core/impl/EventLoopContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new io.vertx.core.impl.EventLoopContext
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
aload 0
getfield io.vertx.core.impl.VertxImpl.eventLoopGroup:Lio/netty/channel/EventLoopGroup;
invokeinterface io.netty.channel.EventLoopGroup.next:()Lio/netty/channel/EventLoop;
aload 0
getfield io.vertx.core.impl.VertxImpl.internalBlockingPool:Lio/vertx/core/impl/WorkerPool;
aload 3
ifnull 1
aload 3
goto 2
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.impl.Deployment io.vertx.core.impl.CloseHooks io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool
1: aload 0
getfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.impl.Deployment io.vertx.core.impl.CloseHooks io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool io.vertx.core.impl.WorkerPool
2: aload 1
aload 2
aload 4
invokespecial io.vertx.core.impl.EventLoopContext.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/spi/tracing/VertxTracer;Lio/netty/channel/EventLoop;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Ljava/lang/ClassLoader;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 deployment Lio/vertx/core/impl/Deployment;
0 3 2 closeHooks Lio/vertx/core/impl/CloseHooks;
0 3 3 workerPool Lio/vertx/core/impl/WorkerPool;
0 3 4 tccl Ljava/lang/ClassLoader;
MethodParameters:
Name Flags
deployment
closeHooks
workerPool
tccl
public io.vertx.core.impl.EventLoopContext createEventLoopContext(io.netty.channel.EventLoop, io.vertx.core.impl.WorkerPool, java.lang.ClassLoader);
descriptor: (Lio/netty/channel/EventLoop;Lio/vertx/core/impl/WorkerPool;Ljava/lang/ClassLoader;)Lio/vertx/core/impl/EventLoopContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new io.vertx.core.impl.EventLoopContext
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
aload 1
aload 0
getfield io.vertx.core.impl.VertxImpl.internalBlockingPool:Lio/vertx/core/impl/WorkerPool;
aload 2
ifnull 1
aload 2
goto 2
StackMap locals: io.vertx.core.impl.VertxImpl io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool
1: aload 0
getfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
StackMap locals: io.vertx.core.impl.VertxImpl io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.netty.channel.EventLoop io.vertx.core.impl.WorkerPool io.vertx.core.impl.WorkerPool
2: aconst_null
aconst_null
aload 3
invokespecial io.vertx.core.impl.EventLoopContext.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/spi/tracing/VertxTracer;Lio/netty/channel/EventLoop;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Ljava/lang/ClassLoader;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 eventLoop Lio/netty/channel/EventLoop;
0 3 2 workerPool Lio/vertx/core/impl/WorkerPool;
0 3 3 tccl Ljava/lang/ClassLoader;
MethodParameters:
Name Flags
eventLoop
workerPool
tccl
public io.vertx.core.impl.EventLoopContext createEventLoopContext();
descriptor: ()Lio/vertx/core/impl/EventLoopContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
aconst_null
aconst_null
invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.getContextClassLoader:()Ljava/lang/ClassLoader;
invokevirtual io.vertx.core.impl.VertxImpl.createEventLoopContext:(Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Lio/vertx/core/impl/WorkerPool;Ljava/lang/ClassLoader;)Lio/vertx/core/impl/EventLoopContext;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.impl.WorkerContext createWorkerContext(io.vertx.core.impl.Deployment, io.vertx.core.impl.CloseHooks, io.vertx.core.impl.WorkerPool, java.lang.ClassLoader);
descriptor: (Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Lio/vertx/core/impl/WorkerPool;Ljava/lang/ClassLoader;)Lio/vertx/core/impl/WorkerContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new io.vertx.core.impl.WorkerContext
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
aload 0
getfield io.vertx.core.impl.VertxImpl.internalBlockingPool:Lio/vertx/core/impl/WorkerPool;
aload 3
ifnull 1
aload 3
goto 2
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.impl.Deployment io.vertx.core.impl.CloseHooks io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.vertx.core.impl.WorkerPool
1: aload 0
getfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
StackMap locals: io.vertx.core.impl.VertxImpl io.vertx.core.impl.Deployment io.vertx.core.impl.CloseHooks io.vertx.core.impl.WorkerPool java.lang.ClassLoader
StackMap stack: new 0 new 0 io.vertx.core.impl.VertxImpl io.vertx.core.spi.tracing.VertxTracer io.vertx.core.impl.WorkerPool io.vertx.core.impl.WorkerPool
2: aload 1
aload 2
aload 4
invokespecial io.vertx.core.impl.WorkerContext.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/WorkerPool;Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Ljava/lang/ClassLoader;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 deployment Lio/vertx/core/impl/Deployment;
0 3 2 closeHooks Lio/vertx/core/impl/CloseHooks;
0 3 3 workerPool Lio/vertx/core/impl/WorkerPool;
0 3 4 tccl Ljava/lang/ClassLoader;
MethodParameters:
Name Flags
deployment
closeHooks
workerPool
tccl
public io.vertx.core.impl.WorkerContext createWorkerContext();
descriptor: ()Lio/vertx/core/impl/WorkerContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
aconst_null
aconst_null
aconst_null
invokevirtual io.vertx.core.impl.VertxImpl.createWorkerContext:(Lio/vertx/core/impl/Deployment;Lio/vertx/core/impl/CloseHooks;Lio/vertx/core/impl/WorkerPool;Ljava/lang/ClassLoader;)Lio/vertx/core/impl/WorkerContext;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.dns.DnsClient createDnsClient(int, java.lang.String);
descriptor: (ILjava/lang/String;)Lio/vertx/core/dns/DnsClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
new io.vertx.core.dns.DnsClientOptions
dup
invokespecial io.vertx.core.dns.DnsClientOptions.<init>:()V
aload 2
invokevirtual io.vertx.core.dns.DnsClientOptions.setHost:(Ljava/lang/String;)Lio/vertx/core/dns/DnsClientOptions;
iload 1
invokevirtual io.vertx.core.dns.DnsClientOptions.setPort:(I)Lio/vertx/core/dns/DnsClientOptions;
invokevirtual io.vertx.core.impl.VertxImpl.createDnsClient:(Lio/vertx/core/dns/DnsClientOptions;)Lio/vertx/core/dns/DnsClient;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 port I
0 1 2 host Ljava/lang/String;
MethodParameters:
Name Flags
port
host
public io.vertx.core.dns.DnsClient createDnsClient();
descriptor: ()Lio/vertx/core/dns/DnsClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.core.dns.DnsClientOptions
dup
invokespecial io.vertx.core.dns.DnsClientOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.createDnsClient:(Lio/vertx/core/dns/DnsClientOptions;)Lio/vertx/core/dns/DnsClient;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.dns.DnsClient createDnsClient(io.vertx.core.dns.DnsClientOptions);
descriptor: (Lio/vertx/core/dns/DnsClientOptions;)Lio/vertx/core/dns/DnsClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.vertx.core.dns.DnsClientOptions.getHost:()Ljava/lang/String;
astore 2
start local 2 1: aload 1
invokevirtual io.vertx.core.dns.DnsClientOptions.getPort:()I
istore 3
start local 3 2: aload 2
ifnull 3
iload 3
ifge 9
3: StackMap locals: java.lang.String int
StackMap stack:
new io.vertx.core.impl.resolver.DnsResolverProvider
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.addressResolverOptions:Lio/vertx/core/dns/AddressResolverOptions;
invokespecial io.vertx.core.impl.resolver.DnsResolverProvider.<init>:(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/dns/AddressResolverOptions;)V
astore 4
start local 4 4: aload 4
invokevirtual io.vertx.core.impl.resolver.DnsResolverProvider.nameServerAddresses:()Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.net.InetSocketAddress
astore 5
start local 5 5: new io.vertx.core.dns.DnsClientOptions
dup
aload 1
invokespecial io.vertx.core.dns.DnsClientOptions.<init>:(Lio/vertx/core/dns/DnsClientOptions;)V
6: aload 5
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokevirtual io.vertx.core.dns.DnsClientOptions.setHost:(Ljava/lang/String;)Lio/vertx/core/dns/DnsClientOptions;
7: aload 5
invokevirtual java.net.InetSocketAddress.getPort:()I
invokevirtual io.vertx.core.dns.DnsClientOptions.setPort:(I)Lio/vertx/core/dns/DnsClientOptions;
8: astore 1
end local 5 end local 4 9: StackMap locals:
StackMap stack:
new io.vertx.core.dns.impl.DnsClientImpl
dup
aload 0
aload 1
invokespecial io.vertx.core.dns.impl.DnsClientImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/dns/DnsClientOptions;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/impl/VertxImpl;
0 10 1 options Lio/vertx/core/dns/DnsClientOptions;
1 10 2 host Ljava/lang/String;
2 10 3 port I
4 9 4 provider Lio/vertx/core/impl/resolver/DnsResolverProvider;
5 9 5 address Ljava/net/InetSocketAddress;
MethodParameters:
Name Flags
options
public long scheduleTimeout(io.vertx.core.impl.ContextInternal, io.vertx.core.Handler<java.lang.Long>, long, );
descriptor: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;JZ)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: lload 3
lconst_1
lcmp
ifge 2
1: new java.lang.IllegalArgumentException
dup
ldc "Cannot schedule a timer with delay < 1 ms"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.impl.VertxImpl.timeoutCounter:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.getAndIncrement:()J
lstore 6
start local 6 3: new io.vertx.core.impl.VertxImpl$InternalTimerHandler
dup
aload 0
lload 6
aload 2
iload 5
lload 3
aload 1
invokespecial io.vertx.core.impl.VertxImpl$InternalTimerHandler.<init>:(Lio/vertx/core/impl/VertxImpl;JLio/vertx/core/Handler;ZJLio/vertx/core/impl/ContextInternal;)V
astore 8
start local 8 4: aload 0
getfield io.vertx.core.impl.VertxImpl.timeouts:Ljava/util/concurrent/ConcurrentMap;
lload 6
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aload 8
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.isDeployment:()Z
ifeq 7
6: aload 1
aload 8
invokeinterface io.vertx.core.impl.ContextInternal.addCloseHook:(Lio/vertx/core/Closeable;)V
7: StackMap locals: long io.vertx.core.impl.VertxImpl$InternalTimerHandler
StackMap stack:
lload 6
lreturn
end local 8 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/impl/VertxImpl;
0 8 1 context Lio/vertx/core/impl/ContextInternal;
0 8 2 handler Lio/vertx/core/Handler<Ljava/lang/Long;>;
0 8 3 delay J
0 8 5 periodic Z
3 8 6 timerId J
4 8 8 task Lio/vertx/core/impl/VertxImpl$InternalTimerHandler;
Signature: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler<Ljava/lang/Long;>;JZ)J
MethodParameters:
Name Flags
context
handler
delay
periodic
public io.vertx.core.impl.AbstractContext getContext();
descriptor: ()Lio/vertx/core/impl/AbstractContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: invokestatic io.vertx.core.impl.ContextInternal.current:()Lio/vertx/core/impl/ContextInternal;
checkcast io.vertx.core.impl.AbstractContext
astore 1
start local 1 1: aload 1
ifnull 3
aload 1
invokevirtual io.vertx.core.impl.AbstractContext.owner:()Lio/vertx/core/impl/VertxInternal;
aload 0
if_acmpne 3
2: aload 1
areturn
3: StackMap locals: io.vertx.core.impl.AbstractContext
StackMap stack:
aload 0
getfield io.vertx.core.impl.VertxImpl.stickyContext:Ljava/lang/ThreadLocal;
invokevirtual java.lang.ThreadLocal.get:()Ljava/lang/Object;
checkcast java.lang.ref.WeakReference
astore 2
start local 2 4: aload 2
ifnull 5
aload 2
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast io.vertx.core.impl.AbstractContext
goto 6
StackMap locals: java.lang.ref.WeakReference
StackMap stack:
5: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.impl.AbstractContext
6: areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/impl/VertxImpl;
1 7 1 context Lio/vertx/core/impl/AbstractContext;
4 7 2 ref Ljava/lang/ref/WeakReference<Lio/vertx/core/impl/AbstractContext;>;
public io.vertx.core.spi.cluster.ClusterManager getClusterManager();
descriptor: ()Lio/vertx/core/spi/cluster/ClusterManager;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.close:(Lio/vertx/core/Handler;)V
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
private void closeClusterManager(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 1: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
ifnull 4
2: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
aload 2
invokeinterface io.vertx.core.spi.cluster.ClusterManager.leave:(Lio/vertx/core/Promise;)V
3: goto 5
4: StackMap locals: io.vertx.core.Promise
StackMap stack:
aload 2
invokeinterface io.vertx.core.Promise.complete:()V
5: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 1
invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$7(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/impl/VertxImpl;
0 7 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 7 2 leavePromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public synchronized void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.closed:Z
ifne 1
aload 0
getfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
ifnonnull 4
1: StackMap locals:
StackMap stack:
aload 1
ifnull 3
2: aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
return
4: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.impl.VertxImpl.closed:Z
5: aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$8(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.core.impl.CloseHooks.run:(Lio/vertx/core/Handler;)V
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/impl/VertxImpl;
0 7 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new io.vertx.core.DeploymentOptions
dup
invokespecial io.vertx.core.DeploymentOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 name Ljava/lang/String;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
name
public void deployVerticle(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
new io.vertx.core.DeploymentOptions
dup
invokespecial io.vertx.core.DeploymentOptions.<init>:()V
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 name Ljava/lang/String;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
name
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(java.lang.String, io.vertx.core.DeploymentOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokevirtual io.vertx.core.DeploymentOptions.isHa:()Z
ifeq 4
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
ifnull 4
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
invokevirtual io.vertx.core.impl.HAManager.isEnabled:()Z
ifeq 4
1: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
aload 1
aload 2
aload 3
invokevirtual io.vertx.core.impl.HAManager.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
3: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
aload 1
aload 2
invokevirtual io.vertx.core.impl.VerticleManager.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/impl/Deployment.deploymentID()Ljava/lang/String; (9 itf)
(Lio/vertx/core/impl/Deployment;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 1 name Ljava/lang/String;
0 5 2 options Lio/vertx/core/DeploymentOptions;
2 4 3 promise Lio/vertx/core/Promise<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
name
options
public void deployVerticle(java.lang.String, io.vertx.core.DeploymentOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 3
ifnull 3
2: aload 4
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 name Ljava/lang/String;
0 4 2 options Lio/vertx/core/DeploymentOptions;
0 4 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 4 4 fut Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
name
options
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(io.vertx.core.Verticle);
descriptor: (Lio/vertx/core/Verticle;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new io.vertx.core.DeploymentOptions
dup
invokespecial io.vertx.core.DeploymentOptions.<init>:()V
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 verticle Lio/vertx/core/Verticle;
Signature: (Lio/vertx/core/Verticle;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
verticle
public void deployVerticle(io.vertx.core.Verticle, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Lio/vertx/core/Verticle;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Lio/vertx/core/Verticle;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 2
ifnull 3
2: aload 3
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 verticle Lio/vertx/core/Verticle;
0 4 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 4 3 fut Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Lio/vertx/core/Verticle;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
verticle
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(io.vertx.core.Verticle, io.vertx.core.DeploymentOptions);
descriptor: (Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokevirtual io.vertx.core.DeploymentOptions.getInstances:()I
iconst_1
if_icmpeq 2
1: new java.lang.IllegalArgumentException
dup
ldc "Can't specify > 1 instances for already created verticle"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokedynamic call(Lio/vertx/core/Verticle;)Ljava/util/concurrent/Callable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/core/impl/VertxImpl.lambda$16(Lio/vertx/core/Verticle;)Lio/vertx/core/Verticle; (6)
()Lio/vertx/core/Verticle;
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/util/concurrent/Callable;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 verticle Lio/vertx/core/Verticle;
0 3 2 options Lio/vertx/core/DeploymentOptions;
Signature: (Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
verticle
options
public void deployVerticle(io.vertx.core.Verticle, io.vertx.core.DeploymentOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 3
ifnull 3
2: aload 4
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 verticle Lio/vertx/core/Verticle;
0 4 2 options Lio/vertx/core/DeploymentOptions;
0 4 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 4 4 fut Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
verticle
options
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(java.lang.Class<? extends io.vertx.core.Verticle>, io.vertx.core.DeploymentOptions);
descriptor: (Ljava/lang/Class;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic call(Ljava/lang/Class;)Ljava/util/concurrent/Callable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
java/lang/Class.newInstance()Ljava/lang/Object; (5)
()Lio/vertx/core/Verticle;
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/util/concurrent/Callable;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 verticleClass Ljava/lang/Class<+Lio/vertx/core/Verticle;>;
0 1 2 options Lio/vertx/core/DeploymentOptions;
Signature: (Ljava/lang/Class<+Lio/vertx/core/Verticle;>;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
verticleClass
options
public void deployVerticle(java.lang.Class<? extends io.vertx.core.Verticle>, io.vertx.core.DeploymentOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/Class;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/lang/Class;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 3
ifnull 3
2: aload 4
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 verticleClass Ljava/lang/Class<+Lio/vertx/core/Verticle;>;
0 4 2 options Lio/vertx/core/DeploymentOptions;
0 4 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 4 4 fut Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/Class<+Lio/vertx/core/Verticle;>;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
verticleClass
options
completionHandler
public io.vertx.core.Future<java.lang.String> deployVerticle(java.util.function.Supplier<io.vertx.core.Verticle>, io.vertx.core.DeploymentOptions);
descriptor: (Ljava/util/function/Supplier;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic call(Ljava/util/function/Supplier;)Ljava/util/concurrent/Callable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
java/util/function/Supplier.get()Ljava/lang/Object; (9 itf)
()Lio/vertx/core/Verticle;
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/util/concurrent/Callable;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 verticleSupplier Ljava/util/function/Supplier<Lio/vertx/core/Verticle;>;
0 1 2 options Lio/vertx/core/DeploymentOptions;
Signature: (Ljava/util/function/Supplier<Lio/vertx/core/Verticle;>;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
verticleSupplier
options
public void deployVerticle(java.util.function.Supplier<io.vertx.core.Verticle>, io.vertx.core.DeploymentOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/util/function/Supplier;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.deployVerticle:(Ljava/util/function/Supplier;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 3
ifnull 3
2: aload 4
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 verticleSupplier Ljava/util/function/Supplier<Lio/vertx/core/Verticle;>;
0 4 2 options Lio/vertx/core/DeploymentOptions;
0 4 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 4 4 fut Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/util/function/Supplier<Lio/vertx/core/Verticle;>;Lio/vertx/core/DeploymentOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
MethodParameters:
Name Flags
verticleSupplier
options
completionHandler
private io.vertx.core.Future<java.lang.String> deployVerticle(java.util.concurrent.Callable<io.vertx.core.Verticle>, io.vertx.core.DeploymentOptions);
descriptor: (Ljava/util/concurrent/Callable;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.core.impl.VertxImpl.closed:Z
istore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.core.impl.VertxImpl java.util.concurrent.Callable io.vertx.core.DeploymentOptions top io.vertx.core.impl.VertxImpl
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.core.impl.VertxImpl java.util.concurrent.Callable io.vertx.core.DeploymentOptions int
StackMap stack:
iload 3
ifeq 8
7: ldc "Vert.x closed"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
aload 1
aload 2
invokevirtual io.vertx.core.impl.DeploymentManager.deployVerticle:(Ljava/util/concurrent/Callable;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/impl/VertxImpl;
0 9 1 verticleSupplier Ljava/util/concurrent/Callable<Lio/vertx/core/Verticle;>;
0 9 2 options Lio/vertx/core/DeploymentOptions;
2 4 3 closed Z
6 9 3 closed Z
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Ljava/util/concurrent/Callable<Lio/vertx/core/Verticle;>;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
verticleSupplier
options
public io.vertx.core.Future<java.lang.Void> undeploy(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
astore 3
start local 3 1: aload 3
ifnull 6
aload 3
invokevirtual io.vertx.core.impl.HAManager.isEnabled:()Z
ifeq 6
2: aload 0
aload 3
aload 1
invokedynamic handle(Lio/vertx/core/impl/HAManager;Ljava/lang/String;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$19(Lio/vertx/core/impl/HAManager;Ljava/lang/String;Lio/vertx/core/Promise;)V (6)
(Lio/vertx/core/Promise;)V
3: iconst_0
4: invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;Z)Lio/vertx/core/Future;
astore 2
start local 2 5: goto 7
end local 2 6: StackMap locals: io.vertx.core.impl.VertxImpl java.lang.String top io.vertx.core.impl.HAManager
StackMap stack:
aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
astore 2
start local 2 7: StackMap locals: io.vertx.core.impl.VertxImpl java.lang.String io.vertx.core.Future io.vertx.core.impl.HAManager
StackMap stack:
aload 2
aload 0
aload 1
invokedynamic apply(Lio/vertx/core/impl/VertxImpl;Ljava/lang/String;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/impl/VertxImpl.lambda$20(Ljava/lang/String;Ljava/lang/Void;)Lio/vertx/core/Future; (7)
(Ljava/lang/Void;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.compose:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/impl/VertxImpl;
0 8 1 deploymentID Ljava/lang/String;
5 6 2 future Lio/vertx/core/Future<Ljava/lang/Void;>;
7 8 2 future Lio/vertx/core/Future<Ljava/lang/Void;>;
1 8 3 haManager Lio/vertx/core/impl/HAManager;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
deploymentID
public void undeploy(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.undeploy:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 2
ifnull 3
2: aload 3
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 deploymentID Ljava/lang/String;
0 4 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 4 3 fut Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
deploymentID
completionHandler
public java.util.Set<java.lang.String> deploymentIDs();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
invokevirtual io.vertx.core.impl.DeploymentManager.deployments:()Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Ljava/util/Set<Ljava/lang/String;>;
public void registerVerticleFactory(io.vertx.core.spi.VerticleFactory);
descriptor: (Lio/vertx/core/spi/VerticleFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
aload 1
invokevirtual io.vertx.core.impl.VerticleManager.registerVerticleFactory:(Lio/vertx/core/spi/VerticleFactory;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 factory Lio/vertx/core/spi/VerticleFactory;
MethodParameters:
Name Flags
factory
public void unregisterVerticleFactory(io.vertx.core.spi.VerticleFactory);
descriptor: (Lio/vertx/core/spi/VerticleFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
aload 1
invokevirtual io.vertx.core.impl.VerticleManager.unregisterVerticleFactory:(Lio/vertx/core/spi/VerticleFactory;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 factory Lio/vertx/core/spi/VerticleFactory;
MethodParameters:
Name Flags
factory
public java.util.Set<io.vertx.core.spi.VerticleFactory> verticleFactories();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
invokevirtual io.vertx.core.impl.VerticleManager.verticleFactories:()Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Ljava/util/Set<Lio/vertx/core/spi/VerticleFactory;>;
public <T> void executeBlockingInternal(io.vertx.core.Handler<io.vertx.core.Promise<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 3
start local 3 1: aload 3
aload 1
aload 2
invokeinterface io.vertx.core.impl.ContextInternal.executeBlockingInternal:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
1 3 3 context Lio/vertx/core/impl/ContextInternal;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
MethodParameters:
Name Flags
blockingCodeHandler
resultHandler
public <T> void executeBlockingInternal(io.vertx.core.Handler<io.vertx.core.Promise<T>>, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 4
start local 4 1: aload 4
aload 1
iload 2
aload 3
invokeinterface io.vertx.core.impl.ContextInternal.executeBlockingInternal:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
2: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
0 3 2 ordered Z
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
1 3 4 context Lio/vertx/core/impl/ContextInternal;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
MethodParameters:
Name Flags
blockingCodeHandler
ordered
resultHandler
public <T> io.vertx.core.Future<T> executeBlocking(io.vertx.core.Handler<io.vertx.core.Promise<T>>, boolean);
descriptor: (Lio/vertx/core/Handler;Z)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 3
start local 3 1: aload 3
aload 1
iload 2
invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;Z)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
0 2 2 ordered Z
1 2 3 context Lio/vertx/core/impl/ContextInternal;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;Z)Lio/vertx/core/Future<TT;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
blockingCodeHandler
ordered
public <T> io.vertx.core.Future<T> executeBlocking(io.vertx.core.Handler<io.vertx.core.Promise<T>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_1
invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;Z)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;)Lio/vertx/core/Future<TT;>;
MethodParameters:
Name Flags
blockingCodeHandler
public <T> void executeBlocking(io.vertx.core.Handler<io.vertx.core.Promise<T>>, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 4
start local 4 1: aload 4
aload 1
iload 2
aload 3
invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
2: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
0 3 2 ordered Z
0 3 3 asyncResultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
1 3 4 context Lio/vertx/core/impl/ContextInternal;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;ZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
MethodParameters:
Name Flags
blockingCodeHandler
ordered
asyncResultHandler
public <T> void executeBlocking(io.vertx.core.Handler<io.vertx.core.Promise<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iconst_1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 blockingCodeHandler Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;
0 2 2 asyncResultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/Handler<Lio/vertx/core/Promise<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
MethodParameters:
Name Flags
blockingCodeHandler
asyncResultHandler
public boolean isClustered();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
ifnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
public io.netty.channel.EventLoopGroup nettyEventLoopGroup();
descriptor: ()Lio/netty/channel/EventLoopGroup;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.eventLoopGroup:Lio/netty/channel/EventLoopGroup;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public void simulateKill();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
ifnull 2
1: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
invokevirtual io.vertx.core.impl.HAManager.simulateKill:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.impl.Deployment getDeployment(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/impl/Deployment;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
aload 1
invokevirtual io.vertx.core.impl.DeploymentManager.getDeployment:(Ljava/lang/String;)Lio/vertx/core/impl/Deployment;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 deploymentID Ljava/lang/String;
MethodParameters:
Name Flags
deploymentID
public synchronized void failoverCompleteHandler(io.vertx.core.impl.FailoverCompleteHandler);
descriptor: (Lio/vertx/core/impl/FailoverCompleteHandler;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
ifnull 2
1: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
aload 1
invokevirtual io.vertx.core.impl.HAManager.setFailoverCompleteHandler:(Lio/vertx/core/impl/FailoverCompleteHandler;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 failoverCompleteHandler Lio/vertx/core/impl/FailoverCompleteHandler;
MethodParameters:
Name Flags
failoverCompleteHandler
public boolean isKilled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
invokevirtual io.vertx.core.impl.HAManager.isKilled:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public void failDuringFailover(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
ifnull 2
1: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
iload 1
invokevirtual io.vertx.core.impl.HAManager.failDuringFailover:(Z)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 fail Z
MethodParameters:
Name Flags
fail
public io.vertx.core.spi.metrics.VertxMetrics metricsSPI();
descriptor: ()Lio/vertx/core/spi/metrics/VertxMetrics;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public java.io.File resolveFile(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/io/File;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.fileResolver:Lio/vertx/core/file/impl/FileResolver;
aload 1
invokevirtual io.vertx.core.file.impl.FileResolver.resolveFile:(Ljava/lang/String;)Ljava/io/File;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 fileName Ljava/lang/String;
MethodParameters:
Name Flags
fileName
public void resolveAddress(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.net.InetAddress>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.addressResolver:Lio/vertx/core/impl/AddressResolver;
aload 1
aload 2
invokevirtual io.vertx.core.impl.AddressResolver.resolveHostname:(Ljava/lang/String;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 hostname Ljava/lang/String;
0 2 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/net/InetAddress;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/net/InetAddress;>;>;)V
MethodParameters:
Name Flags
hostname
resultHandler
public io.vertx.core.impl.AddressResolver addressResolver();
descriptor: ()Lio/vertx/core/impl/AddressResolver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.addressResolver:Lio/vertx/core/impl/AddressResolver;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.netty.resolver.AddressResolverGroup<java.net.InetSocketAddress> nettyAddressResolverGroup();
descriptor: ()Lio/netty/resolver/AddressResolverGroup;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.addressResolver:Lio/vertx/core/impl/AddressResolver;
invokevirtual io.vertx.core.impl.AddressResolver.nettyAddressResolverGroup:()Lio/netty/resolver/AddressResolverGroup;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Lio/netty/resolver/AddressResolverGroup<Ljava/net/InetSocketAddress;>;
public io.vertx.core.impl.BlockedThreadChecker blockedThreadChecker();
descriptor: ()Lio/vertx/core/impl/BlockedThreadChecker;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
private void deleteCacheDirAndShutdown(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$21(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$22(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
2: invokevirtual io.vertx.core.impl.VertxImpl.executeBlockingInternal:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.impl.HAManager haManager();
descriptor: ()Lio/vertx/core/impl/HAManager;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.haManager:Lio/vertx/core/impl/HAManager;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
public io.vertx.core.impl.WorkerExecutorImpl createSharedWorkerExecutor(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/impl/WorkerExecutorImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 0
getfield io.vertx.core.impl.VertxImpl.defaultWorkerPoolSize:I
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;I)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 name Ljava/lang/String;
MethodParameters:
Name Flags
name
public io.vertx.core.impl.WorkerExecutorImpl createSharedWorkerExecutor(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lio/vertx/core/impl/WorkerExecutorImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
aload 0
getfield io.vertx.core.impl.VertxImpl.maxWorkerExecTime:J
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJ)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 name Ljava/lang/String;
0 1 2 poolSize I
MethodParameters:
Name Flags
name
poolSize
public synchronized io.vertx.core.impl.WorkerExecutorImpl createSharedWorkerExecutor(java.lang.String, int, long);
descriptor: (Ljava/lang/String;IJ)Lio/vertx/core/impl/WorkerExecutorImpl;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
lload 3
aload 0
getfield io.vertx.core.impl.VertxImpl.maxWorkerExecTimeUnit:Ljava/util/concurrent/TimeUnit;
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 1 name Ljava/lang/String;
0 1 2 poolSize I
0 1 3 maxExecuteTime J
MethodParameters:
Name Flags
name
poolSize
maxExecuteTime
public synchronized io.vertx.core.impl.WorkerExecutorImpl createSharedWorkerExecutor(java.lang.String, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerExecutorImpl;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=10, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 0
aload 1
iload 2
lload 3
aload 5
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerPool:(Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;
astore 6
start local 6 1: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getContext:()Lio/vertx/core/impl/AbstractContext;
astore 7
start local 7 2: aload 7
ifnull 3
aload 7
invokevirtual io.vertx.core.impl.AbstractContext.closeHooks:()Lio/vertx/core/impl/CloseHooks;
goto 4
StackMap locals: io.vertx.core.impl.VertxImpl$SharedWorkerPool io.vertx.core.impl.AbstractContext
StackMap stack:
3: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.impl.CloseHooks
4: astore 8
start local 8 5: aload 8
ifnonnull 7
6: aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
astore 8
7: StackMap locals: io.vertx.core.impl.CloseHooks
StackMap stack:
new io.vertx.core.impl.WorkerExecutorImpl
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
aload 6
invokespecial io.vertx.core.impl.WorkerExecutorImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/impl/CloseHooks;Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;)V
astore 9
start local 9 8: aload 8
aload 9
invokevirtual io.vertx.core.impl.CloseHooks.add:(Lio/vertx/core/Closeable;)V
9: aload 9
areturn
end local 9 end local 8 end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/impl/VertxImpl;
0 10 1 name Ljava/lang/String;
0 10 2 poolSize I
0 10 3 maxExecuteTime J
0 10 5 maxExecuteTimeUnit Ljava/util/concurrent/TimeUnit;
1 10 6 sharedWorkerPool Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;
2 10 7 ctx Lio/vertx/core/impl/AbstractContext;
5 10 8 hooks Lio/vertx/core/impl/CloseHooks;
8 10 9 namedExec Lio/vertx/core/impl/WorkerExecutorImpl;
MethodParameters:
Name Flags
name
poolSize
maxExecuteTime
maxExecuteTimeUnit
public synchronized io.vertx.core.impl.VertxImpl$SharedWorkerPool createSharedWorkerPool(java.lang.String, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=9, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: iload 2
iconst_1
if_icmpge 2
1: new java.lang.IllegalArgumentException
dup
ldc "poolSize must be > 0"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
lload 3
lconst_1
lcmp
ifge 4
3: new java.lang.IllegalArgumentException
dup
ldc "maxExecuteTime must be > 0"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.impl.VertxImpl.namedWorkerPools:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.impl.VertxImpl$SharedWorkerPool
astore 6
start local 6 5: aload 6
ifnonnull 12
6: iload 2
new io.vertx.core.impl.VertxThreadFactory
dup
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 0
getfield io.vertx.core.impl.VertxImpl.checker:Lio/vertx/core/impl/BlockedThreadChecker;
iconst_1
lload 3
aload 5
invokespecial io.vertx.core.impl.VertxThreadFactory.<init>:(Ljava/lang/String;Lio/vertx/core/impl/BlockedThreadChecker;ZJLjava/util/concurrent/TimeUnit;)V
invokestatic java.util.concurrent.Executors.newFixedThreadPool:(ILjava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ExecutorService;
astore 7
start local 7 7: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
ifnull 8
aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
ldc "worker"
aload 1
iload 2
invokeinterface io.vertx.core.spi.metrics.VertxMetrics.createPoolMetrics:(Ljava/lang/String;Ljava/lang/String;I)Lio/vertx/core/spi/metrics/PoolMetrics;
goto 9
StackMap locals: io.vertx.core.impl.VertxImpl$SharedWorkerPool java.util.concurrent.ExecutorService
StackMap stack:
8: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.spi.metrics.PoolMetrics
9: astore 8
start local 8 10: aload 0
getfield io.vertx.core.impl.VertxImpl.namedWorkerPools:Ljava/util/Map;
aload 1
new io.vertx.core.impl.VertxImpl$SharedWorkerPool
dup
aload 0
aload 1
aload 7
aload 8
invokespecial io.vertx.core.impl.VertxImpl$SharedWorkerPool.<init>:(Lio/vertx/core/impl/VertxImpl;Ljava/lang/String;Ljava/util/concurrent/ExecutorService;Lio/vertx/core/spi/metrics/PoolMetrics;)V
dup
astore 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 8 end local 7 11: goto 13
12: StackMap locals:
StackMap stack:
aload 6
dup
getfield io.vertx.core.impl.VertxImpl$SharedWorkerPool.refCount:I
iconst_1
iadd
putfield io.vertx.core.impl.VertxImpl$SharedWorkerPool.refCount:I
13: StackMap locals:
StackMap stack:
aload 6
areturn
end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/impl/VertxImpl;
0 14 1 name Ljava/lang/String;
0 14 2 poolSize I
0 14 3 maxExecuteTime J
0 14 5 maxExecuteTimeUnit Ljava/util/concurrent/TimeUnit;
5 14 6 sharedWorkerPool Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;
7 11 7 workerExec Ljava/util/concurrent/ExecutorService;
10 11 8 workerMetrics Lio/vertx/core/spi/metrics/PoolMetrics;
MethodParameters:
Name Flags
name
poolSize
maxExecuteTime
maxExecuteTimeUnit
public io.vertx.core.Vertx exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/Vertx;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.impl.VertxImpl.exceptionHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/core/Vertx;
MethodParameters:
Name Flags
handler
public io.vertx.core.Handler<java.lang.Throwable> exceptionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.impl.VertxImpl.exceptionHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
public void addCloseHook(io.vertx.core.Closeable);
descriptor: (Lio/vertx/core/Closeable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
aload 1
invokevirtual io.vertx.core.impl.CloseHooks.add:(Lio/vertx/core/Closeable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 hook Lio/vertx/core/Closeable;
MethodParameters:
Name Flags
hook
public void removeCloseHook(io.vertx.core.Closeable);
descriptor: (Lio/vertx/core/Closeable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
aload 1
invokevirtual io.vertx.core.impl.CloseHooks.remove:(Lio/vertx/core/Closeable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 1 hook Lio/vertx/core/Closeable;
MethodParameters:
Name Flags
hook
private io.vertx.core.impl.CloseHooks resolveHooks();
descriptor: ()Lio/vertx/core/impl/CloseHooks;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getContext:()Lio/vertx/core/impl/AbstractContext;
astore 1
start local 1 1: aload 1
ifnull 2
aload 1
invokevirtual io.vertx.core.impl.AbstractContext.closeHooks:()Lio/vertx/core/impl/CloseHooks;
goto 3
StackMap locals: io.vertx.core.impl.AbstractContext
StackMap stack:
2: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.impl.CloseHooks
3: astore 2
start local 2 4: aload 2
ifnonnull 6
5: aload 0
getfield io.vertx.core.impl.VertxImpl.closeHooks:Lio/vertx/core/impl/CloseHooks;
astore 2
6: StackMap locals: io.vertx.core.impl.CloseHooks
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/impl/VertxImpl;
1 7 1 context Lio/vertx/core/impl/AbstractContext;
4 7 2 hooks Lio/vertx/core/impl/CloseHooks;
public io.vertx.core.impl.ContextInternal getContext();
descriptor: ()Lio/vertx/core/impl/ContextInternal;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getContext:()Lio/vertx/core/impl/AbstractContext;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.impl.WorkerPool createSharedWorkerPool(java.lang.String, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerPool;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=6, locals=6, args_size=5
0: aload 0
aload 1
iload 2
lload 3
aload 5
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerPool:(Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.WorkerExecutor createSharedWorkerExecutor(java.lang.String, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/WorkerExecutor;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=6, locals=6, args_size=5
0: aload 0
aload 1
iload 2
lload 3
aload 5
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.impl.WorkerExecutorInternal createSharedWorkerExecutor(java.lang.String, int, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerExecutorInternal;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=6, locals=6, args_size=5
0: aload 0
aload 1
iload 2
lload 3
aload 5
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJLjava/util/concurrent/TimeUnit;)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.WorkerExecutor createSharedWorkerExecutor(java.lang.String, int, long);
descriptor: (Ljava/lang/String;IJ)Lio/vertx/core/WorkerExecutor;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
0: aload 0
aload 1
iload 2
lload 3
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJ)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.impl.WorkerExecutorInternal createSharedWorkerExecutor(java.lang.String, int, long);
descriptor: (Ljava/lang/String;IJ)Lio/vertx/core/impl/WorkerExecutorInternal;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
0: aload 0
aload 1
iload 2
lload 3
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;IJ)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.WorkerExecutor createSharedWorkerExecutor(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lio/vertx/core/WorkerExecutor;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
iload 2
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;I)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.impl.WorkerExecutorInternal createSharedWorkerExecutor(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lio/vertx/core/impl/WorkerExecutorInternal;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
iload 2
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;I)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.WorkerExecutor createSharedWorkerExecutor(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/WorkerExecutor;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.impl.WorkerExecutorInternal createSharedWorkerExecutor(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/impl/WorkerExecutorInternal;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.createSharedWorkerExecutor:(Ljava/lang/String;)Lio/vertx/core/impl/WorkerExecutorImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Context getOrCreateContext();
descriptor: ()Lio/vertx/core/Context;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$0(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
ifnull 3
2: aload 0
getfield io.vertx.core.impl.VertxImpl.metrics:Lio/vertx/core/spi/metrics/VertxMetrics;
aload 0
invokeinterface io.vertx.core.spi.metrics.VertxMetrics.vertxCreated:(Lio/vertx/core/Vertx;)V
3: StackMap locals:
StackMap stack:
aload 1
aload 0
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: goto 7
5: StackMap locals:
StackMap stack:
getstatic io.vertx.core.impl.VertxImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failed to initialize clustered Vert.x"
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
6: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.close:()Lio/vertx/core/Future;
aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$1(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/impl/VertxImpl;
0 8 2 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$2(io.vertx.core.VertxOptions, io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
aload 1
aload 2
invokevirtual io.vertx.core.impl.VertxImpl.createHaManager:(Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 2
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 3 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$3(io.vertx.core.VertxOptions, io.vertx.core.Promise);
descriptor: (Lio/vertx/core/VertxOptions;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=10, locals=5, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
ldc "__vertx.haInfo"
invokeinterface io.vertx.core.spi.cluster.ClusterManager.getSyncMap:(Ljava/lang/String;)Ljava/util/Map;
astore 3
start local 3 1: new io.vertx.core.impl.HAManager
dup
aload 0
aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
aload 0
getfield io.vertx.core.impl.VertxImpl.verticleManager:Lio/vertx/core/impl/VerticleManager;
aload 0
getfield io.vertx.core.impl.VertxImpl.clusterManager:Lio/vertx/core/spi/cluster/ClusterManager;
aload 3
aload 1
invokevirtual io.vertx.core.VertxOptions.getQuorumSize:()I
aload 1
invokevirtual io.vertx.core.VertxOptions.getHAGroup:()Ljava/lang/String;
aload 1
invokevirtual io.vertx.core.VertxOptions.isHAEnabled:()Z
invokespecial io.vertx.core.impl.HAManager.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/impl/DeploymentManager;Lio/vertx/core/impl/VerticleManager;Lio/vertx/core/spi/cluster/ClusterManager;Ljava/util/Map;ILjava/lang/String;Z)V
astore 4
start local 4 2: aload 2
aload 4
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 4 end local 3 3: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 2 fut Lio/vertx/core/Promise<Lio/vertx/core/impl/HAManager;>;
1 3 3 syncMap Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
2 3 4 haManager Lio/vertx/core/impl/HAManager;
private void lambda$4(io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.impl.HAManager
putfield io.vertx.core.impl.VertxImpl.haManager:Lio/vertx/core/impl/HAManager;
2: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.startEventBus:(Lio/vertx/core/Promise;)V
3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
5: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/impl/VertxImpl;
0 6 2 ar Lio/vertx/core/AsyncResult<Lio/vertx/core/impl/HAManager;>;
private void lambda$5(io.vertx.core.Promise, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.initializeHaManager:(Lio/vertx/core/Promise;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 2 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$6(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.haManager:Lio/vertx/core/impl/HAManager;
invokevirtual io.vertx.core.impl.HAManager.init:()V
1: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/impl/VertxImpl;
0 3 1 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
private static void lambda$7(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 2
1: getstatic io.vertx.core.impl.VertxImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failed to leave cluster"
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
aload 0
ifnull 4
3: aload 0
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$8(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
invokevirtual io.vertx.core.impl.DeploymentManager.undeployAll:()Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$9(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 2 ar Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private static io.vertx.core.Verticle lambda$16(io.vertx.core.Verticle);
descriptor: (Lio/vertx/core/Verticle;)Lio/vertx/core/Verticle;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
private static void lambda$19(io.vertx.core.impl.HAManager, java.lang.String, io.vertx.core.Promise);
descriptor: (Lio/vertx/core/impl/HAManager;Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.impl.HAManager.removeFromHA:(Ljava/lang/String;)V
1: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
private io.vertx.core.Future lambda$20(java.lang.String, java.lang.Void);
descriptor: (Ljava/lang/String;Ljava/lang/Void;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.deploymentManager:Lio/vertx/core/impl/DeploymentManager;
aload 1
invokevirtual io.vertx.core.impl.DeploymentManager.undeployVerticle:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/impl/VertxImpl;
0 1 2 v Ljava/lang/Void;
private void lambda$21(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.impl.VertxImpl.fileResolver:Lio/vertx/core/file/impl/FileResolver;
invokevirtual io.vertx.core.file.impl.FileResolver.close:()V
1: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 5
StackMap locals:
StackMap stack: java.io.IOException
3: astore 2
start local 2 4: aload 1
aload 2
invokeinterface io.vertx.core.Promise.tryFail:(Ljava/lang/Throwable;)Z
pop
end local 2 5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/impl/VertxImpl;
0 6 1 fut Lio/vertx/core/Promise<Ljava/lang/Object;>;
4 5 2 e Ljava/io/IOException;
Exception table:
from to target type
0 2 3 Class java.io.IOException
private void lambda$22(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.workerPool:Lio/vertx/core/impl/WorkerPool;
invokevirtual io.vertx.core.impl.WorkerPool.close:()V
1: aload 0
getfield io.vertx.core.impl.VertxImpl.internalBlockingPool:Lio/vertx/core/impl/WorkerPool;
invokevirtual io.vertx.core.impl.WorkerPool.close:()V
2: new java.util.ArrayList
dup
aload 0
getfield io.vertx.core.impl.VertxImpl.namedWorkerPools:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/WorkerPool.close()V (5)
(Lio/vertx/core/impl/VertxImpl$SharedWorkerPool;)V
invokevirtual java.util.ArrayList.forEach:(Ljava/util/function/Consumer;)V
3: aload 0
getfield io.vertx.core.impl.VertxImpl.acceptorEventLoopGroup:Lio/netty/channel/EventLoopGroup;
lconst_0
ldc 10
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface io.netty.channel.EventLoopGroup.shutdownGracefully:(JJLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/Future;
new io.vertx.core.impl.VertxImpl$3
dup
aload 0
aload 1
invokespecial io.vertx.core.impl.VertxImpl$3.<init>:(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)V
invokeinterface io.netty.util.concurrent.Future.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/util/concurrent/Future;
pop
4: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/impl/VertxImpl;
0 5 2 ar Lio/vertx/core/AsyncResult<Ljava/lang/Object;>;
private static void lambda$1(io.vertx.core.Handler, io.vertx.core.AsyncResult, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 ignore Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$9(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 2 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.haManager:()Lio/vertx/core/impl/HAManager;
astore 3
start local 3 1: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 4
start local 4 2: aload 3
ifnull 7
3: aload 0
aload 3
invokedynamic handle(Lio/vertx/core/impl/HAManager;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$10(Lio/vertx/core/impl/HAManager;Lio/vertx/core/Promise;)V (6)
(Lio/vertx/core/Promise;)V
4: iconst_0
aload 4
5: invokevirtual io.vertx.core.impl.VertxImpl.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
6: goto 8
7: StackMap locals: io.vertx.core.impl.HAManager io.vertx.core.Promise
StackMap stack:
aload 4
invokeinterface io.vertx.core.Promise.complete:()V
8: StackMap locals:
StackMap stack:
aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$11(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 4 end local 3 9: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/impl/VertxImpl;
0 10 2 ar1 Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
1 9 3 haManager Lio/vertx/core/impl/HAManager;
2 9 4 haPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
private static void lambda$10(io.vertx.core.impl.HAManager, io.vertx.core.Promise);
descriptor: (Lio/vertx/core/impl/HAManager;Lio/vertx/core/Promise;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokevirtual io.vertx.core.impl.HAManager.stop:()V
1: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
private void lambda$11(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.core.impl.VertxImpl.addressResolver:Lio/vertx/core/impl/AddressResolver;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$12(Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.core.impl.AddressResolver.close:(Lio/vertx/core/Handler;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 2 ar2 Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$12(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 2 0: aload 0
invokevirtual io.vertx.core.impl.VertxImpl.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 1: aload 0
getfield io.vertx.core.impl.VertxImpl.eventBus:Lio/vertx/core/eventbus/impl/EventBusInternal;
aload 3
invokeinterface io.vertx.core.eventbus.impl.EventBusInternal.close:(Lio/vertx/core/Promise;)V
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$13(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 3 3: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/impl/VertxImpl;
0 4 2 ar3 Ljava/lang/Void;
1 3 3 ebClose Lio/vertx/core/Promise<Ljava/lang/Void;>;
private void lambda$13(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/impl/VertxImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/impl/VertxImpl.lambda$14(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.core.impl.VertxImpl.closeClusterManager:(Lio/vertx/core/Handler;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 2 ar4 Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$14(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.impl.VertxImpl.deleteCacheDirAndShutdown:(Lio/vertx/core/Handler;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/impl/VertxImpl;
0 2 2 ar5 Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
}
SourceFile: "VertxImpl.java"
NestMembers:
io.vertx.core.impl.VertxImpl$1 io.vertx.core.impl.VertxImpl$1$1 io.vertx.core.impl.VertxImpl$2 io.vertx.core.impl.VertxImpl$2$1 io.vertx.core.impl.VertxImpl$3 io.vertx.core.impl.VertxImpl$3$1 io.vertx.core.impl.VertxImpl$InternalTimerHandler io.vertx.core.impl.VertxImpl$SharedWorkerPool io.vertx.core.impl.VertxImpl$TimeoutStreamImpl
InnerClasses:
public final Level = io.netty.util.ResourceLeakDetector$Level of io.netty.util.ResourceLeakDetector
io.vertx.core.impl.VertxImpl$3
private InternalTimerHandler = io.vertx.core.impl.VertxImpl$InternalTimerHandler of io.vertx.core.impl.VertxImpl
SharedWorkerPool = io.vertx.core.impl.VertxImpl$SharedWorkerPool of io.vertx.core.impl.VertxImpl
private TimeoutStreamImpl = io.vertx.core.impl.VertxImpl$TimeoutStreamImpl of io.vertx.core.impl.VertxImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
VertxImpl
log: Logger
workerPool: WorkerPool
getFileSystem(): FileSystem
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)