public class org.apache.zookeeper.server.quorum.QuorumPeerMain extends java.lang.Object { private static final org.slf4j.Logger LOG; private static final java.lang.String USAGE; protected org.apache.zookeeper.server.quorum.QuorumPeer quorumPeer; public void () { org.apache.zookeeper.server.quorum.QuorumPeerMain v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; specialinvoke v.()>(); return; } public static void main(java.lang.String[]) { org.apache.zookeeper.server.quorum.QuorumPeerMain v; java.lang.String[] v; int v, v, v, v, v, v; java.io.PrintStream v, v, v, v; org.apache.zookeeper.server.admin.AdminServer$AdminServerException v; org.slf4j.Logger v, v, v, v, v, v, v; java.lang.IllegalArgumentException v; org.apache.zookeeper.server.ExitCode v, v, v, v, v, v; java.lang.Exception v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; org.apache.zookeeper.server.persistence.FileTxnSnapLog$DatadirException v; v := @parameter: java.lang.String[]; v = new org.apache.zookeeper.server.quorum.QuorumPeerMain; specialinvoke v.()>(); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Invalid arguments, exiting abnormally", v); v = ; interfaceinvoke v.("Usage: QuorumPeerMain configfile"); v = ; virtualinvoke v.("Usage: QuorumPeerMain configfile"); staticinvoke (); v = ; v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Invalid config, exiting abnormally", v); v = ; virtualinvoke v.("Invalid config, exiting abnormally"); staticinvoke (); v = ; v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unable to access datadir, exiting abnormally", v); v = ; virtualinvoke v.("Unable to access datadir, exiting abnormally"); staticinvoke (); v = ; v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unable to start AdminServer, exiting abnormally", v); v = ; virtualinvoke v.("Unable to start AdminServer, exiting abnormally"); staticinvoke (); v = ; v = virtualinvoke v.(); staticinvoke (v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception, exiting abnormally", v); staticinvoke (); v = ; v = virtualinvoke v.(); staticinvoke (v); label: v = ; interfaceinvoke v.("Exiting normally"); v = ; v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.IllegalArgumentException from label to label with label; catch org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException from label to label with label; catch org.apache.zookeeper.server.persistence.FileTxnSnapLog$DatadirException from label to label with label; catch org.apache.zookeeper.server.admin.AdminServer$AdminServerException from label to label with label; catch java.lang.Exception from label to label with label; } protected void initializeAndRun(java.lang.String[]) throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException, java.io.IOException, org.apache.zookeeper.server.admin.AdminServer$AdminServerException { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; org.apache.zookeeper.server.quorum.QuorumPeerMain v; org.slf4j.Logger v; org.apache.zookeeper.server.DatadirCleanupManager v; java.lang.String[] v; java.io.File v, v; int v, v, v, v; java.lang.String v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; v := @parameter: java.lang.String[]; v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig; specialinvoke v.()>(); v = lengthof v; if v != 1 goto label; v = v[0]; virtualinvoke v.(v); label: v = new org.apache.zookeeper.server.DatadirCleanupManager; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.io.File,int,int)>(v, v, v, v); virtualinvoke v.(); v = lengthof v; if v != 1 goto label; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Either no config or no quorum defined in config, running in standalone mode"); staticinvoke (v); label: return; } public void runFromConfig(org.apache.zookeeper.server.quorum.QuorumPeerConfig) throws java.io.IOException, org.apache.zookeeper.server.admin.AdminServer$AdminServerException { org.apache.zookeeper.server.quorum.QuorumPeer 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, v, v, v, v, v, v, v; org.apache.zookeeper.common.QuorumX509Util v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; javax.management.JMException v; java.lang.Throwable v, v, v, v; org.apache.zookeeper.server.ZKDatabase v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v; long v, v; org.apache.zookeeper.server.ServerCnxnFactory v, v; org.apache.zookeeper.server.persistence.FileTxnSnapLog v, v; java.lang.String v, v, v, v, v, v, v, v; java.util.Properties v; java.io.IOException v; java.io.File v, v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; org.apache.zookeeper.server.util.JvmPauseMonitor v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeerMain v; org.apache.zookeeper.metrics.MetricsProvider v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Boolean v; org.slf4j.Logger v, v, v, v, v, v; org.apache.zookeeper.metrics.MetricsProviderLifeCycleException v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeerConfig; label: staticinvoke (); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unable to register log4j JMX control", v); label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Starting quorum peer, myid=\u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot boot MetricsProvider \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: staticinvoke (v); staticinvoke (); v = null; v = null; v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, 0); label: v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, 1); label: v = virtualinvoke v.(); v. = v; v = v.; v = new org.apache.zookeeper.server.persistence.FileTxnSnapLog; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.io.File)>(v, v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = new org.apache.zookeeper.server.ZKDatabase; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, 0); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, 0); label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); label: v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; if v == 0 goto label; v = v.; v = new org.apache.zookeeper.server.util.JvmPauseMonitor; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumPeerConfig)>(v); virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); staticinvoke (); v = v.; virtualinvoke v.(); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error while stopping metrics", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Quorum Peer interrupted", v); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error while stopping metrics", v); goto label; label: v := @caughtexception; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error while stopping metrics", v); label: throw v; label: return; catch javax.management.JMException from label to label with label; catch org.apache.zookeeper.metrics.MetricsProviderLifeCycleException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected org.apache.zookeeper.server.quorum.QuorumPeer getQuorumPeer() throws javax.security.sasl.SaslException { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.server.quorum.QuorumPeerMain v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; v = new org.apache.zookeeper.server.quorum.QuorumPeer; specialinvoke v.()>(); return v; } public void close() { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPeer v, v; org.apache.zookeeper.server.quorum.QuorumPeerMain v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); label: v. = null; goto label; label: v := @caughtexception; v. = null; throw v; label: return; catch java.lang.Throwable from label to label with label; } public java.lang.String toString() { org.apache.zookeeper.server.quorum.QuorumPeer v; java.lang.String v; org.apache.zookeeper.server.quorum.QuorumPeerMain v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerMain; v = v.; if v != null goto label; v = ""; goto label; label: v = virtualinvoke v.(); label: return v; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/zookeeper/server/quorum/QuorumPeerMain;"); = v; return; } }