public final class org.apache.zookeeper.server.embedded.ZookeeperServeInfo extends java.lang.Object
{
private static final javax.management.MBeanServer localServer;
private void <init>()
{
org.apache.zookeeper.server.embedded.ZookeeperServeInfo v;
v := @this: org.apache.zookeeper.server.embedded.ZookeeperServeInfo;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo getStatus() throws java.lang.Exception
{
org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo v;
v = staticinvoke <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo getStatus(java.lang.String)>("*");
return v;
}
public static org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo getStatus(java.lang.String) throws java.lang.Exception
{
org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo v, v, v;
java.util.Set v, v, v, v;
java.lang.Exception v, v;
java.lang.Throwable v, v, v;
long v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ConnectionInfo v, v;
java.lang.IllegalStateException v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
javax.management.ObjectName v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v, v, v, v;
org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo v;
java.lang.String[] v, v, v, v;
javax.management.MBeanServer v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v, v, v, v;
java.lang.reflect.UndeclaredThrowableException v;
java.lang.Class v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
v := @parameter: java.lang.String;
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo;
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: void <init>()>();
v = 0;
v = staticinvoke <org.apache.zookeeper.common.StringUtils: boolean isBlank(java.lang.String)>(v);
if v == 0 goto label;
v = "*";
label:
v = new javax.management.ObjectName;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("org.apache.ZooKeeperService:name0=\u0001");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.management.ObjectName)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No ZooKeeper server found in this JVM with name \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "";
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<javax.management.ObjectInstance: java.lang.String getClassName()>();
v = class "Lorg/apache/zookeeper/server/ZooKeeperServerBean;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = 1;
v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: boolean leader> = 1;
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo;
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo: void <init>(java.lang.String,java.lang.String,java.lang.String,boolean)>("local", "local", "STANDALONE", 1);
virtualinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: void addPeer(org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo)>(v);
goto label;
label:
v = virtualinvoke v.<javax.management.ObjectInstance: java.lang.String getClassName()>();
v = class "Lorg/apache/zookeeper/server/quorum/QuorumBean;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = 0;
label:
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = staticinvoke <javax.management.MBeanServerInvocationHandler: java.lang.Object newProxyInstance(javax.management.MBeanServerConnection,javax.management.ObjectName,java.lang.Class,boolean)>(v, v, class "Lorg/apache/zookeeper/server/quorum/QuorumMXBean;", 0);
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.QuorumMXBean: java.lang.String getName()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.reflect.UndeclaredThrowableException: java.lang.Throwable getCause()>();
v = v instanceof javax.management.InstanceNotFoundException;
if v != 0 goto label;
throw v;
label:
v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: boolean standaloneMode> = v;
if v == 0 goto label;
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = new javax.management.ObjectName;
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>("org.apache.ZooKeeperService:name0=*,name1=Connections,name2=*,name3=*");
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = staticinvoke <javax.management.MBeanServerInvocationHandler: java.lang.Object newProxyInstance(javax.management.MBeanServerConnection,javax.management.ObjectName,java.lang.Class,boolean)>(v, v, class "Lorg/apache/zookeeper/server/ConnectionMXBean;", 0);
label:
v = "";
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String[] getEphemeralNodes()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String[] getEphemeralNodes()>();
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
label:
v = v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: java.util.List connections>;
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ConnectionInfo;
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getSourceIP()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getSessionId()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getLastOperation()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getLastResponseTime()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: long getAvgLatency()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: long getLastLatency()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ConnectionInfo: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v instanceof javax.management.InstanceNotFoundException;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Exception: java.lang.Throwable getCause()>();
v = v instanceof javax.management.InstanceNotFoundException;
if v != 0 goto label;
label:
throw v;
label:
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Set)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot find local JMX name for current node, in quorum mode, scanned \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 0;
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = new javax.management.ObjectName;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("org.apache.ZooKeeperService:name0=\u,name1=*");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<javax.management.ObjectInstance: java.lang.String getClassName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("local");
if v == 0 goto label;
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = staticinvoke <javax.management.MBeanServerInvocationHandler: java.lang.Object newProxyInstance(javax.management.MBeanServerConnection,javax.management.ObjectName,java.lang.Class,boolean)>(v, v, class "Lorg/apache/zookeeper/server/quorum/LocalPeerMXBean;", 0);
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo;
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.LocalPeerMXBean: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.LocalPeerMXBean: java.lang.String getQuorumAddress()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.LocalPeerMXBean: java.lang.String getState()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.LocalPeerMXBean: boolean isLeader()>();
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo: void <init>(java.lang.String,java.lang.String,java.lang.String,boolean)>(v, v, v, v);
virtualinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: void addPeer(org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo)>(v);
v = new javax.management.ObjectName;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.management.ObjectName)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u,name2=Follower");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = new javax.management.ObjectName;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.management.ObjectName)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u,name2=Leader");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = interfaceinvoke v.<javax.management.MBeanServer: boolean isRegistered(javax.management.ObjectName)>(v);
if v == 0 goto label;
v = 1;
v = new javax.management.ObjectName;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.management.ObjectName)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u,name3=Connections,name4=*,name5=*");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
goto label;
label:
v = 0;
v = new javax.management.ObjectName;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.management.ObjectName)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u,name3=Connections,name4=*,name5=*");
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = interfaceinvoke v.<javax.management.MBeanServer: java.util.Set queryMBeans(javax.management.ObjectName,javax.management.QueryExp)>(v, null);
label:
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = staticinvoke <javax.management.MBeanServerInvocationHandler: java.lang.Object newProxyInstance(javax.management.MBeanServerConnection,javax.management.ObjectName,java.lang.Class,boolean)>(v, v, class "Lorg/apache/zookeeper/server/ConnectionMXBean;", 0);
label:
v = "";
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String[] getEphemeralNodes()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String[] getEphemeralNodes()>();
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
label:
v = v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: java.util.List connections>;
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ConnectionInfo;
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getSourceIP()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getSessionId()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getLastOperation()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: java.lang.String getLastResponseTime()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: long getAvgLatency()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
v = interfaceinvoke v.<org.apache.zookeeper.server.ConnectionMXBean: long getLastLatency()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ConnectionInfo: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v instanceof javax.management.InstanceNotFoundException;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Exception: java.lang.Throwable getCause()>();
v = v instanceof javax.management.InstanceNotFoundException;
if v != 0 goto label;
label:
throw v;
label:
v = <org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer>;
v = virtualinvoke v.<javax.management.ObjectInstance: javax.management.ObjectName getObjectName()>();
v = staticinvoke <javax.management.MBeanServerInvocationHandler: java.lang.Object newProxyInstance(javax.management.MBeanServerConnection,javax.management.ObjectName,java.lang.Class,boolean)>(v, v, class "Lorg/apache/zookeeper/server/quorum/RemotePeerMXBean;", 0);
v = new org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo;
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.RemotePeerMXBean: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.RemotePeerMXBean: java.lang.String getQuorumAddress()>();
v = interfaceinvoke v.<org.apache.zookeeper.server.quorum.RemotePeerMXBean: boolean isLeader()>();
specialinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo: void <init>(java.lang.String,java.lang.String,java.lang.String,boolean)>(v, v, "REMOTE", v);
virtualinvoke v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: void addPeer(org.apache.zookeeper.server.embedded.ZookeeperServeInfo$PeerInfo)>(v);
goto label;
label:
v.<org.apache.zookeeper.server.embedded.ZookeeperServeInfo$ServerInfo: boolean leader> = v;
label:
return v;
catch java.lang.reflect.UndeclaredThrowableException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
javax.management.MBeanServer v;
v = staticinvoke <java.lang.management.ManagementFactory: javax.management.MBeanServer getPlatformMBeanServer()>();
<org.apache.zookeeper.server.embedded.ZookeeperServeInfo: javax.management.MBeanServer localServer> = v;
return;
}
}