public class io.vertx.spi.cluster.ignite.IgniteClusterManager implements io.vertx.core.spi.cluster.ClusterManager
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.spi.cluster.ignite.IgniteClusterManager
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 DEFAULT_CONFIG_FILE;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "default-ignite.json"
private static final java.lang.String CONFIG_FILE;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "ignite.json"
private static final java.lang.String XML_CONFIG_FILE;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "ignite.xml"
private static final java.lang.String VERTX_NODE_PREFIX;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "vertx.ignite.node."
private static final java.lang.String LOCK_SEMAPHORE_PREFIX;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "__vertx."
private static final javax.cache.expiry.ExpiryPolicy DEFAULT_EXPIRY_POLICY;
descriptor: Ljavax/cache/expiry/ExpiryPolicy;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final int[] IGNITE_EVENTS;
descriptor: [I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.spi.cluster.NodeSelector nodeSelector;
descriptor: Lio/vertx/core/spi/cluster/NodeSelector;
flags: (0x0002) ACC_PRIVATE
private org.apache.ignite.configuration.IgniteConfiguration cfg;
descriptor: Lorg/apache/ignite/configuration/IgniteConfiguration;
flags: (0x0002) ACC_PRIVATE
private org.apache.ignite.Ignite ignite;
descriptor: Lorg/apache/ignite/Ignite;
flags: (0x0002) ACC_PRIVATE
private boolean customIgnite;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean shutdownOnSegmentation;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.lang.String nodeId;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.spi.cluster.NodeInfo nodeInfo;
descriptor: Lio/vertx/core/spi/cluster/NodeInfo;
flags: (0x0002) ACC_PRIVATE
private org.apache.ignite.IgniteCache<java.lang.String, io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo> nodeInfoMap;
descriptor: Lorg/apache/ignite/IgniteCache;
flags: (0x0002) ACC_PRIVATE
Signature: Lorg/apache/ignite/IgniteCache<Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;>;
private io.vertx.spi.cluster.ignite.impl.SubsMapHelper subsMapHelper;
descriptor: Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.spi.cluster.NodeListener nodeListener;
descriptor: Lio/vertx/core/spi/cluster/NodeListener;
flags: (0x0002) ACC_PRIVATE
private org.apache.ignite.lang.IgnitePredicate<org.apache.ignite.events.Event> eventListener;
descriptor: Lorg/apache/ignite/lang/IgnitePredicate;
flags: (0x0002) ACC_PRIVATE
Signature: Lorg/apache/ignite/lang/IgnitePredicate<Lorg/apache/ignite/events/Event;>;
private volatile boolean active;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.lang.Object monitor;
descriptor: Ljava/lang/Object;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.util.concurrent.ExecutorService lockReleaseExec;
descriptor: Ljava/util/concurrent/ExecutorService;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: ldc Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
1: new io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy
dup
invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy.<init>:()V
putstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.DEFAULT_EXPIRY_POLICY:Ljavax/cache/expiry/ExpiryPolicy;
2: iconst_4
newarray 10
dup
iconst_0
bipush 10
iastore
dup
iconst_1
bipush 11
iastore
dup
iconst_2
bipush 12
iastore
dup
iconst_3
bipush 14
iastore
putstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.IGNITE_EVENTS:[I
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=2, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
2: ldc "IGNITE_NO_SHUTDOWN_HOOK"
ldc "true"
invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
pop
3: getstatic org.apache.ignite.internal.IgniteComponentType.SPRING:Lorg/apache/ignite/internal/IgniteComponentType;
invokevirtual org.apache.ignite.internal.IgniteComponentType.inClassPath:()Z
ifeq 8
4: aload 0
aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
iconst_1
anewarray java.lang.String
dup
iconst_0
ldc "ignite.xml"
aastore
invokestatic io.vertx.spi.cluster.ignite.util.ConfigHelper.lookupXmlConfiguration:(Ljava/lang/Class;[Ljava/lang/String;)Lorg/apache/ignite/configuration/IgniteConfiguration;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
5: goto 8
StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager
StackMap stack: io.vertx.core.VertxException
6: pop
7: getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "xml config could not be loaded"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
ifnonnull 14
9: new io.vertx.spi.cluster.ignite.IgniteOptions
dup
aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "ignite.json"
aastore
dup
iconst_1
ldc "default-ignite.json"
aastore
invokestatic io.vertx.spi.cluster.ignite.util.ConfigHelper.lookupJsonConfiguration:(Ljava/lang/Class;[Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
invokespecial io.vertx.spi.cluster.ignite.IgniteOptions.<init>:(Lio/vertx/core/json/JsonObject;)V
astore 1
start local 1 10: aload 0
aload 1
invokevirtual io.vertx.spi.cluster.ignite.IgniteOptions.isShutdownOnSegmentation:()Z
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.shutdownOnSegmentation:Z
11: aload 0
aload 1
invokevirtual io.vertx.spi.cluster.ignite.IgniteOptions.toConfig:()Lorg/apache/ignite/configuration/IgniteConfiguration;
12: new io.vertx.spi.cluster.ignite.impl.VertxLogger
dup
invokespecial io.vertx.spi.cluster.ignite.impl.VertxLogger.<init>:()V
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setGridLogger:(Lorg/apache/ignite/IgniteLogger;)Lorg/apache/ignite/configuration/IgniteConfiguration;
13: putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
end local 1 14: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeId:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
15: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
10 14 1 options Lio/vertx/spi/cluster/ignite/IgniteOptions;
Exception table:
from to target type
4 5 6 Class io.vertx.core.VertxException
public void <init>(org.apache.ignite.configuration.IgniteConfiguration);
descriptor: (Lorg/apache/ignite/configuration/IgniteConfiguration;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
2: ldc "IGNITE_NO_SHUTDOWN_HOOK"
ldc "true"
invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
pop
3: aload 0
aload 1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
4: aload 0
aload 1
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeId:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 6 1 cfg Lorg/apache/ignite/configuration/IgniteConfiguration;
MethodParameters:
Name Flags
cfg
public void <init>(java.net.URL);
descriptor: (Ljava/net/URL;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
2: ldc "IGNITE_NO_SHUTDOWN_HOOK"
ldc "true"
invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
pop
3: aload 0
aload 1
invokestatic io.vertx.spi.cluster.ignite.util.ConfigHelper.loadConfiguration:(Ljava/net/URL;)Lorg/apache/ignite/configuration/IgniteConfiguration;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
4: aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeId:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 6 1 configFile Ljava/net/URL;
MethodParameters:
Name Flags
configFile
public void <init>(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
2: ldc "IGNITE_NO_SHUTDOWN_HOOK"
ldc "true"
invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
pop
3: new io.vertx.spi.cluster.ignite.IgniteOptions
dup
aload 1
invokespecial io.vertx.spi.cluster.ignite.IgniteOptions.<init>:(Lio/vertx/core/json/JsonObject;)V
astore 2
start local 2 4: aload 0
aload 2
invokevirtual io.vertx.spi.cluster.ignite.IgniteOptions.isShutdownOnSegmentation:()Z
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.shutdownOnSegmentation:Z
5: aload 0
aload 2
invokevirtual io.vertx.spi.cluster.ignite.IgniteOptions.toConfig:()Lorg/apache/ignite/configuration/IgniteConfiguration;
6: new io.vertx.spi.cluster.ignite.impl.VertxLogger
dup
invokespecial io.vertx.spi.cluster.ignite.impl.VertxLogger.<init>:()V
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setGridLogger:(Lorg/apache/ignite/IgniteLogger;)Lorg/apache/ignite/configuration/IgniteConfiguration;
7: putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
8: aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeId:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
9: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 10 1 jsonConfig Lio/vertx/core/json/JsonObject;
4 10 2 options Lio/vertx/spi/cluster/ignite/IgniteOptions;
MethodParameters:
Name Flags
jsonConfig
public void <init>(org.apache.ignite.Ignite);
descriptor: (Lorg/apache/ignite/Ignite;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
2: aload 1
ldc "Ignite instance can't be null."
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
4: aload 0
iconst_1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 6 1 ignite Lorg/apache/ignite/Ignite;
MethodParameters:
Name Flags
ignite
public org.apache.ignite.Ignite getIgniteInstance();
descriptor: ()Lorg/apache/ignite/Ignite;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
public void init(io.vertx.core.Vertx, io.vertx.core.spi.cluster.NodeSelector);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/spi/cluster/NodeSelector;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
1: aload 0
aload 2
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 3 1 vertx Lio/vertx/core/Vertx;
0 3 2 nodeSelector Lio/vertx/core/spi/cluster/NodeSelector;
MethodParameters:
Name Flags
vertx
nodeSelector
public void nodeListener(io.vertx.core.spi.cluster.NodeListener);
descriptor: (Lio/vertx/core/spi/cluster/NodeListener;)V
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.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 2 1 nodeListener Lio/vertx/core/spi/cluster/NodeListener;
MethodParameters:
Name Flags
nodeListener
public <K, V> void getAsyncMap(java.lang.String, io.vertx.core.Promise<io.vertx.core.shareddata.AsyncMap<K, V>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)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.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;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/spi/cluster/ignite/IgniteClusterManager.lambda$0(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
aload 2
invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;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/spi/cluster/ignite/IgniteClusterManager;
0 2 1 name Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;)V
MethodParameters:
Name Flags
name
promise
public <K, V> java.util.Map<K, V> getSyncMap(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.vertx.spi.cluster.ignite.impl.MapImpl
dup
aload 0
aload 1
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
invokespecial io.vertx.spi.cluster.ignite.impl.MapImpl.<init>:(Lorg/apache/ignite/IgniteCache;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 1 1 name Ljava/lang/String;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;)Ljava/util/Map<TK;TV;>;
MethodParameters:
Name Flags
name
public void getLockWithTimeout(java.lang.String, long, io.vertx.core.Promise<io.vertx.core.shareddata.Lock>);
descriptor: (Ljava/lang/String;JLio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
lload 2
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;J)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/spi/cluster/ignite/IgniteClusterManager.lambda$1(Ljava/lang/String;JLio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 4
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 4 1 name Ljava/lang/String;
0 4 2 timeout J
0 4 4 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
Signature: (Ljava/lang/String;JLio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;)V
MethodParameters:
Name Flags
name
timeout
promise
public void getCounter(java.lang.String, io.vertx.core.Promise<io.vertx.core.shareddata.Counter>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)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.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;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/spi/cluster/ignite/IgniteClusterManager.lambda$2(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
aload 2
invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;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/spi/cluster/ignite/IgniteClusterManager;
0 2 1 name Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;)V
MethodParameters:
Name Flags
name
promise
public java.lang.String getNodeId();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
public void setNodeInfo(io.vertx.core.spi.cluster.NodeInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/spi/cluster/NodeInfo;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 3
monitorenter
1: aload 0
aload 1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfo:Lio/vertx/core/spi/cluster/NodeInfo;
2: aload 3
monitorexit
3: goto 6
StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.spi.cluster.NodeInfo io.vertx.core.Promise io.vertx.spi.cluster.ignite.IgniteClusterManager
StackMap stack: java.lang.Throwable
4: aload 3
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
new io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo
dup
aload 1
invokespecial io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo.<init>:(Lio/vertx/core/spi/cluster/NodeInfo;)V
astore 3
start local 3 7: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 3
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;)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/spi/cluster/ignite/IgniteClusterManager.lambda$3(Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
8: iconst_0
aload 2
9: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
10: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 11 1 nodeInfo Lio/vertx/core/spi/cluster/NodeInfo;
0 11 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
7 11 3 value Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Lio/vertx/core/spi/cluster/NodeInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
nodeInfo
promise
public synchronized io.vertx.core.spi.cluster.NodeInfo getNodeInfo();
descriptor: ()Lio/vertx/core/spi/cluster/NodeInfo;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfo:Lio/vertx/core/spi/cluster/NodeInfo;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
public void getNodeInfo(java.lang.String, io.vertx.core.Promise<io.vertx.core.spi.cluster.NodeInfo>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfoMap:Lorg/apache/ignite/IgniteCache;
aload 1
invokeinterface org.apache.ignite.IgniteCache.getAsync:(Ljava/lang/Object;)Lorg/apache/ignite/lang/IgniteFuture;
aload 2
invokedynamic apply(Lio/vertx/core/Promise;)Lorg/apache/ignite/lang/IgniteInClosure;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$4(Lio/vertx/core/Promise;Lorg/apache/ignite/lang/IgniteFuture;)V (6)
(Lorg/apache/ignite/lang/IgniteFuture;)V
1
invokeinterface org.apache.ignite.lang.IgniteFuture.listen:(Lorg/apache/ignite/lang/IgniteInClosure;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 2 1 id Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/NodeInfo;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/NodeInfo;>;)V
MethodParameters:
Name Flags
id
promise
public java.util.List<java.lang.String> getNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.Ignite.cluster:()Lorg/apache/ignite/IgniteCluster;
invokeinterface org.apache.ignite.IgniteCluster.nodes:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
1: 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/spi/cluster/ignite/IgniteClusterManager.nodeId(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String; (6)
(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
2: areturn
3: StackMap locals:
StackMap stack: java.lang.IllegalStateException
astore 1
start local 1 4: getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
aload 1
invokevirtual java.lang.IllegalStateException.getMessage:()Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
5: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
4 6 1 e Ljava/lang/IllegalStateException;
Exception table:
from to target type
0 2 3 Class java.lang.IllegalStateException
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public void join(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)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/spi/cluster/ignite/IgniteClusterManager.lambda$6(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 1
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(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/spi/cluster/ignite/IgniteClusterManager;
0 4 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
promise
public void leave(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)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/spi/cluster/ignite/IgniteClusterManager.lambda$10(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 1
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(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/spi/cluster/ignite/IgniteClusterManager;
0 4 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
promise
public boolean isActive();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
public void addRegistration(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)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/spi/cluster/ignite/IgniteClusterManager.lambda$11(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 3
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: 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/spi/cluster/ignite/IgniteClusterManager;
0 4 1 address Ljava/lang/String;
0 4 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 4 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
address
registrationInfo
promise
public void removeRegistration(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)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/spi/cluster/ignite/IgniteClusterManager.lambda$12(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 3
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: 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/spi/cluster/ignite/IgniteClusterManager;
0 4 1 address Ljava/lang/String;
0 4 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 4 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
address
registrationInfo
promise
public void getRegistrations(java.lang.String, io.vertx.core.Promise<java.util.List<io.vertx.core.spi.cluster.RegistrationInfo>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)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
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;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/spi/cluster/ignite/IgniteClusterManager.lambda$13(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 2
2: invokeinterface io.vertx.core.impl.VertxInternal.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/spi/cluster/ignite/IgniteClusterManager;
0 4 1 address Ljava/lang/String;
0 4 2 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;)V
MethodParameters:
Name Flags
address
promise
private void cleanSubs(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
aload 1
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.removeAllForNode:(Ljava/lang/String;)V
1: goto 3
StackMap locals:
StackMap stack: java.lang.RuntimeException
2: pop
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 4 1 id Ljava/lang/String;
Exception table:
from to target type
0 1 2 Class java.lang.IllegalStateException
0 1 2 Class javax.cache.CacheException
MethodParameters:
Name Flags
id
private boolean cleanNodeInfos(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfoMap:Lorg/apache/ignite/IgniteCache;
aload 1
invokeinterface org.apache.ignite.IgniteCache.remove:(Ljava/lang/Object;)Z
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.RuntimeException
pop
3: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 4 1 nid Ljava/lang/String;
Exception table:
from to target type
0 1 2 Class java.lang.IllegalStateException
0 1 2 Class javax.cache.CacheException
MethodParameters:
Name Flags
nid
private void setNodeId(org.apache.ignite.configuration.IgniteConfiguration);
descriptor: (Lorg/apache/ignite/configuration/IgniteConfiguration;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
astore 2
start local 2 1: aload 1
aload 2
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setNodeId:(Ljava/util/UUID;)Lorg/apache/ignite/configuration/IgniteConfiguration;
pop
2: aload 1
new java.lang.StringBuilder
dup
ldc "vertx.ignite.node."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setIgniteInstanceName:(Ljava/lang/String;)Lorg/apache/ignite/configuration/IgniteConfiguration;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 4 1 cfg Lorg/apache/ignite/configuration/IgniteConfiguration;
1 4 2 uuid Ljava/util/UUID;
MethodParameters:
Name Flags
cfg
private <K, V> org.apache.ignite.IgniteCache<K, V> getCache(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
aload 1
invokeinterface org.apache.ignite.Ignite.getOrCreateCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
astore 2
start local 2 1: aload 2
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.DEFAULT_EXPIRY_POLICY:Ljavax/cache/expiry/ExpiryPolicy;
invokeinterface org.apache.ignite.IgniteCache.withExpiryPolicy:(Ljavax/cache/expiry/ExpiryPolicy;)Lorg/apache/ignite/IgniteCache;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 2 1 name Ljava/lang/String;
1 2 2 cache Lorg/apache/ignite/IgniteCache<TK;TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache<TK;TV;>;
MethodParameters:
Name Flags
name
private static java.lang.String nodeId(org.apache.ignite.cluster.ClusterNode);
descriptor: (Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface org.apache.ignite.cluster.ClusterNode.id:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 node Lorg/apache/ignite/cluster/ClusterNode;
MethodParameters:
Name Flags
node
private void lambda$0(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 2 0: aload 2
new io.vertx.spi.cluster.ignite.impl.AsyncMapImpl
dup
aload 0
aload 1
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
invokespecial io.vertx.spi.cluster.ignite.impl.AsyncMapImpl.<init>:(Lorg/apache/ignite/IgniteCache;Lio/vertx/core/impl/VertxInternal;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 1 2 prom Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;
private void lambda$1(java.lang.String, long, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;JLio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=7, locals=11, args_size=4
start local 0 start local 4 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
new java.lang.StringBuilder
dup
ldc "__vertx."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
iconst_1
iconst_1
iconst_1
invokeinterface org.apache.ignite.Ignite.semaphore:(Ljava/lang/String;IZZ)Lorg/apache/ignite/IgniteSemaphore;
astore 5
start local 5 1: lload 2
lstore 7
start local 7 2: StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager java.lang.String long io.vertx.core.Promise org.apache.ignite.IgniteSemaphore top long
StackMap stack:
invokestatic java.lang.System.nanoTime:()J
lstore 9
start local 9 3: aload 5
lload 7
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.apache.ignite.IgniteSemaphore.tryAcquire:(JLjava/util/concurrent/TimeUnit;)Z
istore 6
start local 6 4: lload 7
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic java.lang.System.nanoTime:()J
lload 9
lsub
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
lsub
lstore 7
end local 9 5: iload 6
ifne 7
lload 7
lconst_0
6: lcmp
ifgt 2
7: StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager java.lang.String long io.vertx.core.Promise org.apache.ignite.IgniteSemaphore int long
StackMap stack:
iload 6
ifeq 10
8: aload 4
new io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl
dup
aload 5
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl.<init>:(Lorg/apache/ignite/IgniteSemaphore;Ljava/util/concurrent/Executor;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
9: goto 11
10: StackMap locals:
StackMap stack:
new io.vertx.core.VertxException
dup
new java.lang.StringBuilder
dup
ldc "Timed out waiting to get lock "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
athrow
end local 7 end local 6 end local 5 11: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 12 4 prom Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
1 11 5 semaphore Lorg/apache/ignite/IgniteSemaphore;
4 11 6 locked Z
2 11 7 remaining J
3 5 9 start J
private void lambda$2(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=9, locals=3, args_size=3
start local 0 start local 2 0: aload 2
new io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl
dup
aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
aload 1
lconst_0
iconst_1
invokeinterface org.apache.ignite.Ignite.atomicLong:(Ljava/lang/String;JZ)Lorg/apache/ignite/IgniteAtomicLong;
invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl.<init>:(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lorg/apache/ignite/IgniteAtomicLong;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 1 2 prom Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;
private void lambda$3(io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo, io.vertx.core.Promise);
descriptor: (Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;Lio/vertx/core/Promise;)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.spi.cluster.ignite.IgniteClusterManager.nodeInfoMap:Lorg/apache/ignite/IgniteCache;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:Ljava/lang/String;
aload 1
invokeinterface org.apache.ignite.IgniteCache.put:(Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 3 2 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
private static void lambda$4(io.vertx.core.Promise, org.apache.ignite.lang.IgniteFuture);
descriptor: (Lio/vertx/core/Promise;Lorg/apache/ignite/lang/IgniteFuture;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 1 0: aload 1
invokeinterface org.apache.ignite.lang.IgniteFuture.get:()Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo
astore 2
start local 2 1: aload 2
ifnull 4
2: aload 0
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo.unwrap:()Lio/vertx/core/spi/cluster/NodeInfo;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
3: goto 8
4: StackMap locals: io.vertx.spi.cluster.ignite.impl.IgniteNodeInfo
StackMap stack:
aload 0
ldc "Not a member of the cluster"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
end local 2 5: goto 8
StackMap locals: io.vertx.core.Promise org.apache.ignite.lang.IgniteFuture
StackMap stack: org.apache.ignite.IgniteException
6: astore 2
start local 2 7: aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 9 1 fut Lorg/apache/ignite/lang/IgniteFuture<Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;>;
1 5 2 value Lio/vertx/spi/cluster/ignite/impl/IgniteNodeInfo;
7 8 2 e Lorg/apache/ignite/IgniteException;
Exception table:
from to target type
0 5 6 Class org.apache.ignite.IgniteException
private void lambda$6(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
ifne 14
2: aload 0
iconst_1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
3: aload 0
invokedynamic newThread()Ljava/util/concurrent/ThreadFactory;
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/Runnable;)Ljava/lang/Thread;
io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$7(Ljava/lang/Runnable;)Ljava/lang/Thread; (6)
(Ljava/lang/Runnable;)Ljava/lang/Thread;
invokestatic java.util.concurrent.Executors.newCachedThreadPool:(Ljava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ExecutorService;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
4: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
ifne 8
5: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
getstatic org.apache.ignite.plugin.segmentation.SegmentationPolicy.NOOP:Lorg/apache/ignite/plugin/segmentation/SegmentationPolicy;
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setSegmentationPolicy:(Lorg/apache/ignite/plugin/segmentation/SegmentationPolicy;)Lorg/apache/ignite/configuration/IgniteConfiguration;
pop
6: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
new org.apache.ignite.failure.StopNodeFailureHandler
dup
invokespecial org.apache.ignite.failure.StopNodeFailureHandler.<init>:()V
invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setFailureHandler:(Lorg/apache/ignite/failure/FailureHandler;)Lorg/apache/ignite/configuration/IgniteConfiguration;
pop
7: aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
invokestatic org.apache.ignite.Ignition.start:(Lorg/apache/ignite/configuration/IgniteConfiguration;)Lorg/apache/ignite/Ignite;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
8: StackMap locals: java.lang.Object
StackMap stack:
aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.Ignite.cluster:()Lorg/apache/ignite/IgniteCluster;
invokeinterface org.apache.ignite.IgniteCluster.localNode:()Lorg/apache/ignite/cluster/ClusterNode;
invokestatic io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:Ljava/lang/String;
9: aload 0
aload 0
invokedynamic apply(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)Lorg/apache/ignite/lang/IgnitePredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$8(Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
10: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.IGNITE_EVENTS:[I
invokeinterface org.apache.ignite.IgniteEvents.localListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)V
11: aload 0
new io.vertx.spi.cluster.ignite.impl.SubsMapHelper
dup
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
invokespecial io.vertx.spi.cluster.ignite.impl.SubsMapHelper.<init>:(Lorg/apache/ignite/Ignite;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)V
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
12: aload 0
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
ldc "__vertx.nodeInfo"
invokeinterface org.apache.ignite.Ignite.getOrCreateCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfoMap:Lorg/apache/ignite/IgniteCache;
13: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
14: StackMap locals:
StackMap stack:
aload 2
monitorexit
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: aload 2
monitorexit
17: athrow
18: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 19 1 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
Exception table:
from to target type
1 15 16 any
16 17 16 any
private void lambda$10(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
ifeq 14
2: aload 0
iconst_0
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
3: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
invokeinterface java.util.concurrent.ExecutorService.shutdown:()V
4: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
ifnull 6
5: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.IGNITE_EVENTS:[I
invokeinterface org.apache.ignite.IgniteEvents.stopLocalListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)Z
pop
6: StackMap locals: java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.leave:(Lorg/apache/ignite/Ignite;)V
7: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
ifne 12
8: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.Ignite.close:()V
9: goto 12
StackMap locals:
StackMap stack: java.lang.Exception
10: astore 3
start local 3 11: getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
aload 3
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
end local 3 12: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
13: aload 0
aconst_null
putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeInfoMap:Lorg/apache/ignite/IgniteCache;
14: StackMap locals:
StackMap stack:
aload 2
monitorexit
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: aload 2
monitorexit
17: athrow
18: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.Promise.complete:()V
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 20 1 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
11 12 3 e Ljava/lang/Exception;
Exception table:
from to target type
4 9 10 Class java.lang.Exception
1 15 16 any
16 17 16 any
private void lambda$11(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
aload 1
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.put:(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Lio/vertx/core/Future;
1: aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
2: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 3 3 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
private void lambda$12(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
aload 1
aload 2
aload 3
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.remove:(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
1: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 2 3 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
private void lambda$13(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)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.spi.cluster.ignite.IgniteClusterManager.subsMapHelper:Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
aload 1
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.get:(Ljava/lang/String;Lio/vertx/core/Promise;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 2 2 prom Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
private static java.lang.Thread lambda$7(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Ljava/lang/Thread;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new java.lang.Thread
dup
aload 0
ldc "vertx-ignite-service-release-lock-thread"
invokespecial java.lang.Thread.<init>:(Ljava/lang/Runnable;Ljava/lang/String;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 r Ljava/lang/Runnable;
private boolean lambda$8(org.apache.ignite.events.Event);
descriptor: (Lorg/apache/ignite/events/Event;)Z
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.isActive:()Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lorg/apache/ignite/events/Event;)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/spi/cluster/ignite/IgniteClusterManager.lambda$9(Lorg/apache/ignite/events/Event;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
3: aconst_null
4: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
5: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 6 1 event Lorg/apache/ignite/events/Event;
private void lambda$9(org.apache.ignite.events.Event, io.vertx.core.Promise);
descriptor: (Lorg/apache/ignite/events/Event;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 2 0: aload 1
checkcast org.apache.ignite.events.DiscoveryEvent
invokevirtual org.apache.ignite.events.DiscoveryEvent.eventNode:()Lorg/apache/ignite/cluster/ClusterNode;
invokestatic io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
astore 3
start local 3 1: aload 1
invokeinterface org.apache.ignite.events.Event.type:()I
tableswitch { // 10 - 14
10: 2
11: 7
12: 7
13: 23
14: 16
default: 23
}
2: StackMap locals: java.lang.String
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 4
3: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
aload 3
invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeAdded:(Ljava/lang/String;)V
4: StackMap locals:
StackMap stack:
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
new java.lang.StringBuilder
dup
ldc "node "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " joined the cluster"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
5: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
6: goto 24
7: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.cleanNodeInfos:(Ljava/lang/String;)Z
ifeq 9
8: aload 0
aload 3
invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.cleanSubs:(Ljava/lang/String;)V
9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 13
10: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
aload 3
invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeLeft:(Ljava/lang/String;)V
11: goto 13
StackMap locals:
StackMap stack: java.lang.Exception
12: pop
13: StackMap locals:
StackMap stack:
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
new java.lang.StringBuilder
dup
ldc "node "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " left the cluster"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
14: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
15: goto 24
16: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
ifne 17
aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.shutdownOnSegmentation:Z
ifne 19
17: StackMap locals:
StackMap stack:
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "node got segmented"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
18: goto 21
19: StackMap locals:
StackMap stack:
getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "node got segmented and will be shut down"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
20: aload 0
getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.close:()Lio/vertx/core/Future;
pop
21: StackMap locals:
StackMap stack:
aload 2
new java.lang.IllegalStateException
dup
ldc "node is stopped"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
22: goto 24
23: StackMap locals:
StackMap stack:
aload 2
ldc "event not known"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
end local 3 24: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
0 25 2 f Lio/vertx/core/Promise<Ljava/lang/Object;>;
1 24 3 id Ljava/lang/String;
Exception table:
from to target type
10 11 12 Class java.lang.Exception
private static java.lang.Object $deserializeLambda$(java.lang.invoke.SerializedLambda);
descriptor: (Ljava/lang/invoke/SerializedLambda;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=1
0: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodName:()Ljava/lang/String;
astore 1
iconst_m1
istore 2
aload 1
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 2
-1647345001: 1
-1647344997: 2
default: 3
}
StackMap locals: java.lang.String int
StackMap stack:
1: aload 1
ldc "lambda$4"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 3
iconst_0
istore 2
goto 3
StackMap locals:
StackMap stack:
2: aload 1
ldc "lambda$8"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 3
iconst_1
istore 2
StackMap locals:
StackMap stack:
3: iload 2
lookupswitch { // 2
0: 4
1: 5
default: 6
}
StackMap locals:
StackMap stack:
4: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgniteInClosure"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;)V"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/IgniteClusterManager"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Lio/vertx/core/Promise;Lorg/apache/ignite/lang/IgniteFuture;)V"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.core.Promise
invokedynamic apply(Lio/vertx/core/Promise;)Lorg/apache/ignite/lang/IgniteInClosure;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$4(Lio/vertx/core/Promise;Lorg/apache/ignite/lang/IgniteFuture;)V (6)
(Lorg/apache/ignite/lang/IgniteFuture;)V
1
areturn
StackMap locals:
StackMap stack:
5: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 7
if_icmpne 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgnitePredicate"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/IgniteClusterManager"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Lorg/apache/ignite/events/Event;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.IgniteClusterManager
invokedynamic apply(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)Lorg/apache/ignite/lang/IgnitePredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$8(Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
areturn
StackMap locals:
StackMap stack:
6: new java.lang.IllegalArgumentException
dup
ldc "Invalid lambda deserialization"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "IgniteClusterManager.java"
NestMembers:
io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl
InnerClasses:
private ClearExpiryPolicy = io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy of io.vertx.spi.cluster.ignite.IgniteClusterManager
private CounterImpl = io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl of io.vertx.spi.cluster.ignite.IgniteClusterManager
private LockImpl = io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl of io.vertx.spi.cluster.ignite.IgniteClusterManager
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
IgniteClusterManager
log: Logger
<clinit>(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-ignite: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)