public class oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig extends java.lang.Object { private static final org.slf4j.Logger LOG; private static final int UNSET_SERVERID; public static final java.lang.String nextDynamicConfigFileSuffix; private static boolean standaloneEnabled; private static boolean reconfigEnabled; protected java.net.InetSocketAddress clientPortAddress; protected java.net.InetSocketAddress secureClientPortAddress; protected boolean sslQuorum; protected boolean shouldUsePortUnification; protected boolean sslQuorumReloadCertFiles; protected java.io.File dataDir; protected java.io.File dataLogDir; protected java.lang.String dynamicConfigFileStr; protected java.lang.String configFileStr; protected int tickTime; protected int maxClientCnxns; protected int minSessionTimeout; protected int maxSessionTimeout; protected boolean localSessionsEnabled; protected boolean localSessionsUpgradingEnabled; protected int initLimit; protected int syncLimit; protected int electionAlg; protected int electionPort; protected boolean quorumListenOnAllIPs; protected long serverId; protected oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier quorumVerifier; protected oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier lastSeenQuorumVerifier; protected int snapRetainCount; protected int purgeInterval; protected boolean syncEnabled; protected oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType peerType; protected boolean quorumServerRequireSasl; protected boolean quorumLearnerRequireSasl; protected boolean quorumEnableSasl; protected java.lang.String quorumServicePrincipal; protected java.lang.String quorumLearnerLoginContext; protected java.lang.String quorumServerLoginContext; protected int quorumCnxnThreadsSize; private final int MIN_SNAP_RETAIN_COUNT; public void () { oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; int v, v; v := @this: oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig; specialinvoke v.()>(); v. = 0; v. = 0; v. = 0; v. = null; v. = null; v. = 3000; v. = 60; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = 0; v. = 0; v. = 3; v. = 2182; v. = 0; v. = -1L; v. = null; v. = null; v. = 3; v. = 0; v. = 1; v = ; v. = v; v. = 0; v. = 0; v. = 0; v. = "zkquorum/localhost"; v. = "QuorumLearner"; v. = "QuorumServer"; v. = 3; return; } public void parse(java.lang.String) throws oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v, v; boolean v, v, v, v, v; java.util.Set v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.Throwable v, v, v; oadd.org.apache.zookeeper.server.util.VerifyingFileFactory v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Properties v, v, v; org.slf4j.Logger v, v, v; java.util.Iterator v; java.io.IOException v, v, v; java.io.FileInputStream v, v, v; java.lang.IllegalArgumentException v, v; java.io.File v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v, v, v, v, v; java.lang.Object v, v; v := @this: oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.lang.String; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Reading configuration from: \u0001"); interfaceinvoke v.(v); label: v = new oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder; v = ; specialinvoke v.(org.slf4j.Logger)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = new java.util.Properties; specialinvoke v.()>(); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: virtualinvoke v.(v); v. = v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error processing \u0001"); specialinvoke v.(java.lang.String,java.lang.Exception)>(v, v); throw v; label: v := @caughtexception; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error processing \u0001"); specialinvoke v.(java.lang.String,java.lang.Exception)>(v, v); throw v; label: v = v.; if v == null goto label; label: v = new java.util.Properties; specialinvoke v.()>(); v = new java.io.FileInputStream; v = v.; specialinvoke v.(java.lang.String)>(v); label: virtualinvoke v.(v); v = virtualinvoke v.("version"); if v == null goto label; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; specialinvoke v.(java.lang.String)>("dynamic file shouldn\'t have version inside"); throw v; label: v = v.; v = staticinvoke (v); if v == null goto label; virtualinvoke v.("version", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(v, 0); label: goto label; label: v := @caughtexception; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error processing \u0001"); specialinvoke v.(java.lang.String,java.lang.Exception)>(v, v); throw v; label: v := @caughtexception; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error processing \u0001"); specialinvoke v.(java.lang.String,java.lang.Exception)>(v, v); throw v; label: v = new java.io.File; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.dynamic.next"); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v == 0 goto label; label: v = new java.util.Properties; specialinvoke v.()>(); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: virtualinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = 0; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("group"); if v != 0 goto label; v = virtualinvoke v.("weight"); if v == 0 goto label; label: v = 1; label: v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("NextQuorumVerifier is initiated to null"); label: return; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.IllegalArgumentException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.IllegalArgumentException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } public static java.lang.String getVersionFromFilename(java.lang.String) { java.lang.NumberFormatException v; long v; int v, v, v; java.lang.String v, v, v; v := @parameter: java.lang.String; v = virtualinvoke v.(46); if v < 0 goto label; v = virtualinvoke v.(); if v < v goto label; label: return null; label: v = v + 1; v = virtualinvoke v.(v); label: v = staticinvoke (v, 16); v = staticinvoke (v); label: return v; label: v := @caughtexception; return null; catch java.lang.NumberFormatException from label to label with label; } public void parseProperties(java.util.Properties) throws java.io.IOException, oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v; oadd.org.apache.zookeeper.server.util.VerifyingFileFactory v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v; int 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.slf4j.Logger v, v, v, v, v, v, v, v; java.lang.Object v, v, v; java.net.InetAddress v, v; java.util.Set 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; java.util.Properties v; java.io.File v, v, v, v, v; boolean 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.lang.IllegalArgumentException v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v, v, v, v; v := @this: oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.util.Properties; v = 0; v = 0; v = null; v = null; v = new oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder; v = ; specialinvoke v.(org.slf4j.Logger)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("dataDir"); if v == 0 goto label; v = virtualinvoke v.(v); v. = v; goto label; label: v = virtualinvoke v.("dataLogDir"); if v == 0 goto label; v = virtualinvoke v.(v); v. = v; goto label; label: v = virtualinvoke v.("clientPort"); if v == 0 goto label; v = staticinvoke (v); goto label; label: v = virtualinvoke v.("localSessionsEnabled"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("localSessionsUpgradingEnabled"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("clientPortAddress"); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.("secureClientPort"); if v == 0 goto label; v = staticinvoke (v); goto label; label: v = virtualinvoke v.("secureClientPortAddress"); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.("tickTime"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("maxClientCnxns"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("minSessionTimeout"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("maxSessionTimeout"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("initLimit"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("syncLimit"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("electionAlg"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("quorumListenOnAllIPs"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("peerType"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("observer"); if v == 0 goto label; v = ; v. = v; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.("participant"); if v == 0 goto label; v = ; v. = v; goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unrecognised peertype: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.("syncEnabled"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("dynamicConfigFile"); if v == 0 goto label; v. = v; goto label; label: v = virtualinvoke v.("autopurge.snapRetainCount"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("autopurge.purgeInterval"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("standaloneEnabled"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("true"); if v == 0 goto label; staticinvoke (1); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.("false"); if v == 0 goto label; staticinvoke (0); goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid option \u for standalone mode. Choose \'true\' or \'false.\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.("reconfigEnabled"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("true"); if v == 0 goto label; staticinvoke (1); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.("false"); if v == 0 goto label; staticinvoke (0); goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid option \u for reconfigEnabled flag. Choose \'true\' or \'false.\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.("sslQuorum"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("portUnification"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("sslQuorumReloadCertFiles"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("server."); if v != 0 goto label; v = virtualinvoke v.("group"); if v != 0 goto label; v = virtualinvoke v.("weight"); if v == 0 goto label; label: v = virtualinvoke v.("dynamicConfigFile"); if v == 0 goto label; v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("parameter: \u must be in a separate dynamic config file"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.("quorum.auth.enableSasl"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.serverRequireSasl"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.learnerRequireSasl"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.learner.saslLoginContext"); if v == 0 goto label; v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.server.saslLoginContext"); if v == 0 goto label; v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.kerberos.servicePrincipal"); if v == 0 goto label; v. = v; goto label; label: v = virtualinvoke v.("quorum.cnxn.threads.size"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("zookeeper.\u0001"); staticinvoke (v, v); goto label; label: v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("quorum.auth.enableSasl is disabled, so cannot enable quorum.auth.serverRequireSasl"); throw v; label: v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("quorum.auth.enableSasl is disabled, so cannot enable quorum.auth.learnerRequireSasl"); throw v; label: v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("quorum.auth.learnerRequireSasl is disabled, so cannot enable quorum.auth.serverRequireSasl"); throw v; label: v = v.; if v >= 3 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid autopurge.snapRetainCount: \u. Defaulting to 3"); interfaceinvoke v.(v); v. = 3; label: v = v.; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("dataDir is not set"); throw v; label: v = v.; if v != null goto label; v = v.; v. = v; label: if v != 0 goto label; v = ; interfaceinvoke v.("clientPort is not set"); if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("clientPortAddress is set but clientPort is not set"); throw v; label: if v == null goto label; v = new java.net.InetSocketAddress; v = staticinvoke (v); specialinvoke v.(java.net.InetAddress,int)>(v, v); v. = v; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("clientPortAddress is {}", v); goto label; label: v = new java.net.InetSocketAddress; specialinvoke v.(int)>(v); v. = v; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("clientPortAddress is {}", v); label: if v != 0 goto label; v = ; interfaceinvoke v.("secureClientPort is not set"); if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("secureClientPortAddress is set but secureClientPort is not set"); throw v; label: if v == null goto label; v = new java.net.InetSocketAddress; v = staticinvoke (v); specialinvoke v.(java.net.InetAddress,int)>(v, v); v. = v; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("secureClientPortAddress is {}", v); goto label; label: v = new java.net.InetSocketAddress; specialinvoke v.(int)>(v); v. = v; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("secureClientPortAddress is {}", v); label: v = v.; if v == null goto label; staticinvoke (); label: v = v.; if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("tickTime is not set"); throw v; label: v = v.; v = (int) -1; if v != v goto label; v = v.; v = v * 2; goto label; label: v = v.; label: v. = v; v = v.; v = (int) -1; if v != v goto label; v = v.; v = v * 20; goto label; label: v = v.; label: v. = v; v = v.; v = v.; if v <= v goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("minSessionTimeout must not be larger than maxSessionTimeout"); throw v; label: v = v.; if v != null goto label; virtualinvoke v.(v, 1); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); if v == 0 goto label; specialinvoke v.(); label: return; } public static void configureSSLAuth() throws oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.lang.Throwable v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; oadd.org.apache.zookeeper.common.ClientX509Util v; java.lang.String v, v, v, v, v, v, v, v; boolean v; v = new oadd.org.apache.zookeeper.common.ClientX509Util; specialinvoke v.()>(); label: v = virtualinvoke v.(); v = staticinvoke (v, "x509"); v = dynamicinvoke "makeConcatWithConstants" (v) ("zookeeper.authProvider.\u0001"); v = staticinvoke (v); if v != null goto label; v = "zookeeper.authProvider.x509"; v = virtualinvoke v.(v); if v == 0 goto label; staticinvoke ("zookeeper.authProvider.x509", "oadd.org.apache.zookeeper.server.auth.X509AuthenticationProvider"); goto label; label: v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("No auth provider configured for the SSL authentication scheme \'\u0001\'."); specialinvoke v.(java.lang.String)>(v); throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void backupOldConfig() throws java.io.IOException { oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$1 v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.String v, v; java.io.File v; oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom v; v := @this: oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = new oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom; v = new java.io.File; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.bak"); specialinvoke v.(java.lang.String)>(v); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$1; specialinvoke v.(oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig)>(v); specialinvoke v.(java.io.File,oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom$OutputStreamStatement)>(v, v); return; } public static void writeDynamicConfig(java.lang.String, oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier, boolean) throws java.io.IOException { oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$2 v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v; java.io.File v; oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom v; boolean v; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier; v := @parameter: boolean; v = new oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$2; specialinvoke v.(oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier,boolean)>(v, v); specialinvoke v.(java.io.File,oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom$WriterStatement)>(v, v); return; } public static void editStaticConfig(java.lang.String, java.lang.String, boolean) throws java.io.IOException { java.lang.Throwable v; oadd.org.apache.zookeeper.server.util.VerifyingFileFactory v, v; oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v, v, v, v, v; java.lang.String v, v; oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom v; boolean v; java.util.Properties v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$3 v; org.slf4j.Logger v, v; java.io.FileInputStream v; java.io.File v, v, v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: boolean; if v != null goto label; return; label: v = new oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder; v = ; specialinvoke v.(org.slf4j.Logger)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = new oadd.org.apache.zookeeper.server.util.VerifyingFileFactory$Builder; v = ; specialinvoke v.(org.slf4j.Logger)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = new java.util.Properties; specialinvoke v.()>(); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: virtualinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = new oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$3; specialinvoke v.(java.util.Properties,boolean,java.io.File)>(v, v, v); specialinvoke v.(java.io.File,oadd.org.apache.zookeeper.common.AtomicFileWritingIdiom$WriterStatement)>(v, v); return; catch java.lang.Throwable from label to label with label; } public static void deleteFile(java.lang.String) { org.slf4j.Logger v; java.lang.String v, v; java.io.File v; java.lang.Exception v; boolean v; v := @parameter: java.lang.String; if v != null goto label; return; label: v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("deleting \u failed"); interfaceinvoke v.(v); label: return; catch java.lang.Exception from label to label with label; } private static oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier createQuorumVerifier(java.util.Properties, boolean) throws oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Properties v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumMaj v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical v; boolean v; v := @parameter: java.util.Properties; v := @parameter: boolean; if v == 0 goto label; v = new oadd.org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical; specialinvoke v.(java.util.Properties)>(v); return v; label: v = new oadd.org.apache.zookeeper.server.quorum.flexible.QuorumMaj; specialinvoke v.(java.util.Properties)>(v); return v; } void setupQuorumPeerConfig(java.util.Properties, boolean) throws java.io.IOException, oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Properties v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig v; int v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; boolean v; v := @this: oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.util.Properties; v := @parameter: boolean; v = v.; v = staticinvoke (v, v, 1, v); v. = v; specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); virtualinvoke v.(); return; } public static oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier parseDynamicConfig(java.util.Properties, int, boolean, boolean) throws java.io.IOException, oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Map v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v; java.util.Collection v; java.util.Set v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.net.InetSocketAddress v; long v; int v, v, v, v; java.lang.String v, v, v, v, v; java.util.Properties v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v; java.lang.IllegalArgumentException v, v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; java.lang.Object v, v, v; v := @parameter: java.util.Properties; v := @parameter: int; v := @parameter: boolean; v := @parameter: boolean; v = 0; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("group"); if v != 0 goto label; v = virtualinvoke v.("weight"); if v == 0 goto label; label: v = 1; goto label; label: if v != 0 goto label; v = virtualinvoke v.("server."); if v != 0 goto label; v = virtualinvoke v.("version"); if v != 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v); v = new oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unrecognised parameter: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = staticinvoke (v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = ; if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("standaloneEnabled = false then number of participants should be >0"); throw v; label: if v <= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Observers w/o participants is an invalid configuration"); throw v; label: if v != 1 goto label; v = ; if v == 0 goto label; v = ; interfaceinvoke v.