public abstract class oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager extends oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager { private static final java.lang.String ZK_CONF_PREFIX; public static final java.lang.String ZK_DTSM_ZK_NUM_RETRIES; public static final java.lang.String ZK_DTSM_ZK_SESSION_TIMEOUT; public static final java.lang.String ZK_DTSM_ZK_CONNECTION_TIMEOUT; public static final java.lang.String ZK_DTSM_ZK_SHUTDOWN_TIMEOUT; public static final java.lang.String ZK_DTSM_ZNODE_WORKING_PATH; public static final java.lang.String ZK_DTSM_ZK_AUTH_TYPE; public static final java.lang.String ZK_DTSM_ZK_CONNECTION_STRING; public static final java.lang.String ZK_DTSM_ZK_KERBEROS_KEYTAB; public static final java.lang.String ZK_DTSM_ZK_KERBEROS_PRINCIPAL; public static final int ZK_DTSM_ZK_NUM_RETRIES_DEFAULT; public static final int ZK_DTSM_ZK_SESSION_TIMEOUT_DEFAULT; public static final int ZK_DTSM_ZK_CONNECTION_TIMEOUT_DEFAULT; public static final int ZK_DTSM_ZK_SHUTDOWN_TIMEOUT_DEFAULT; public static final java.lang.String ZK_DTSM_ZNODE_WORKING_PATH_DEAFULT; private static org.slf4j.Logger LOG; private static final java.lang.String JAAS_LOGIN_ENTRY_NAME; private static final java.lang.String ZK_DTSM_NAMESPACE; private static final java.lang.String ZK_DTSM_SEQNUM_ROOT; private static final java.lang.String ZK_DTSM_KEYID_ROOT; private static final java.lang.String ZK_DTSM_TOKENS_ROOT; private static final java.lang.String ZK_DTSM_MASTER_KEY_ROOT; private static final java.lang.String DELEGATION_KEY_PREFIX; private static final java.lang.String DELEGATION_TOKEN_PREFIX; private static final java.lang.ThreadLocal CURATOR_TL; private final boolean isExternalClient; private final oadd.org.apache.curator.framework.CuratorFramework zkClient; private oadd.org.apache.curator.framework.recipes.shared.SharedCount delTokSeqCounter; private oadd.org.apache.curator.framework.recipes.shared.SharedCount keyIdSeqCounter; private oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache keyCache; private oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache tokenCache; private java.util.concurrent.ExecutorService listenerThreadPool; private final long shutdownTimeout; public static void setCurator(oadd.org.apache.curator.framework.CuratorFramework) { java.lang.ThreadLocal v; oadd.org.apache.curator.framework.CuratorFramework v; v := @parameter: oadd.org.apache.curator.framework.CuratorFramework; v = ; virtualinvoke v.(v); return; } public void (oadd.org.apache.hadoop.conf.Configuration) { oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$SASLOwnerACLProvider v; boolean v, v, v, v; java.lang.ThreadLocal v, v; oadd.org.apache.curator.framework.CuratorFrameworkFactory$Builder v, v, v, v, v, v, v; oadd.org.apache.curator.framework.CuratorFramework v, v; java.lang.Exception v; oadd.org.apache.curator.framework.api.ACLProvider v; long v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; oadd.org.apache.curator.retry.RetryNTimes v; org.slf4j.Logger v, v; oadd.org.apache.curator.ensemble.fixed.FixedEnsembleProvider v; java.lang.RuntimeException v; java.lang.Object v, v; oadd.org.apache.curator.framework.imps.DefaultACLProvider v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v = virtualinvoke v.("delegation-token.update-interval.sec", 86400L); v = v * 1000L; v = virtualinvoke v.("delegation-token.max-lifetime.sec", 604800L); v = v * 1000L; v = virtualinvoke v.("delegation-token.renew-interval.sec", 86400L); v = v * 1000L; v = virtualinvoke v.("delegation-token.removal-scan-interval.sec", 3600L); v = v * 1000L; specialinvoke v.(long,long,long,long)>(v, v, v, v); v = virtualinvoke v.("zk-dt-secret-manager.zkShutdownTimeout", 10000L); v. = v; v = ; v = virtualinvoke v.(); if v == null goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.("zk-dt-secret-manager.znodeWorkingPath", "zkdtsm"); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001/ZKDTSMRoot"); v = interfaceinvoke v.(v); v. = v; v. = 1; goto label; label: v = virtualinvoke v.("zk-dt-secret-manager.zkConnectionString"); staticinvoke (v, "Zookeeper connection string cannot be null"); v = virtualinvoke v.("zk-dt-secret-manager.zkAuthType"); staticinvoke (v, "Zookeeper authType cannot be null !!"); v = virtualinvoke v.("sasl"); if v != 0 goto label; v = virtualinvoke v.("none"); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: staticinvoke (v, "Zookeeper authType must be one of [none, sasl]"); label: v = virtualinvoke v.("sasl"); if v == 0 goto label; v = ; interfaceinvoke v.("Connecting to ZooKeeper with SASL/Kerberosand using \'sasl\' ACLs"); v = specialinvoke v.(v); staticinvoke ("zookeeper.sasl.clientconfig", "ZKDelegationTokenSecretManagerClient"); staticinvoke ("zookeeper.authProvider.1", "oadd.org.apache.zookeeper.server.auth.SASLAuthenticationProvider"); v = new oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$SASLOwnerACLProvider; specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = ; interfaceinvoke v.("Connecting to ZooKeeper without authentication"); v = new oadd.org.apache.curator.framework.imps.DefaultACLProvider; specialinvoke v.()>(); v = v; label: v = virtualinvoke v.("zk-dt-secret-manager.zkSessionTimeout", 10000); v = virtualinvoke v.("zk-dt-secret-manager.zkNumRetries", 3); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.("zk-dt-secret-manager.znodeWorkingPath", "zkdtsm"); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001/ZKDTSMRoot"); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.("zk-dt-secret-manager.zkConnectionTimeout", 10000); v = virtualinvoke v.(v); v = new oadd.org.apache.curator.retry.RetryNTimes; v = v / v; specialinvoke v.(int,int)>(v, v); v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not Load ZK acls or auth: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = new oadd.org.apache.curator.ensemble.fixed.FixedEnsembleProvider; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v. = 0; label: return; catch java.lang.Exception from label to label with label; } private java.lang.String setJaasConfiguration(oadd.org.apache.hadoop.conf.Configuration) throws java.lang.Exception { java.lang.String[] v; java.lang.IllegalArgumentException v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$JaasConfiguration v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v; oadd.org.apache.hadoop.conf.Configuration v; java.lang.String v, v, v, v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v = virtualinvoke v.("zk-dt-secret-manager.kerberos.keytab", ""); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("zk-dt-secret-manager.kerberos.keytab must be specified"); throw v; label: v = virtualinvoke v.("zk-dt-secret-manager.kerberos.principal", ""); v = virtualinvoke v.(); v = staticinvoke (v, ""); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("zk-dt-secret-manager.kerberos.principal must be specified"); throw v; label: v = new oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$JaasConfiguration; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("ZKDelegationTokenSecretManagerClient", v, v); staticinvoke (v); v = virtualinvoke v.("[/@]"); v = v[0]; return v; } public void startThreads() throws java.io.IOException { oadd.org.apache.curator.utils.EnsurePath v; oadd.org.apache.curator.CuratorZookeeperClient v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$1 v; boolean v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$2 v; oadd.org.apache.curator.framework.recipes.shared.SharedCount v, v, v, v, v, v; oadd.org.apache.curator.framework.CuratorFramework v, v, v, v, v, v, v, v; java.lang.Exception v, v, v, v, v, v, v; oadd.org.apache.curator.framework.listen.ListenerContainer v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; java.lang.String v, v; java.util.concurrent.ExecutorService v, v, v; java.io.IOException v, v, v, v, v, v; java.lang.RuntimeException v; oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache v, v, v, v, v, v, v, v; oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache$StartMode v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v = v.; if v != 0 goto label; label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not start Curator Framework", v); throw v; label: v = v.; v = interfaceinvoke v.(null); v = v.; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/\u0001"); v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not create namespace", v); throw v; label: v = staticinvoke (); v. = v; label: v = new oadd.org.apache.curator.framework.recipes.shared.SharedCount; v = v.; specialinvoke v.(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,int)>(v, "/ZKDTSMSeqNumRoot", 0); v. = v; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not start Sequence Counter", v); throw v; label: v = new oadd.org.apache.curator.framework.recipes.shared.SharedCount; v = v.; specialinvoke v.(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,int)>(v, "/ZKDTSMKeyIdRoot", 0); v. = v; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not start KeyId Counter", v); throw v; label: specialinvoke v.("/ZKDTSMMasterKeyRoot"); specialinvoke v.("/ZKDTSMTokensRoot"); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("Could not create ZK paths"); throw v; label: v = new oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache; v = v.; specialinvoke v.(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,boolean)>(v, "/ZKDTSMMasterKeyRoot", 1); v. = v; v = v.; if v == null goto label; v = v.; v = ; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$1; specialinvoke v.(oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager)>(v); v = v.; virtualinvoke v.(v, v); specialinvoke v.(0); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not start PathChildrenCache for keys", v); throw v; label: v = new oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache; v = v.; specialinvoke v.(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,boolean)>(v, "/ZKDTSMTokensRoot", 1); v. = v; v = v.; if v == null goto label; v = v.; v = ; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager$2; specialinvoke v.(oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager)>(v); v = v.; virtualinvoke v.(v, v); specialinvoke v.(1); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not start PathChildrenCache for tokens", v); throw v; label: specialinvoke v.(); return; catch java.lang.Exception 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; catch java.lang.Exception 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; catch java.lang.Exception from label to label with label; } private void loadFromZKCache(boolean) { byte[] v; java.lang.Integer v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; java.lang.String v, v, v; boolean v, v; org.slf4j.Logger v, v, v, v, v; java.util.Iterator v; java.lang.Exception v; java.util.List v; oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache v, v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: boolean; if v == 0 goto label; v = "token"; goto label; label: v = "key"; label: v = v; v = ; interfaceinvoke v.("Starting to load {} cache.", v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); label: v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: if v == 0 goto label; specialinvoke v.(v); goto label; label: v = virtualinvoke v.(); specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Ignoring node {} because it failed to load.", v); v = ; interfaceinvoke v.("Failure exception:", v); v = v + 1; goto label; label: if v <= 0 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Ignored {} nodes while loading {} cache.", v, v); label: v = ; interfaceinvoke v.("Loaded {} cache.", v); return; catch java.lang.Exception from label to label with label; } private void processKeyAddOrUpdate(byte[]) throws java.io.IOException { java.lang.Throwable v; byte[] v; java.io.DataInputStream v; java.lang.Integer v; java.io.ByteArrayInputStream v; java.util.Map v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: byte[]; v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = new oadd.org.apache.hadoop.security.token.delegation.DelegationKey; specialinvoke v.()>(); virtualinvoke v.(v); entermonitor v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void processKeyRemoved(java.lang.String) { java.lang.Throwable v; java.lang.Integer v; java.util.Map v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v, v, v, v; java.lang.String v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: java.lang.String; v = virtualinvoke v.(47); if v <= 0 goto label; v = v + 1; v = virtualinvoke v.(v); v = virtualinvoke v.(95); if v <= 0 goto label; v = v + 1; v = virtualinvoke v.(v); v = staticinvoke (v); entermonitor v; label: v = v.; v = staticinvoke (v); interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void processTokenAddOrUpdate(oadd.org.apache.curator.framework.recipes.cache.ChildData) throws java.io.IOException { java.lang.Throwable v; byte[] v, v; java.io.DataInputStream v; long v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v; oadd.org.apache.curator.framework.recipes.cache.ChildData v; oadd.org.apache.hadoop.security.token.TokenIdentifier v; java.io.ByteArrayInputStream v; java.util.Map v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.curator.framework.recipes.cache.ChildData; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (byte)[v]; v = virtualinvoke v.(v, 0, v); v = (int) -1; if v <= v goto label; v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation; specialinvoke v.(long,byte[])>(v, v); entermonitor v; label: v = v.; interfaceinvoke v.(v, v); virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private void processTokenRemoved(oadd.org.apache.curator.framework.recipes.cache.ChildData) throws java.io.IOException { java.lang.Throwable v; byte[] v; java.io.DataInputStream v; oadd.org.apache.curator.framework.recipes.cache.ChildData v; oadd.org.apache.hadoop.security.token.TokenIdentifier v; java.io.ByteArrayInputStream v; java.util.Map v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.curator.framework.recipes.cache.ChildData; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); entermonitor v; label: v = v.; interfaceinvoke v.(v); virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void stopThreads() { java.lang.Thread v; boolean v, v; oadd.org.apache.curator.framework.recipes.shared.SharedCount v, v, v, v; oadd.org.apache.curator.framework.CuratorFramework v, v; java.lang.Exception v, v, v, v, v; long v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; java.util.concurrent.ExecutorService v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v; java.util.concurrent.TimeUnit v; java.lang.InterruptedException v; oadd.org.apache.curator.framework.recipes.cache.PathChildrenCache v, v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; specialinvoke v.(); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not stop Delegation Token Cache", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not stop Delegation Token Counter", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not stop Key Id Counter", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not stop KeyCache", v); label: v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not stop Curator Framework", v); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; v = v.; v = ; v = interfaceinvoke v.(v, v); if v != 0 goto label; v = ; interfaceinvoke v.("Forcing Listener threadPool to shutdown !!"); v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); v = staticinvoke (); virtualinvoke v.(); label: return; catch java.lang.Exception 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; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.InterruptedException from label to label with label; } private void createPersistentNode(java.lang.String) throws java.lang.Exception { oadd.org.apache.zookeeper.CreateMode v; oadd.org.apache.zookeeper.KeeperException$NodeExistsException v; org.slf4j.Logger v; java.io.IOException v; oadd.org.apache.curator.framework.CuratorFramework v; java.lang.Exception v; oadd.org.apache.curator.framework.api.CreateBuilder v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; java.lang.Object v; java.lang.String v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: java.lang.String; label: v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u znode already exists !!"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u znode could not be created !!"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch oadd.org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label; catch java.lang.Exception from label to label with label; } protected int getDelegationTokenSeqNum() { int v; oadd.org.apache.curator.framework.recipes.shared.SharedCount v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v = v.; v = virtualinvoke v.(); return v; } private void incrSharedCount(oadd.org.apache.curator.framework.recipes.shared.SharedCount) throws java.lang.Exception { oadd.org.apache.curator.framework.recipes.shared.SharedCount v; oadd.org.apache.curator.framework.recipes.shared.VersionedValue v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v; java.lang.Object v; boolean v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.curator.framework.recipes.shared.SharedCount; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1; v = virtualinvoke v.(v, v); if v == 0 goto label; return; } protected int incrementDelegationTokenSeqNum() { oadd.org.apache.curator.framework.recipes.shared.SharedCount v, v; org.slf4j.Logger v; java.lang.RuntimeException v; java.lang.Exception v; java.lang.InterruptedException v; java.lang.Thread v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; label: v = v.; specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Thread interrupted while performing token counter increment", v); v = staticinvoke (); virtualinvoke v.(); goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not increment shared counter !!", v); throw v; label: v = v.; v = virtualinvoke v.(); return v; catch java.lang.InterruptedException from label to label with label; catch java.lang.Exception from label to label with label; } protected void setDelegationTokenSeqNum(int) { oadd.org.apache.curator.framework.recipes.shared.SharedCount v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; java.lang.RuntimeException v; java.lang.Exception v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: int; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not set shared counter !!", v); throw v; label: return; catch java.lang.Exception from label to label with label; } protected int getCurrentKeyId() { int v; oadd.org.apache.curator.framework.recipes.shared.SharedCount v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v = v.; v = virtualinvoke v.(); return v; } protected int incrementCurrentKeyId() { oadd.org.apache.curator.framework.recipes.shared.SharedCount v, v; org.slf4j.Logger v; java.lang.RuntimeException v; java.lang.Exception v; java.lang.InterruptedException v; java.lang.Thread v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; label: v = v.; specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Thread interrupted while performing keyId increment", v); v = staticinvoke (); virtualinvoke v.(); goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not increment shared keyId counter !!", v); throw v; label: v = v.; v = virtualinvoke v.(); return v; catch java.lang.InterruptedException from label to label with label; catch java.lang.Exception from label to label with label; } protected oadd.org.apache.hadoop.security.token.delegation.DelegationKey getDelegationKey(int) { org.slf4j.Logger v; java.io.IOException v; java.lang.Integer v, v; java.util.Map v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; java.lang.Object v; java.lang.String v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: int; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; label: v = specialinvoke v.(v); if v == null goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Error retrieving key [\u] from ZK"); interfaceinvoke v.(v, v); label: return v; catch java.io.IOException from label to label with label; } private oadd.org.apache.hadoop.security.token.delegation.DelegationKey getKeyFromZK(int) throws java.io.IOException { java.io.DataInputStream v; oadd.org.apache.curator.framework.api.GetDataBuilder v; java.io.ByteArrayInputStream v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v; java.lang.String v, v, v; oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; org.slf4j.Logger v; java.io.IOException v; oadd.org.apache.zookeeper.KeeperException$NoNodeException v; oadd.org.apache.curator.framework.CuratorFramework v; java.lang.Exception v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: int; v = dynamicinvoke "makeConcatWithConstants" (v) ("DK_\u0001"); v = staticinvoke ("/ZKDTSMMasterKeyRoot", v); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = lengthof v; if v != 0 goto label; label: return null; label: v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = new oadd.org.apache.hadoop.security.token.delegation.DelegationKey; specialinvoke v.()>(); virtualinvoke v.(v); label: return v; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("No node in path [\u]"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return null; catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label; catch oadd.org.apache.zookeeper.KeeperException$NoNodeException 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; } protected oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) { org.slf4j.Logger v; java.io.IOException v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v; java.util.Map v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; java.lang.Object v; java.lang.String v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier; v = v.; v = interfaceinvoke v.(v); if v != null goto label; label: v = specialinvoke v.(v); if v == null goto label; v = v.; interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Error retrieving tokenInfo [\u] from ZK"); interfaceinvoke v.(v, v); label: return v; catch java.io.IOException from label to label with label; } private synchronized void syncLocalCacheWithZk(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) { org.slf4j.Logger v; java.io.IOException v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v; java.util.Map v, v, v, v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v; java.lang.String v; boolean v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier; label: v = specialinvoke v.(v); if v == null goto label; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.(v, v); goto label; label: if v != null goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Error retrieving tokenInfo [\u] from ZK"); interfaceinvoke v.(v, v); label: return; catch java.io.IOException from label to label with label; } private oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfoFromZK(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) throws java.io.IOException { oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier; v = specialinvoke v.(v, 0); return v; } private oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfoFromZK(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, boolean) throws java.io.IOException { byte[] v; java.io.DataInputStream v; long v; oadd.org.apache.curator.framework.api.GetDataBuilder v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v; oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v; java.io.ByteArrayInputStream v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v, v, v, v; java.lang.String v, v, v; boolean v; org.slf4j.Logger v; java.io.IOException v; oadd.org.apache.zookeeper.KeeperException$NoNodeException v; oadd.org.apache.curator.framework.CuratorFramework v; java.lang.Exception v; oadd.org.apache.hadoop.security.token.TokenIdentifier v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier; v := @parameter: boolean; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DT_\u0001"); v = staticinvoke ("/ZKDTSMTokensRoot", v); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = lengthof v; if v != 0 goto label; label: return null; label: v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (byte)[v]; v = virtualinvoke v.(v, 0, v); v = (int) -1; if v <= v goto label; v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation; specialinvoke v.(long,byte[])>(v, v); label: return v; label: v := @caughtexception; if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("No node in path [\u]"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return null; catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label; catch oadd.org.apache.zookeeper.KeeperException$NoNodeException 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; } protected void storeDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException { oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey; specialinvoke v.(v, 0); return; } protected void updateDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException { oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey; specialinvoke v.(v, 1); return; } private void addOrUpdateDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey, boolean) throws java.io.IOException { byte[] v, v; oadd.org.apache.zookeeper.CreateMode v; oadd.org.apache.curator.framework.api.SetDataBuilder v; java.io.DataOutputStream v; oadd.org.apache.curator.framework.api.CreateBuilder v; boolean v, v; oadd.org.apache.zookeeper.KeeperException$NodeExistsException v; oadd.org.apache.curator.framework.CuratorFramework v, v, v; java.lang.Exception v; java.lang.Throwable v; java.io.ByteArrayOutputStream v; oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v, v; java.lang.String v, v, v, v, v, v; oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; org.slf4j.Logger v, v, v, v, v; java.io.IOException v; oadd.org.apache.curator.framework.api.ExistsBuilder v; java.lang.Object v, v, v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey; v := @parameter: boolean; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DK_\u0001"); v = staticinvoke ("/ZKDTSMMasterKeyRoot", v); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Storing ZKDTSMDelegationKey_\u0001"); interfaceinvoke v.(v); label: virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); v = (int) -1; virtualinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Key with path [\u] already exists.. Updating !!"); interfaceinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Updating non existent Key path [\u].. Adding new !!"); interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u znode already exists !!"); interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v := @caughtexception; virtualinvoke v.(); throw v; label: return; catch oadd.org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label; catch java.lang.Exception 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 void removeStoredMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) { oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager v; int v, v; java.lang.String v, v, v, v, v, v; oadd.org.apache.hadoop.security.token.delegation.DelegationKey v; boolean v; org.slf4j.Logger v, v, v, v, v; oadd.org.apache.zookeeper.KeeperException$NoNodeException v; oadd.org.apache.curator.framework.CuratorFramework v, v, v; java.lang.Exception v; oadd.org.apache.curator.framework.api.ExistsBuilder v, v; oadd.org.apache.curator.framework.api.ChildrenDeletable v; java.lang.Object v, v; oadd.org.apache.curator.framework.api.DeleteBuilder v; v := @this: oadd.org.apache.hadoop.security.token.delegation.ZKDelegationTokenSecretManager; v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("DK_\u0001"); v = staticinvoke ("/ZKDTSMMasterKeyRoot", v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Removing ZKDTSMDelegationKey_\u0001"); interfaceinvoke v.