public abstract class oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager extends oadd.org.apache.hadoop.security.token.SecretManager
{
private static final org.slf4j.Logger LOG;
protected final java.util.Map currentTokens;
protected int delegationTokenSequenceNumber;
protected final java.util.Map allKeys;
protected int currentId;
private oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey;
private long keyUpdateInterval;
private long tokenMaxLifetime;
private long tokenRemoverScanInterval;
private long tokenRenewInterval;
protected boolean storeTokenTrackingId;
private java.lang.Thread tokenRemoverThread;
protected volatile boolean running;
protected java.lang.Object noInterruptsLock;
static final boolean $assertionsDisabled;
private java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.lang.String v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("(\u)");
return v;
}
public void <init>(long, long, long, long)
{
java.util.HashMap v, v;
long v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int delegationTokenSequenceNumber> = 0;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int currentId> = 0;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Object noInterruptsLock> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long keyUpdateInterval> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenMaxLifetime> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenRenewInterval> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenRemoverScanInterval> = v;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean storeTokenTrackingId> = 0;
return;
}
public void startThreads() throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.util.Daemon v;
java.lang.Thread v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$ExpiredTokenRemover v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.com.google.common.base.Preconditions: void checkState(boolean)>(v);
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void updateCurrentKey()>();
entermonitor v;
label:
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running> = 1;
v = new oadd.org.apache.hadoop.util.Daemon;
v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$ExpiredTokenRemover;
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$ExpiredTokenRemover: void <init>(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager)>(v);
specialinvoke v.<oadd.org.apache.hadoop.util.Daemon: void <init>(java.lang.Runnable)>(v);
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Thread tokenRemoverThread> = v;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Thread tokenRemoverThread>;
virtualinvoke v.<java.lang.Thread: void start()>();
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 synchronized void reset()
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.util.Map v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void setCurrentKeyId(int)>(0);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
interfaceinvoke v.<java.util.Map: void clear()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void setDelegationTokenSeqNum(int)>(0);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
interfaceinvoke v.<java.util.Map: void clear()>();
return;
}
public synchronized void addKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException
{
java.io.IOException v;
java.lang.Integer v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.util.Map v;
int v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running>;
if v == 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Can\'t add delegation key to a running SecretManager.");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int getCurrentKeyId()>();
if v <= v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void setCurrentKeyId(int)>(v);
label:
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public synchronized oadd.org.apache.hadoop.security.token.delegation.DelegationKey[] getAllKeys()
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey[] v;
java.lang.Object[] v;
java.util.Collection v;
java.util.Map v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = newarray (oadd.org.apache.hadoop.security.token.delegation.DelegationKey)[0];
v = interfaceinvoke v.<java.util.Collection: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
protected void logUpdateMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
return;
}
protected void logExpireToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
return;
}
protected void storeNewMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
return;
}
protected void removeStoredMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
return;
}
protected void storeNewToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, long) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
long v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: long;
return;
}
protected void removeStoredToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
return;
}
protected void updateStoredToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, long) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
long v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: long;
return;
}
protected synchronized int getCurrentKeyId()
{
int v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int currentId>;
return v;
}
protected synchronized int incrementCurrentKeyId()
{
int v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int currentId>;
v = v + 1;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int currentId> = v;
return v;
}
protected synchronized void setCurrentKeyId(int)
{
int v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: int;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int currentId> = v;
return;
}
protected synchronized int getDelegationTokenSeqNum()
{
int v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int delegationTokenSequenceNumber>;
return v;
}
protected synchronized int incrementDelegationTokenSeqNum()
{
int v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int delegationTokenSequenceNumber>;
v = v + 1;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int delegationTokenSequenceNumber> = v;
return v;
}
protected synchronized void setDelegationTokenSeqNum(int)
{
int v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: int;
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int delegationTokenSequenceNumber> = v;
return;
}
protected oadd.org.apache.hadoop.security.token.delegation.DelegationKey getDelegationKey(int)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.util.Map v;
int v;
java.lang.Object v;
java.lang.Integer v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
protected void storeDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.util.Map v;
int v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
java.lang.Integer v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void storeNewMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)>(v);
return;
}
protected void updateDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.util.Map v;
int v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
java.lang.Integer v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
protected oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.util.Map v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
protected void storeToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.util.Map v;
long v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: long getRenewDate()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void storeNewToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier,long)>(v, v);
return;
}
protected void updateToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.util.Map v;
long v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: long getRenewDate()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void updateStoredToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier,long)>(v, v);
return;
}
public synchronized void addPersistedDelegationToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, long) throws java.io.IOException
{
byte[] v, v;
long v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v, v;
java.lang.Integer v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.util.Map v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v;
boolean v;
org.slf4j.Logger v;
java.io.IOException v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.lang.Object v;
javax.crypto.SecretKey v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running>;
if v == 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Can\'t add persisted delegation token to a running SecretManager.");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getMasterKeyId()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = null;
if v != null goto label;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No KEY found for persisted identifier, expiring stored token \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = 0L;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: byte[] getBytes()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: javax.crypto.SecretKey getKey()>();
v = staticinvoke <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: byte[] createPassword(byte[],javax.crypto.SecretKey)>(v, v);
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getSequenceNumber()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int getDelegationTokenSeqNum()>();
if v <= v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getSequenceNumber()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void setDelegationTokenSeqNum(int)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
if v != null goto label;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String getTrackingIdIfEnabled(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: void <init>(long,byte[],java.lang.String)>(v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new java.io.IOException;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Same delegation token being added twice: \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private void updateCurrentKey() throws java.io.IOException
{
java.lang.Throwable v, v;
org.slf4j.Logger v;
long v, v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
int v;
javax.crypto.SecretKey v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Updating the current master key for generating delegation tokens");
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int incrementCurrentKeyId()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = new oadd.org.apache.hadoop.security.token.delegation.DelegationKey;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long keyUpdateInterval>;
v = v + v;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenMaxLifetime>;
v = v + v;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: javax.crypto.SecretKey generateSecret()>();
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: void <init>(int,long,javax.crypto.SecretKey)>(v, v, v);
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void logUpdateMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)>(v);
entermonitor v;
label:
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey> = v;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void storeDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)>(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;
catch java.lang.Throwable from label to label with label;
}
void rollMasterKey() throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
long v, v, v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
entermonitor v;
label:
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void removeExpiredKeys()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenMaxLifetime>;
v = v + v;
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: void setExpiryDate(long)>(v);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void updateDelegationKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void updateCurrentKey()>();
return;
catch java.lang.Throwable from label to label with label;
}
private synchronized void removeExpiredKeys()
{
java.util.Iterator v;
java.util.Set v;
long v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
byte v;
java.util.Map v;
java.lang.Object v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map allKeys>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: long getExpiryDate()>();
v = v cmp v;
if v >= 0 goto label;
interfaceinvoke v.<java.util.Iterator: void remove()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void removeStoredMasterKey(oadd.org.apache.hadoop.security.token.delegation.DelegationKey)>(v);
goto label;
label:
return;
}
protected synchronized byte[] createPassword(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)
{
byte[] v, v;
long v, v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
int v, v, v;
java.lang.String v, v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v, v, v;
org.slf4j.Logger v, v;
java.io.IOException v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
javax.crypto.SecretKey v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: int incrementDelegationTokenSeqNum()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void setIssueDate(long)>(v);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenMaxLifetime>;
v = v + v;
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void setMaxDate(long)>(v);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void setMasterKeyId(int)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void setSequenceNumber(int)>(v);
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: int getKeyId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Creating password for identifier: \u, currentKey: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: byte[] getBytes()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey currentKey>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: javax.crypto.SecretKey getKey()>();
v = staticinvoke <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: byte[] createPassword(byte[],javax.crypto.SecretKey)>(v, v);
v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenRenewInterval>;
v = v + v;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String getTrackingIdIfEnabled(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: void <init>(long,byte[],java.lang.String)>(v, v, v);
label:
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void storeToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier,oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not store token \u0001!!");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
label:
return v;
catch java.io.IOException from label to label with label;
}
protected oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation checkToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) throws oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken
{
long v, v, v;
java.lang.AssertionError v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
byte v;
java.lang.String v, v, v, v, v, v;
boolean v, v;
oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean $assertionsDisabled>;
if v != 0 goto label;
v = staticinvoke <java.lang.Thread: boolean holdsLock(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("token \u can\'t be found in cache");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: long getRenewDate()>();
v = v cmp v;
if v >= 0 goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = staticinvoke <oadd.org.apache.hadoop.util.Time: java.lang.String formatTime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: long getRenewDate()>();
v = staticinvoke <oadd.org.apache.hadoop.util.Time: java.lang.String formatTime(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("token \u is expired, current time: \u expected renewal time: \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public synchronized byte[] retrievePassword(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier) throws oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
byte[] v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation checkToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: byte[] getPassword()>();
return v;
}
protected java.lang.String getTrackingIdIfEnabled(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean storeTokenTrackingId>;
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: java.lang.String getTrackingId()>();
return v;
label:
return null;
}
public synchronized java.lang.String getTokenTrackingId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.lang.String v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
if v != null goto label;
return null;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: java.lang.String getTrackingId()>();
return v;
}
public synchronized void verifyToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier, byte[]) throws oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken
{
byte[] v, v;
oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
v := @parameter: byte[];
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: byte[] retrievePassword(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = staticinvoke <java.security.MessageDigest: boolean isEqual(byte[],byte[])>(v, v);
if v != 0 goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("token \u is invalid, password doesn\'t match");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public synchronized long renewToken(oadd.org.apache.hadoop.security.token.Token, java.lang.String) throws oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken, java.io.IOException
{
byte[] v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation v, v;
byte v;
java.io.ByteArrayInputStream v;
java.util.Map v;
boolean v, v, v;
oadd.org.apache.hadoop.io.Text v, v, v, v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenIdentifier v;
javax.crypto.SecretKey v;
java.io.DataInputStream v;
long v, v, v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.security.token.delegation.DelegationKey v;
org.slf4j.Logger v;
oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken v, v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.AccessControlException v, v, v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.lang.String;
v = new java.io.ByteArrayInputStream;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getIdentifier()>();
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = new java.io.DataInputStream;
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.TokenIdentifier createIdentifier()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void readFields(java.io.DataInput)>(v);
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Token renewal for identifier: \u; total currentTokens \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: long getMaxDate()>();
v = v cmp v;
if v >= 0 goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: long getMaxDate()>();
v = staticinvoke <oadd.org.apache.hadoop.util.Time: java.lang.String formatTime(long)>(v);
v = staticinvoke <oadd.org.apache.hadoop.util.Time: java.lang.String formatTime(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u tried to renew an expired token \u max expiration date: \u currentTime: \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.io.Text getRenewer()>();
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.io.Text getRenewer()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new oadd.org.apache.hadoop.security.AccessControlException;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u tried to renew a token \u without a renewer");
specialinvoke v.<oadd.org.apache.hadoop.security.AccessControlException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.io.Text getRenewer()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new oadd.org.apache.hadoop.security.AccessControlException;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.io.Text getRenewer()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,oadd.org.apache.hadoop.io.Text)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u tries to renew a token \u with non-matching renewer \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.AccessControlException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getMasterKeyId()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.DelegationKey getDelegationKey(int)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getMasterKeyId()>();
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: int getSequenceNumber()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.lang.String,int)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to find master key for keyId=\u from cache. Failed to renew an unexpired token \u with sequenceNumber=\u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getIdentifier()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.DelegationKey: javax.crypto.SecretKey getKey()>();
v = staticinvoke <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: byte[] createPassword(byte[],javax.crypto.SecretKey)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getPassword()>();
v = staticinvoke <java.security.MessageDigest: boolean isEqual(byte[],byte[])>(v, v);
if v != 0 goto label;
v = new oadd.org.apache.hadoop.security.AccessControlException;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u is trying to renew a token \u with wrong password");
specialinvoke v.<oadd.org.apache.hadoop.security.AccessControlException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: long getMaxDate()>();
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: long tokenRenewInterval>;
v = v + v;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String getTrackingIdIfEnabled(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = new oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation;
specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: void <init>(long,byte[],java.lang.String)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation getTokenInfo(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Renewal request for unknown token \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void updateToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier,oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation)>(v, v);
return v;
}
public synchronized oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier cancelToken(oadd.org.apache.hadoop.security.token.Token, java.lang.String) throws java.io.IOException
{
byte[] v;
java.io.ByteArrayInputStream v;
java.util.Map v;
boolean v, v, v;
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenIdentifier v;
java.io.DataInputStream v;
oadd.org.apache.hadoop.security.HadoopKerberosName v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.security.UserGroupInformation v, v;
org.slf4j.Logger v;
oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken v, v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.AccessControlException v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.lang.String;
v = new java.io.ByteArrayInputStream;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getIdentifier()>();
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = new java.io.DataInputStream;
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: oadd.org.apache.hadoop.security.token.TokenIdentifier createIdentifier()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: void readFields(java.io.DataInput)>(v);
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Token cancellation requested for identifier: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.security.UserGroupInformation getUser()>();
if v != null goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Token with no owner \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.security.UserGroupInformation getUser()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.lang.String getUserName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier: oadd.org.apache.hadoop.io.Text getRenewer()>();
v = new oadd.org.apache.hadoop.security.HadoopKerberosName;
specialinvoke v.<oadd.org.apache.hadoop.security.HadoopKerberosName: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.HadoopKerberosName: java.lang.String getShortName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
label:
v = new oadd.org.apache.hadoop.security.AccessControlException;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u is not authorized to cancel the token \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.AccessControlException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Token not found \u0001");
specialinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager$InvalidToken: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void removeStoredToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
return v;
}
public static javax.crypto.SecretKey createSecretKey(byte[])
{
byte[] v;
javax.crypto.SecretKey v;
v := @parameter: byte[];
v = staticinvoke <oadd.org.apache.hadoop.security.token.SecretManager: javax.crypto.SecretKey createSecretKey(byte[])>(v);
return v;
}
private void removeExpiredToken() throws java.io.IOException
{
java.lang.Throwable v;
java.util.Iterator v;
java.util.Set v;
long v, v;
java.util.HashSet v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
byte v;
java.util.Map v;
java.lang.Object v, v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.util.Map currentTokens>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager$DelegationTokenInformation: long getRenewDate()>();
v = v cmp v;
if v >= 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void logExpireTokens(java.util.Collection)>(v);
return;
catch java.lang.Throwable from label to label with label;
}
protected void logExpireTokens(java.util.Collection) throws java.io.IOException
{
org.slf4j.Logger v;
java.util.Iterator v;
java.util.Collection v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.lang.Object v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: java.util.Collection;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void logExpireToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.String formatTokenId(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Removing expired token \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: void removeStoredToken(oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier)>(v);
goto label;
label:
return;
}
public void stopThreads()
{
java.lang.Throwable v;
org.slf4j.Logger v, v;
java.lang.RuntimeException v;
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
java.lang.InterruptedException v;
java.lang.Thread v, v, v;
java.lang.Object v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Stopping expired delegation token remover thread");
label:
v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running> = 0;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Thread tokenRemoverThread>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Object noInterruptsLock>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Thread tokenRemoverThread>;
virtualinvoke v.<java.lang.Thread: void interrupt()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: java.lang.Thread tokenRemoverThread>;
virtualinvoke v.<java.lang.Thread: void join()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to join on token removal thread", v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public synchronized boolean isRunning()
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v = v.<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean running>;
return v;
}
public oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier decodeTokenIdentifier(oadd.org.apache.hadoop.security.token.Token) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenIdentifier v;
v := @this: oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
v := @parameter: oadd.org.apache.hadoop.security.token.Token;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenIdentifier decodeIdentifier()>();
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.lang.Class v;
boolean v, v;
v = class "Loadd/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: boolean $assertionsDisabled> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/security/token/delegation/AbstractDelegationTokenSecretManager;");
<oadd.org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager: org.slf4j.Logger LOG> = v;
return;
}
}