public class org.I0Itec.zkclient.ZkServer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.I0Itec.zkclient.ZkServer
super_class: java.lang.Object
{
private static final org.slf4j.Logger LOG;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_PORT;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 2181
public static final int DEFAULT_TICK_TIME;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 5000
public static final int DEFAULT_MIN_SESSION_TIMEOUT;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 10000
private java.lang.String _dataDir;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String _logDir;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private org.I0Itec.zkclient.IDefaultNameSpace _defaultNameSpace;
descriptor: Lorg/I0Itec/zkclient/IDefaultNameSpace;
flags: (0x0002) ACC_PRIVATE
private org.apache.zookeeper.server.ZooKeeperServer _zk;
descriptor: Lorg/apache/zookeeper/server/ZooKeeperServer;
flags: (0x0002) ACC_PRIVATE
private org.apache.zookeeper.server.NIOServerCnxnFactory _nioFactory;
descriptor: Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
flags: (0x0002) ACC_PRIVATE
private org.I0Itec.zkclient.ZkClient _zkClient;
descriptor: Lorg/I0Itec/zkclient/ZkClient;
flags: (0x0002) ACC_PRIVATE
private int _port;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int _tickTime;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int _minSessionTimeout;
descriptor: I
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/I0Itec/zkclient/ZkServer;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
1: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.lang.String, java.lang.String, org.I0Itec.zkclient.IDefaultNameSpace);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
sipush 2181
invokespecial org.I0Itec.zkclient.ZkServer.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;I)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/I0Itec/zkclient/ZkServer;
0 2 1 dataDir Ljava/lang/String;
0 2 2 logDir Ljava/lang/String;
0 2 3 defaultNameSpace Lorg/I0Itec/zkclient/IDefaultNameSpace;
MethodParameters:
Name Flags
dataDir
logDir
defaultNameSpace
public void <init>(java.lang.String, java.lang.String, org.I0Itec.zkclient.IDefaultNameSpace, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
iload 4
sipush 5000
invokespecial org.I0Itec.zkclient.ZkServer.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;II)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/I0Itec/zkclient/ZkServer;
0 2 1 dataDir Ljava/lang/String;
0 2 2 logDir Ljava/lang/String;
0 2 3 defaultNameSpace Lorg/I0Itec/zkclient/IDefaultNameSpace;
0 2 4 port I
MethodParameters:
Name Flags
dataDir
logDir
defaultNameSpace
port
public void <init>(java.lang.String, java.lang.String, org.I0Itec.zkclient.IDefaultNameSpace, int, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;II)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aload 3
iload 4
iload 5
sipush 10000
invokespecial org.I0Itec.zkclient.ZkServer.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;III)V
1: return
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 2 0 this Lorg/I0Itec/zkclient/ZkServer;
0 2 1 dataDir Ljava/lang/String;
0 2 2 logDir Ljava/lang/String;
0 2 3 defaultNameSpace Lorg/I0Itec/zkclient/IDefaultNameSpace;
0 2 4 port I
0 2 5 tickTime I
MethodParameters:
Name Flags
dataDir
logDir
defaultNameSpace
port
tickTime
public void <init>(java.lang.String, java.lang.String, org.I0Itec.zkclient.IDefaultNameSpace, int, int, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/I0Itec/zkclient/IDefaultNameSpace;III)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.I0Itec.zkclient.ZkServer._dataDir:Ljava/lang/String;
2: aload 0
aload 2
putfield org.I0Itec.zkclient.ZkServer._logDir:Ljava/lang/String;
3: aload 0
aload 3
putfield org.I0Itec.zkclient.ZkServer._defaultNameSpace:Lorg/I0Itec/zkclient/IDefaultNameSpace;
4: aload 0
iload 4
putfield org.I0Itec.zkclient.ZkServer._port:I
5: aload 0
iload 5
putfield org.I0Itec.zkclient.ZkServer._tickTime:I
6: aload 0
iload 6
putfield org.I0Itec.zkclient.ZkServer._minSessionTimeout:I
7: return
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 8 0 this Lorg/I0Itec/zkclient/ZkServer;
0 8 1 dataDir Ljava/lang/String;
0 8 2 logDir Ljava/lang/String;
0 8 3 defaultNameSpace Lorg/I0Itec/zkclient/IDefaultNameSpace;
0 8 4 port I
0 8 5 tickTime I
0 8 6 minSessionTimeout I
MethodParameters:
Name Flags
dataDir
logDir
defaultNameSpace
port
tickTime
minSessionTimeout
public int getPort();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.I0Itec.zkclient.ZkServer._port:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/I0Itec/zkclient/ZkServer;
public void start();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=1
start local 0 0: invokestatic org.I0Itec.zkclient.NetworkUtil.getLocalHostNames:()[Ljava/lang/String;
astore 1
start local 1 1: ldc ""
astore 2
start local 2 2: iconst_0
istore 3
start local 3 3: goto 9
4: StackMap locals: java.lang.String[] java.lang.String int
StackMap stack:
aload 1
iload 3
aaload
astore 4
start local 4 5: new java.lang.StringBuilder
dup
aload 2
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;
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
6: iload 3
iconst_1
iadd
aload 1
arraylength
if_icmpeq 8
7: new java.lang.StringBuilder
dup
aload 2
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;
astore 2
end local 4 8: StackMap locals:
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
9: iload 3
aload 1
arraylength
if_icmplt 4
end local 3 10: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "Starting ZkServer on: ["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "] port "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.I0Itec.zkclient.ZkServer._port:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "..."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
11: aload 0
invokevirtual org.I0Itec.zkclient.ZkServer.startZooKeeperServer:()V
12: aload 0
new org.I0Itec.zkclient.ZkClient
dup
new java.lang.StringBuilder
dup
ldc "localhost:"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.I0Itec.zkclient.ZkServer._port:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
sipush 10000
invokespecial org.I0Itec.zkclient.ZkClient.<init>:(Ljava/lang/String;I)V
putfield org.I0Itec.zkclient.ZkServer._zkClient:Lorg/I0Itec/zkclient/ZkClient;
13: aload 0
getfield org.I0Itec.zkclient.ZkServer._defaultNameSpace:Lorg/I0Itec/zkclient/IDefaultNameSpace;
aload 0
getfield org.I0Itec.zkclient.ZkServer._zkClient:Lorg/I0Itec/zkclient/ZkClient;
invokeinterface org.I0Itec.zkclient.IDefaultNameSpace.createDefaultNameSpace:(Lorg/I0Itec/zkclient/ZkClient;)V
14: goto 18
StackMap locals: org.I0Itec.zkclient.ZkServer java.lang.String[] java.lang.String
StackMap stack: java.lang.RuntimeException
15: astore 3
start local 3 16: aload 0
invokevirtual org.I0Itec.zkclient.ZkServer.shutdown:()V
17: aload 3
athrow
end local 3 18: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/I0Itec/zkclient/ZkServer;
1 19 1 localHostNames [Ljava/lang/String;
2 19 2 names Ljava/lang/String;
3 10 3 i I
5 8 4 name Ljava/lang/String;
16 18 3 e Ljava/lang/RuntimeException;
Exception table:
from to target type
11 14 15 Class java.lang.RuntimeException
RuntimeVisibleAnnotations:
javax.annotation.PostConstruct()
private void startZooKeeperServer();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=9, args_size=1
start local 0 0: invokestatic org.I0Itec.zkclient.NetworkUtil.getLocalHostNames:()[Ljava/lang/String;
astore 1
start local 1 1: new java.lang.StringBuilder
dup
ldc "localhost:"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.I0Itec.zkclient.ZkServer._port:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
start local 2 2: iconst_m1
istore 3
start local 3 3: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "check if hostNames "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " is in list: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;)V
4: aload 2
aload 1
invokestatic org.I0Itec.zkclient.NetworkUtil.hostNamesInList:(Ljava/lang/String;[Ljava/lang/String;)I
dup
istore 3
iconst_m1
if_icmpeq 25
5: aload 2
ldc ","
invokevirtual java.lang.String.split:(Ljava/lang/String;)[Ljava/lang/String;
astore 4
start local 4 6: aload 4
iload 3
aaload
ldc ":"
invokevirtual java.lang.String.split:(Ljava/lang/String;)[Ljava/lang/String;
astore 5
start local 5 7: aload 0
getfield org.I0Itec.zkclient.ZkServer._port:I
istore 6
start local 6 8: aload 5
arraylength
iconst_1
if_icmple 10
9: aload 5
iconst_1
aaload
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
istore 6
10: StackMap locals: org.I0Itec.zkclient.ZkServer java.lang.String[] java.lang.String int java.lang.String[] java.lang.String[] int
StackMap stack:
iload 6
invokestatic org.I0Itec.zkclient.NetworkUtil.isPortFree:(I)Z
ifeq 24
11: new java.io.File
dup
aload 0
getfield org.I0Itec.zkclient.ZkServer._dataDir:Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 7
start local 7 12: new java.io.File
dup
aload 0
getfield org.I0Itec.zkclient.ZkServer._logDir:Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 8
start local 8 13: aload 7
invokevirtual java.io.File.mkdirs:()Z
pop
14: aload 8
invokevirtual java.io.File.mkdirs:()Z
pop
15: aload 4
arraylength
iconst_1
if_icmple 18
16: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
ldc "Start distributed zookeeper server..."
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
17: new java.lang.IllegalArgumentException
dup
ldc "Unable to start distributed zookeeper server"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
18: StackMap locals: java.io.File java.io.File
StackMap stack:
getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
ldc "Start single zookeeper server..."
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
19: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "data dir: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
20: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "data log dir: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 8
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
21: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "JAAS login file: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "java.security.auth.login.config"
ldc "none"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
22: aload 0
aload 0
getfield org.I0Itec.zkclient.ZkServer._tickTime:I
aload 7
aload 8
iload 6
invokevirtual org.I0Itec.zkclient.ZkServer.startSingleZkServer:(ILjava/io/File;Ljava/io/File;I)V
end local 8 end local 7 23: goto 25
24: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Zookeeper port "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 6
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " was already in use. Running in single machine mode?"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 6 end local 5 end local 4 25: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/I0Itec/zkclient/ZkServer;
1 26 1 localhostHostNames [Ljava/lang/String;
2 26 2 servers Ljava/lang/String;
3 26 3 pos I
6 25 4 hosts [Ljava/lang/String;
7 25 5 hostSplitted [Ljava/lang/String;
8 25 6 port I
12 23 7 dataDir Ljava/io/File;
13 23 8 dataLogDir Ljava/io/File;
private void startSingleZkServer(int, java.io.File, java.io.File, int);
descriptor: (ILjava/io/File;Ljava/io/File;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
new org.apache.zookeeper.server.ZooKeeperServer
dup
aload 2
aload 3
iload 1
invokespecial org.apache.zookeeper.server.ZooKeeperServer.<init>:(Ljava/io/File;Ljava/io/File;I)V
putfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
1: aload 0
getfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
aload 0
getfield org.I0Itec.zkclient.ZkServer._minSessionTimeout:I
invokevirtual org.apache.zookeeper.server.ZooKeeperServer.setMinSessionTimeout:(I)V
2: aload 0
new org.apache.zookeeper.server.NIOServerCnxnFactory
dup
invokespecial org.apache.zookeeper.server.NIOServerCnxnFactory.<init>:()V
putfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
3: iconst_0
istore 5
start local 5 4: aload 0
getfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
new java.net.InetSocketAddress
dup
iload 4
invokespecial java.net.InetSocketAddress.<init>:(I)V
iload 5
invokevirtual org.apache.zookeeper.server.NIOServerCnxnFactory.configure:(Ljava/net/InetSocketAddress;I)V
5: aload 0
getfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
aload 0
getfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
invokevirtual org.apache.zookeeper.server.NIOServerCnxnFactory.startup:(Lorg/apache/zookeeper/server/ZooKeeperServer;)V
end local 5 6: goto 11
StackMap locals:
StackMap stack: java.io.IOException
7: astore 5
start local 5 8: new org.I0Itec.zkclient.exception.ZkException
dup
ldc "Unable to start single ZooKeeper server."
aload 5
invokespecial org.I0Itec.zkclient.exception.ZkException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 5 9: StackMap locals:
StackMap stack: java.lang.InterruptedException
astore 5
start local 5 10: new org.I0Itec.zkclient.exception.ZkInterruptedException
dup
aload 5
invokespecial org.I0Itec.zkclient.exception.ZkInterruptedException.<init>:(Ljava/lang/InterruptedException;)V
athrow
end local 5 11: StackMap locals:
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 12 0 this Lorg/I0Itec/zkclient/ZkServer;
0 12 1 tickTime I
0 12 2 dataDir Ljava/io/File;
0 12 3 dataLogDir Ljava/io/File;
0 12 4 port I
4 6 5 maxClientConnections I
8 9 5 e Ljava/io/IOException;
10 11 5 e Ljava/lang/InterruptedException;
Exception table:
from to target type
0 6 7 Class java.io.IOException
0 6 9 Class java.lang.InterruptedException
MethodParameters:
Name Flags
tickTime final
dataDir final
dataLogDir final
port final
public void shutdown();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
ldc "Shutting down ZkServer..."
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
1: aload 0
getfield org.I0Itec.zkclient.ZkServer._zkClient:Lorg/I0Itec/zkclient/ZkClient;
ifnull 6
2: aload 0
getfield org.I0Itec.zkclient.ZkServer._zkClient:Lorg/I0Itec/zkclient/ZkClient;
invokevirtual org.I0Itec.zkclient.ZkClient.close:()V
3: goto 6
StackMap locals:
StackMap stack: org.I0Itec.zkclient.exception.ZkException
4: astore 1
start local 1 5: getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
new java.lang.StringBuilder
dup
ldc "Error on closing zkclient: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
end local 1 6: StackMap locals:
StackMap stack:
aload 0
getfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
ifnull 13
7: aload 0
getfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
invokevirtual org.apache.zookeeper.server.NIOServerCnxnFactory.shutdown:()V
8: aload 0
getfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
invokevirtual org.apache.zookeeper.server.NIOServerCnxnFactory.join:()V
9: goto 12
StackMap locals:
StackMap stack: java.lang.InterruptedException
10: pop
11: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
12: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield org.I0Itec.zkclient.ZkServer._nioFactory:Lorg/apache/zookeeper/server/NIOServerCnxnFactory;
13: StackMap locals:
StackMap stack:
aload 0
getfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
ifnull 16
14: aload 0
getfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
invokevirtual org.apache.zookeeper.server.ZooKeeperServer.shutdown:()V
15: aload 0
aconst_null
putfield org.I0Itec.zkclient.ZkServer._zk:Lorg/apache/zookeeper/server/ZooKeeperServer;
16: StackMap locals:
StackMap stack:
getstatic org.I0Itec.zkclient.ZkServer.LOG:Lorg/slf4j/Logger;
ldc "Shutting down ZkServer...done"
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
17: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/I0Itec/zkclient/ZkServer;
5 6 1 e Lorg/I0Itec/zkclient/exception/ZkException;
Exception table:
from to target type
1 3 4 Class org.I0Itec.zkclient.exception.ZkException
8 9 10 Class java.lang.InterruptedException
RuntimeVisibleAnnotations:
javax.annotation.PreDestroy()
public org.I0Itec.zkclient.ZkClient getZkClient();
descriptor: ()Lorg/I0Itec/zkclient/ZkClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.I0Itec.zkclient.ZkServer._zkClient:Lorg/I0Itec/zkclient/ZkClient;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/I0Itec/zkclient/ZkServer;
}
SourceFile: "ZkServer.java"