public class 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 int observerMasterPort; 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 java.lang.String metricsProviderClassName; protected java.util.Properties metricsProviderConfiguration; protected boolean localSessionsEnabled; protected boolean localSessionsUpgradingEnabled; protected int clientPortListenBacklog; protected int initLimit; protected int syncLimit; protected int connectToLearnerMasterLimit; protected int electionAlg; protected int electionPort; protected boolean quorumListenOnAllIPs; protected long serverId; protected org.apache.zookeeper.server.quorum.flexible.QuorumVerifier quorumVerifier; protected org.apache.zookeeper.server.quorum.flexible.QuorumVerifier lastSeenQuorumVerifier; protected int snapRetainCount; protected int purgeInterval; protected boolean syncEnabled; protected java.lang.String initialConfig; protected 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 boolean multiAddressEnabled; private boolean multiAddressReachabilityCheckEnabled; private int multiAddressReachabilityCheckTimeoutMs; protected java.lang.String oraclePath; private final int MIN_SNAP_RETAIN_COUNT; protected boolean jvmPauseMonitorToRun; protected long jvmPauseWarnThresholdMs; protected long jvmPauseInfoThresholdMs; protected long jvmPauseSleepTimeMs; public void () { long v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; java.time.Duration v; int v, v, v, v; java.lang.String v, v, v, v, v; boolean v, v; java.util.Properties v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.Class v; v := @this: 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 = class "Lorg/apache/zookeeper/metrics/impl/DefaultMetricsProvider;"; v = virtualinvoke v.(); v. = v; v = new java.util.Properties; specialinvoke v.()>(); v. = v; v. = 0; v. = 0; v = (int) -1; v. = v; 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 = staticinvoke ("zookeeper.multiAddress.enabled", "false"); v = staticinvoke (v); v. = v; v = staticinvoke ("zookeeper.multiAddress.reachabilityCheckEnabled", "true"); v = staticinvoke (v); v. = v; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke ("zookeeper.multiAddress.reachabilityCheckTimeoutMs", v); v = staticinvoke (v); v. = v; v. = 3; v. = 0; v. = 10000L; v. = 1000L; v. = 500L; return; } public void parse(java.lang.String) throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { byte[] v; org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v, v; java.nio.file.Path v; boolean v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.util.Set v; java.lang.Throwable v, v, v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.util.VerifyingFileFactory 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; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v, v, v, v, v; java.lang.Object v, v; v := @this: 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 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; throw v; label: v = new java.lang.String; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(byte[])>(v); v. = v; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new 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 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 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; throw v; label: virtualinvoke v.(v, 0); label: goto label; label: v := @caughtexception; v = new 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 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; 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, org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.lang.Integer v, v, v; java.lang.Thread v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.ClassLoader v; long v, v, v; org.apache.zookeeper.server.util.VerifyingFileFactory 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, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException 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; java.util.Properties v, v; java.io.File v, v, v, v, v; java.lang.ClassNotFoundException v; org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType 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, 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, v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.util.Properties; v = null; v = null; v = 0; v = null; v = null; v = new 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); v = staticinvoke (v); goto label; label: v = virtualinvoke v.("localSessionsEnabled"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("localSessionsUpgradingEnabled"); if v == 0 goto label; v = specialinvoke v.(v, 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); v = staticinvoke (v); goto label; label: v = virtualinvoke v.("secureClientPortAddress"); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.("observerMasterPort"); if v == 0 goto label; v = staticinvoke (v); goto label; label: v = virtualinvoke v.("clientPortListenBacklog"); if v == 0 goto label; v = staticinvoke (v); v. = 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.("connectToLearnerMasterLimit"); 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; v = v.; if v == 3 goto label; v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; specialinvoke v.(java.lang.String)>("Invalid electionAlg value. Only 3 is supported."); throw v; label: v = virtualinvoke v.("quorumListenOnAllIPs"); if v == 0 goto label; v = specialinvoke v.(v, 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 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 = specialinvoke v.(v, 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 = specialinvoke v.(v, v); staticinvoke (v); goto label; label: v = virtualinvoke v.("reconfigEnabled"); if v == 0 goto label; v = specialinvoke v.(v, v); staticinvoke (v); goto label; label: v = virtualinvoke v.("sslQuorum"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("portUnification"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("sslQuorumReloadCertFiles"); if v == 0 goto label; v = specialinvoke v.(v, 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 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 = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.serverRequireSasl"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("quorum.auth.learnerRequireSasl"); if v == 0 goto label; v = specialinvoke v.(v, 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 = virtualinvoke v.("jvm.pause.info-threshold.ms"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("jvm.pause.warn-threshold.ms"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("jvm.pause.sleep.time.ms"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("jvm.pause.monitor"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("metricsProvider.className"); if v == 0 goto label; v. = v; goto label; label: v = virtualinvoke v.("metricsProvider."); if v == 0 goto label; v = virtualinvoke v.(16); v = v.; virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.("multiAddress.enabled"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("multiAddress.reachabilityCheckTimeoutMs"); if v == 0 goto label; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.("multiAddress.reachabilityCheckEnabled"); if v == 0 goto label; v = specialinvoke v.(v, v); v. = v; goto label; label: v = virtualinvoke v.("oraclePath"); if v == 0 goto label; 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 != null 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); v = virtualinvoke 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; v = virtualinvoke v.(); specialinvoke v.(int)>(v); v. = v; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("clientPortAddress is {}", v); label: if v != null 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); v = virtualinvoke 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; v = virtualinvoke v.(); 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: if v > 0 goto label; v = ; interfaceinvoke v.("observerMasterPort is not set"); goto label; label: v. = v; v = ; v = staticinvoke (v); interfaceinvoke v.("observerMasterPort is {}", v); 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 = v.; interfaceinvoke v.("metricsProvider.className is {}", v); label: v = v.; v = staticinvoke (); v = virtualinvoke v.(); staticinvoke (v, 0, v); label: goto label; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("metrics provider class was not found", v); 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; catch java.lang.ClassNotFoundException from label to label with label; } public static void configureSSLAuth() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; java.lang.String v, v, v, v, v, v, v, v; org.apache.zookeeper.common.ClientX509Util v; boolean v; v = new 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", "org.apache.zookeeper.server.auth.X509AuthenticationProvider"); goto label; label: v = new 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 { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; org.apache.zookeeper.common.AtomicFileWritingIdiom v; java.lang.String v, v; java.io.File v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$1 v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = new 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 org.apache.zookeeper.server.quorum.QuorumPeerConfig$1; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumPeerConfig)>(v); specialinvoke v.(java.io.File,org.apache.zookeeper.common.AtomicFileWritingIdiom$OutputStreamStatement)>(v, v); return; } public static void writeDynamicConfig(java.lang.String, org.apache.zookeeper.server.quorum.flexible.QuorumVerifier, boolean) throws java.io.IOException { org.apache.zookeeper.common.AtomicFileWritingIdiom v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v; java.io.File v; boolean v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$2 v; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.server.quorum.flexible.QuorumVerifier; v := @parameter: boolean; v = new org.apache.zookeeper.common.AtomicFileWritingIdiom; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig$2; specialinvoke v.(org.apache.zookeeper.server.quorum.flexible.QuorumVerifier,boolean)>(v, v); specialinvoke v.(java.io.File,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; org.apache.zookeeper.server.util.VerifyingFileFactory$Builder v, v, v, v, v, v; java.lang.String v, v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$3 v; org.apache.zookeeper.server.util.VerifyingFileFactory v, v; boolean v; java.util.Properties v; org.slf4j.Logger v, v; java.io.FileInputStream v; java.io.File v, v, v; org.apache.zookeeper.common.AtomicFileWritingIdiom v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: boolean; if v != null goto label; return; label: v = new 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 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; throw v; label: v = new org.apache.zookeeper.common.AtomicFileWritingIdiom; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig$3; specialinvoke v.(java.util.Properties,boolean,java.io.File)>(v, v, v); specialinvoke v.(java.io.File,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; 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 = ; interfaceinvoke v.("deleting {} failed", v); label: return; catch java.lang.Exception from label to label with label; } private static org.apache.zookeeper.server.quorum.flexible.QuorumVerifier createQuorumVerifier(java.util.Properties, boolean, java.lang.String) throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Properties v; org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v; boolean v; v := @parameter: java.util.Properties; v := @parameter: boolean; v := @parameter: java.lang.String; if v != null goto label; v = staticinvoke (v, v); return v; label: v = new org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj; specialinvoke v.(java.util.Properties,java.lang.String)>(v, v); return v; } private static org.apache.zookeeper.server.quorum.flexible.QuorumVerifier createQuorumVerifier(java.util.Properties, boolean) throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Properties v; org.apache.zookeeper.server.quorum.flexible.QuorumMaj v; 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 org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical; specialinvoke v.(java.util.Properties)>(v); return v; label: v = new 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, org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.util.Properties v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; int v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; java.lang.String v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.util.Properties; v := @parameter: boolean; v = v.; v = v.; v = staticinvoke (v, v, 1, v, v); v. = v; specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); virtualinvoke v.(); return; } public static org.apache.zookeeper.server.quorum.flexible.QuorumVerifier parseDynamicConfig(java.util.Properties, int, boolean, boolean, java.lang.String) throws java.io.IOException, 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; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v; int v, v, v, v; java.lang.String v, 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; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v, v, v; v := @parameter: java.util.Properties; v := @parameter: int; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: java.lang.String; 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 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); 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.("Invalid configuration, only one server specified (ignoring)"); if v <= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Observers w/o quorum is an invalid configuration"); throw v; label: if v == 0 goto label; if v > 2 goto label; v = ; interfaceinvoke v.("No server failure will be tolerated. You need at least 3 servers."); goto label; label: v = v % 2; if v != 0 goto label; v = ; interfaceinvoke v.("Non-optimal configuration, consider an odd number of servers."); label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v != null goto label; v = new java.lang.IllegalArgumentException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Missing election port for server: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } private void setupMyId() throws java.io.IOException { java.lang.Throwable v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.NumberFormatException v; long v; java.lang.IllegalArgumentException v; java.io.File v, v; java.io.BufferedReader v; java.io.FileReader v; java.lang.String v, v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = new java.io.File; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "myid"); v = virtualinvoke v.(); if v != 0 goto label; return; label: v = new java.io.BufferedReader; v = new java.io.FileReader; specialinvoke v.(java.io.File)>(v); specialinvoke v.(java.io.Reader)>(v); label: v = virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = staticinvoke (v); v. = v; staticinvoke ("myid", v); label: goto label; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("serverid \u is not a number"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.NumberFormatException from label to label with label; } private void setupClientPort() throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { java.net.InetAddress v, v; byte v; java.lang.Long v; java.util.Map v; boolean v, v, v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.net.InetSocketAddress v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v; int v, v; java.lang.String v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; v = v cmp -1L; if v != 0 goto label; return; label: v = v.; v = interfaceinvoke v.(); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; if v == null goto label; if v == null goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == v goto label; label: v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = v.; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("client address for this server (id = \u) in static config file is \u is different from client address found in dynamic file: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v == null goto label; v = v.; if v == null goto label; v = v.; v. = v; label: if v == null goto label; v = v.; if v != null goto label; v = v.; v. = v; v. = 1; label: return; } private void setupPeerType() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; org.slf4j.Logger v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v; java.lang.Long v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v; java.util.Map v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; v = interfaceinvoke v.(); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = ; goto label; label: v = ; label: v = v.; if v == v goto label; v = ; v = v.; interfaceinvoke v.("Peer type from servers list ({}) doesn\'t match peerType ({}). Defaulting to servers list.", v, v); v. = v; label: return; } public void checkValidity() throws java.io.IOException, org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; long v; java.lang.IllegalArgumentException v, v, v; byte v; int v, v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("initLimit is not set"); throw v; label: v = v.; if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("syncLimit is not set"); throw v; label: v = v.; v = v cmp -1L; if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("myid file is missing"); throw v; label: return; } public java.net.InetSocketAddress getClientPortAddress() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.net.InetSocketAddress v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.net.InetSocketAddress getSecureClientPortAddress() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.net.InetSocketAddress v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getObserverMasterPort() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.io.File getDataDir() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.io.File v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.io.File getDataLogDir() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.io.File v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.lang.String getInitialConfig() { java.lang.String v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getTickTime() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getMaxClientCnxns() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getMinSessionTimeout() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getMaxSessionTimeout() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.lang.String getMetricsProviderClassName() { java.lang.String v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.util.Properties getMetricsProviderConfiguration() { java.util.Properties v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean areLocalSessionsEnabled() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean isLocalSessionsUpgradingEnabled() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean isSslQuorum() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean shouldUsePortUnification() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getClientPortListenBacklog() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getInitLimit() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getSyncLimit() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getConnectToLearnerMasterLimit() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getElectionAlg() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getElectionPort() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getSnapRetainCount() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getPurgeInterval() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean getSyncEnabled() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getQuorumVerifier() { org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public org.apache.zookeeper.server.quorum.flexible.QuorumVerifier getLastSeenQuorumVerifier() { org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.util.Map getServers() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.util.Map v, v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); return v; } public long getJvmPauseInfoThresholdMs() { long v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public long getJvmPauseWarnThresholdMs() { long v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public long getJvmPauseSleepTimeMs() { long v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean isJvmPauseMonitorToRun() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public long getServerId() { long v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean isDistributed() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.util.Map v; int v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; if v == null goto label; v = ; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v <= 1 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getPeerType() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.lang.String getConfigFilename() { java.lang.String v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public java.lang.Boolean getQuorumListenOnAllIPs() { java.lang.Boolean v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; v = staticinvoke (v); return v; } public boolean isMultiAddressEnabled() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public boolean isMultiAddressReachabilityCheckEnabled() { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public int getMultiAddressReachabilityCheckTimeoutMs() { int v; org.apache.zookeeper.server.quorum.QuorumPeerConfig v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v = v.; return v; } public static boolean isStandaloneEnabled() { boolean v; v = ; return v; } public static void setStandaloneEnabled(boolean) { boolean v; v := @parameter: boolean; = v; return; } public static boolean isReconfigEnabled() { boolean v; v = ; return v; } public static void setReconfigEnabled(boolean) { boolean v; v := @parameter: boolean; = v; return; } private boolean parseBoolean(java.lang.String, java.lang.String) throws org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException { org.apache.zookeeper.server.quorum.QuorumPeerConfig v; java.lang.String v, v, v; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; boolean v, v; v := @this: org.apache.zookeeper.server.quorum.QuorumPeerConfig; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.("true"); if v == 0 goto label; return 1; label: v = virtualinvoke v.("false"); if v == 0 goto label; return 0; label: v = new org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Invalid option \u for \u. Choose \'true\' or \'false.\'"); specialinvoke v.(java.lang.String)>(v); throw v; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/zookeeper/server/quorum/QuorumPeerConfig;"); = v; = 1; = 0; return; } }