public class oadd.org.apache.hadoop.security.token.Token extends java.lang.Object implements oadd.org.apache.hadoop.io.Writable
{
public static final org.slf4j.Logger LOG;
private static java.util.Map tokenKindMap;
private byte[] identifier;
private byte[] password;
private oadd.org.apache.hadoop.io.Text kind;
private oadd.org.apache.hadoop.io.Text service;
private oadd.org.apache.hadoop.security.token.TokenRenewer renewer;
private static java.util.ServiceLoader renewers;
private static final oadd.org.apache.hadoop.security.token.TokenRenewer TRIVIAL_RENEWER;
public void <init>(oadd.org.apache.hadoop.security.token.TokenIdentifier, oadd.org.apache.hadoop.security.token.SecretManager)
{
byte[] v, v;
oadd.org.apache.hadoop.security.token.SecretManager v;
oadd.org.apache.hadoop.security.token.TokenIdentifier v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.security.token.TokenIdentifier;
v := @parameter: oadd.org.apache.hadoop.security.token.SecretManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.SecretManager: byte[] createPassword(oadd.org.apache.hadoop.security.token.TokenIdentifier)>(v);
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenIdentifier: byte[] getBytes()>();
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenIdentifier: oadd.org.apache.hadoop.io.Text getKind()>();
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
v = new oadd.org.apache.hadoop.io.Text;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public void setID(byte[])
{
byte[] v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: byte[];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
return;
}
public void setPassword(byte[])
{
byte[] v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: byte[];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
return;
}
public void <init>(byte[], byte[], oadd.org.apache.hadoop.io.Text, oadd.org.apache.hadoop.io.Text)
{
byte[] v, v, v, v;
oadd.org.apache.hadoop.io.Text v, v, v, v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: oadd.org.apache.hadoop.io.Text;
v := @parameter: oadd.org.apache.hadoop.io.Text;
specialinvoke v.<java.lang.Object: void <init>()>();
if v != null goto label;
v = newarray (byte)[0];
goto label;
label:
v = v;
label:
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
if v != null goto label;
v = newarray (byte)[0];
goto label;
label:
v = v;
label:
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
if v != null goto label;
v = new oadd.org.apache.hadoop.io.Text;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>()>();
goto label;
label:
v = v;
label:
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
if v != null goto label;
v = new oadd.org.apache.hadoop.io.Text;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>()>();
goto label;
label:
v = v;
label:
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public void <init>()
{
byte[] v, v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
specialinvoke v.<java.lang.Object: void <init>()>();
v = newarray (byte)[0];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
v = newarray (byte)[0];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
v = new oadd.org.apache.hadoop.io.Text;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
v = new oadd.org.apache.hadoop.io.Text;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>()>();
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public void <init>(oadd.org.apache.hadoop.security.token.Token)
{
byte[] v, v;
oadd.org.apache.hadoop.io.Text v, v, v, v;
oadd.org.apache.hadoop.security.token.Token v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.security.token.Token;
specialinvoke v.<java.lang.Object: void <init>()>();
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = virtualinvoke v.<java.lang.Object: java.lang.Object clone()>();
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v = virtualinvoke v.<java.lang.Object: java.lang.Object clone()>();
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
v = new oadd.org.apache.hadoop.io.Text;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>(oadd.org.apache.hadoop.io.Text)>(v);
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
v = new oadd.org.apache.hadoop.io.Text;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>(oadd.org.apache.hadoop.io.Text)>(v);
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public oadd.org.apache.hadoop.security.token.Token copyToken()
{
oadd.org.apache.hadoop.security.token.Token v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = new oadd.org.apache.hadoop.security.token.Token;
specialinvoke v.<oadd.org.apache.hadoop.security.token.Token: void <init>(oadd.org.apache.hadoop.security.token.Token)>(v);
return v;
}
public void <init>(oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto)
{
byte[] v, v, v, v;
oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.com.google.protobuf.ByteString v, v, v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto: oadd.com.google.protobuf.ByteString getIdentifier()>();
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: byte[] toByteArray()>();
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto: oadd.com.google.protobuf.ByteString getPassword()>();
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: byte[] toByteArray()>();
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
v = new oadd.org.apache.hadoop.io.Text;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto: oadd.com.google.protobuf.ByteString getKindBytes()>();
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: byte[] toByteArray()>();
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>(byte[])>(v);
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
v = new oadd.org.apache.hadoop.io.Text;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto: oadd.com.google.protobuf.ByteString getServiceBytes()>();
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: byte[] toByteArray()>();
specialinvoke v.<oadd.org.apache.hadoop.io.Text: void <init>(byte[])>(v);
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto toTokenProto()
{
byte[] v, v, v, v;
oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto v;
int v, v;
oadd.org.apache.hadoop.io.Text v, v, v, v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.com.google.protobuf.ByteString v, v, v, v;
oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = staticinvoke <oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder newBuilder()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getIdentifier()>();
v = staticinvoke <oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.ByteString copyFrom(byte[])>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder setIdentifier(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: byte[] getPassword()>();
v = staticinvoke <oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.ByteString copyFrom(byte[])>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder setPassword(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text getKind()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: byte[] getBytes()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text getKind()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: int getLength()>();
v = staticinvoke <oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.ByteString copyFrom(byte[],int,int)>(v, 0, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder setKindBytes(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text getService()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: byte[] getBytes()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text getService()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: int getLength()>();
v = staticinvoke <oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.ByteString copyFrom(byte[],int,int)>(v, 0, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder setServiceBytes(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto$Builder: oadd.org.apache.hadoop.security.proto.SecurityProtos$TokenProto build()>();
return v;
}
public byte[] getIdentifier()
{
byte[] v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
return v;
}
private static java.lang.Class getClassForIdentifier(oadd.org.apache.hadoop.io.Text)
{
java.lang.Throwable v;
java.lang.Error v;
java.util.HashMap v;
java.util.Map v, v, v;
boolean v;
org.slf4j.Logger v, v;
java.util.Iterator v;
oadd.org.apache.hadoop.io.Text v, v;
java.util.ServiceLoader v;
java.lang.Class v;
java.lang.Object v, v;
v := @parameter: oadd.org.apache.hadoop.io.Text;
entermonitor class "Loadd/org/apache/hadoop/security/token/Token;";
label:
v = <oadd.org.apache.hadoop.security.token.Token: java.util.Map tokenKindMap>;
if v != null goto label;
v = staticinvoke <oadd.com.google.common.collect.Maps: java.util.HashMap newHashMap()>();
<oadd.org.apache.hadoop.security.token.Token: java.util.Map tokenKindMap> = v;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Loadd/org/apache/hadoop/security/token/TokenIdentifier;");
v = virtualinvoke v.<java.util.ServiceLoader: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <oadd.org.apache.hadoop.security.token.Token: java.util.Map tokenKindMap>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenIdentifier: oadd.org.apache.hadoop.io.Text getKind()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.security.token.Token: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Failed to load token identifier implementation", v);
goto label;
label:
v = <oadd.org.apache.hadoop.security.token.Token: java.util.Map tokenKindMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
exitmonitor class "Loadd/org/apache/hadoop/security/token/Token;";
label:
goto label;
label:
v := @caughtexception;
exitmonitor class "Loadd/org/apache/hadoop/security/token/Token;";
throw v;
label:
if v != null goto label;
v = <oadd.org.apache.hadoop.security.token.Token: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Cannot find class for token kind {}", v);
return null;
label:
return v;
catch java.util.ServiceConfigurationError from label to label with label;
catch java.lang.LinkageError from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.hadoop.security.token.TokenIdentifier decodeIdentifier() throws java.io.IOException
{
byte[] v;
java.io.DataInputStream v;
java.io.ByteArrayInputStream v;
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
java.lang.Class v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text getKind()>();
v = staticinvoke <oadd.org.apache.hadoop.security.token.Token: java.lang.Class getClassForIdentifier(oadd.org.apache.hadoop.io.Text)>(v);
if v != null goto label;
return null;
label:
v = staticinvoke <oadd.org.apache.hadoop.util.ReflectionUtils: java.lang.Object newInstance(java.lang.Class,oadd.org.apache.hadoop.conf.Configuration)>(v, null);
v = new java.io.ByteArrayInputStream;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
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);
virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenIdentifier: void readFields(java.io.DataInput)>(v);
virtualinvoke v.<java.io.DataInputStream: void close()>();
return v;
}
public byte[] getPassword()
{
byte[] v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
return v;
}
public synchronized oadd.org.apache.hadoop.io.Text getKind()
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
return v;
}
public synchronized void setKind(oadd.org.apache.hadoop.io.Text)
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.io.Text;
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind> = v;
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer> = null;
return;
}
public oadd.org.apache.hadoop.io.Text getService()
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
return v;
}
public void setService(oadd.org.apache.hadoop.io.Text)
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.io.Text;
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service> = v;
return;
}
public boolean isPrivate()
{
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
return 0;
}
public boolean isPrivateCloneOf(oadd.org.apache.hadoop.io.Text)
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.io.Text;
return 0;
}
public oadd.org.apache.hadoop.security.token.Token privateClone(oadd.org.apache.hadoop.io.Text)
{
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.Token$PrivateToken v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.io.Text;
v = new oadd.org.apache.hadoop.security.token.Token$PrivateToken;
specialinvoke v.<oadd.org.apache.hadoop.security.token.Token$PrivateToken: void <init>(oadd.org.apache.hadoop.security.token.Token,oadd.org.apache.hadoop.io.Text)>(v, v);
return v;
}
public void readFields(java.io.DataInput) throws java.io.IOException
{
byte[] v, v, v, v, v, v, v, v;
int v, v, v, v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
java.io.DataInput v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.io.DataInput;
v = staticinvoke <oadd.org.apache.hadoop.io.WritableUtils: int readVInt(java.io.DataInput)>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = lengthof v;
if v == v goto label;
label:
v = newarray (byte)[v];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier> = v;
label:
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
interfaceinvoke v.<java.io.DataInput: void readFully(byte[])>(v);
v = staticinvoke <oadd.org.apache.hadoop.io.WritableUtils: int readVInt(java.io.DataInput)>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v = lengthof v;
if v == v goto label;
label:
v = newarray (byte)[v];
v.<oadd.org.apache.hadoop.security.token.Token: byte[] password> = v;
label:
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
interfaceinvoke v.<java.io.DataInput: void readFully(byte[])>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
virtualinvoke v.<oadd.org.apache.hadoop.io.Text: void readFields(java.io.DataInput)>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
virtualinvoke v.<oadd.org.apache.hadoop.io.Text: void readFields(java.io.DataInput)>(v);
return;
}
public void write(java.io.DataOutput) throws java.io.IOException
{
byte[] v, v, v, v;
java.io.DataOutput v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
int v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.io.DataOutput;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = lengthof v;
staticinvoke <oadd.org.apache.hadoop.io.WritableUtils: void writeVInt(java.io.DataOutput,int)>(v, v);
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
interfaceinvoke v.<java.io.DataOutput: void write(byte[])>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v = lengthof v;
staticinvoke <oadd.org.apache.hadoop.io.WritableUtils: void writeVInt(java.io.DataOutput,int)>(v, v);
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
interfaceinvoke v.<java.io.DataOutput: void write(byte[])>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
virtualinvoke v.<oadd.org.apache.hadoop.io.Text: void write(java.io.DataOutput)>(v);
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
virtualinvoke v.<oadd.org.apache.hadoop.io.Text: void write(java.io.DataOutput)>(v);
return;
}
private static java.lang.String encodeWritable(oadd.org.apache.hadoop.io.Writable) throws java.io.IOException
{
byte[] v, v;
oadd.org.apache.hadoop.io.Writable v;
oadd.org.apache.commons.codec.binary.Base v;
oadd.org.apache.hadoop.io.DataOutputBuffer v;
int v, v;
java.lang.String v;
v := @parameter: oadd.org.apache.hadoop.io.Writable;
v = new oadd.org.apache.hadoop.io.DataOutputBuffer;
specialinvoke v.<oadd.org.apache.hadoop.io.DataOutputBuffer: void <init>()>();
interfaceinvoke v.<oadd.org.apache.hadoop.io.Writable: void write(java.io.DataOutput)>(v);
v = new oadd.org.apache.commons.codec.binary.Base;
specialinvoke v.<oadd.org.apache.commons.codec.binary.Base64: void <init>(int,byte[],boolean)>(0, null, 1);
v = virtualinvoke v.<oadd.org.apache.hadoop.io.DataOutputBuffer: int getLength()>();
v = newarray (byte)[v];
v = virtualinvoke v.<oadd.org.apache.hadoop.io.DataOutputBuffer: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.DataOutputBuffer: int getLength()>();
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
v = virtualinvoke v.<oadd.org.apache.commons.codec.binary.Base64: java.lang.String encodeToString(byte[])>(v);
return v;
}
private static void decodeWritable(oadd.org.apache.hadoop.io.Writable, java.lang.String) throws java.io.IOException
{
byte[] v;
int v;
oadd.org.apache.hadoop.io.DataInputBuffer v;
oadd.org.apache.hadoop.io.Writable v;
oadd.org.apache.commons.codec.binary.Base v;
java.lang.String v;
oadd.org.apache.hadoop.HadoopIllegalArgumentException v;
v := @parameter: oadd.org.apache.hadoop.io.Writable;
v := @parameter: java.lang.String;
if v != null goto label;
v = new oadd.org.apache.hadoop.HadoopIllegalArgumentException;
specialinvoke v.<oadd.org.apache.hadoop.HadoopIllegalArgumentException: void <init>(java.lang.String)>("Invalid argument, newValue is null");
throw v;
label:
v = new oadd.org.apache.commons.codec.binary.Base;
specialinvoke v.<oadd.org.apache.commons.codec.binary.Base64: void <init>(int,byte[],boolean)>(0, null, 1);
v = new oadd.org.apache.hadoop.io.DataInputBuffer;
specialinvoke v.<oadd.org.apache.hadoop.io.DataInputBuffer: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.commons.codec.binary.Base64: byte[] decode(java.lang.String)>(v);
v = lengthof v;
virtualinvoke v.<oadd.org.apache.hadoop.io.DataInputBuffer: void reset(byte[],int)>(v, v);
interfaceinvoke v.<oadd.org.apache.hadoop.io.Writable: void readFields(java.io.DataInput)>(v);
return;
}
public java.lang.String encodeToUrlString() throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.Token v;
java.lang.String v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = staticinvoke <oadd.org.apache.hadoop.security.token.Token: java.lang.String encodeWritable(oadd.org.apache.hadoop.io.Writable)>(v);
return v;
}
public void decodeFromUrlString(java.lang.String) throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.Token v;
java.lang.String v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.lang.String;
staticinvoke <oadd.org.apache.hadoop.security.token.Token: void decodeWritable(oadd.org.apache.hadoop.io.Writable,java.lang.String)>(v, v);
return;
}
public boolean equals(java.lang.Object)
{
byte[] v, v, v, v;
boolean v, v, v, v, v;
oadd.org.apache.hadoop.io.Text v, v, v, v;
oadd.org.apache.hadoop.security.token.Token v;
java.lang.Class v, v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.lang.Object;
if v != v goto label;
return 1;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == v goto label;
label:
return 0;
label:
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = staticinvoke <java.security.MessageDigest: boolean isEqual(byte[],byte[])>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v = staticinvoke <java.security.MessageDigest: boolean isEqual(byte[],byte[])>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int hashCode()
{
byte[] v, v;
int v, v;
oadd.org.apache.hadoop.security.token.Token v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v = lengthof v;
v = staticinvoke <oadd.org.apache.hadoop.io.WritableComparator: int hashBytes(byte[],int)>(v, v);
return v;
}
private static void addBinaryBuffer(java.lang.StringBuilder, byte[])
{
byte[] v;
short v;
byte v;
int v, v, v;
java.lang.StringBuilder v;
java.lang.String v;
v := @parameter: java.lang.StringBuilder;
v := @parameter: byte[];
v = 0;
label:
v = lengthof v;
if v >= v goto label;
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(32);
label:
v = v[v];
v = 255 & v;
v = staticinvoke <java.lang.Integer: java.lang.String toHexString(int)>(v);
v = virtualinvoke v.<java.lang.String: int length()>();
if v >= 2 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(48);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v + 1;
goto label;
label:
return;
}
private void identifierToString(java.lang.StringBuilder)
{
java.lang.Throwable v;
byte[] v, v, v;
oadd.org.apache.hadoop.security.token.Token v;
java.io.IOException v;
oadd.org.apache.hadoop.security.token.TokenIdentifier v;
java.lang.StringBuilder v, v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: java.lang.StringBuilder;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenIdentifier decodeIdentifier()>();
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("(");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(")");
goto label;
label:
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
staticinvoke <oadd.org.apache.hadoop.security.token.Token: void addBinaryBuffer(java.lang.StringBuilder,byte[])>(v, v);
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
staticinvoke <oadd.org.apache.hadoop.security.token.Token: void addBinaryBuffer(java.lang.StringBuilder,byte[])>(v, v);
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
staticinvoke <oadd.org.apache.hadoop.security.token.Token: void addBinaryBuffer(java.lang.StringBuilder,byte[])>(v, v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String toString()
{
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
java.lang.StringBuilder v;
java.lang.String v, v, v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("Kind: ");
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", Service: ");
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text service>;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", Ident: ");
specialinvoke v.<oadd.org.apache.hadoop.security.token.Token: void identifierToString(java.lang.StringBuilder)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public java.lang.String buildCacheKey()
{
byte[] v, v, v, v;
oadd.org.apache.hadoop.io.Text v;
oadd.org.apache.hadoop.security.token.Token v;
java.util.UUID v;
byte[][] v;
java.lang.String v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = newarray (byte[])[3];
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.Text: byte[] getBytes()>();
v[0] = v;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] identifier>;
v[1] = v;
v = v.<oadd.org.apache.hadoop.security.token.Token: byte[] password>;
v[2] = v;
v = staticinvoke <oadd.com.google.common.primitives.Bytes: byte[] concat(byte[][])>(v);
v = staticinvoke <java.util.UUID: java.util.UUID nameUUIDFromBytes(byte[])>(v);
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
return v;
}
private synchronized oadd.org.apache.hadoop.security.token.TokenRenewer getRenewer() throws java.io.IOException
{
java.lang.Throwable v;
java.util.ServiceConfigurationError v;
oadd.org.apache.hadoop.security.token.TokenRenewer v, v, v, v, v;
boolean v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
oadd.org.apache.hadoop.io.Text v, v;
oadd.org.apache.hadoop.security.token.Token v;
java.util.ServiceLoader v, v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer>;
return v;
label:
v = <oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer TRIVIAL_RENEWER>;
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer> = v;
v = <oadd.org.apache.hadoop.security.token.Token: java.util.ServiceLoader renewers>;
entermonitor v;
label:
v = <oadd.org.apache.hadoop.security.token.Token: java.util.ServiceLoader renewers>;
v = virtualinvoke v.<java.util.ServiceLoader: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenRenewer: boolean handleKind(oadd.org.apache.hadoop.io.Text)>(v);
if v == 0 goto label;
v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer> = v;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer>;
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.security.token.Token: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Failed to load token renewer implementation", v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = <oadd.org.apache.hadoop.security.token.Token: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.io.Text kind>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("No TokenRenewer defined for token kind {}", v);
v = v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer renewer>;
return v;
catch java.util.ServiceConfigurationError 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;
}
public boolean isManaged() throws java.io.IOException
{
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenRenewer v;
boolean v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer getRenewer()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenRenewer: boolean isManaged(oadd.org.apache.hadoop.security.token.Token)>(v);
return v;
}
public long renew(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException, java.lang.InterruptedException
{
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenRenewer v;
long v;
oadd.org.apache.hadoop.conf.Configuration v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer getRenewer()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenRenewer: long renew(oadd.org.apache.hadoop.security.token.Token,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public void cancel(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException, java.lang.InterruptedException
{
oadd.org.apache.hadoop.security.token.Token v;
oadd.org.apache.hadoop.security.token.TokenRenewer v;
oadd.org.apache.hadoop.conf.Configuration v;
v := @this: oadd.org.apache.hadoop.security.token.Token;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = specialinvoke v.<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer getRenewer()>();
virtualinvoke v.<oadd.org.apache.hadoop.security.token.TokenRenewer: void cancel(oadd.org.apache.hadoop.security.token.Token,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return;
}
static void <clinit>()
{
java.util.ServiceLoader v;
oadd.org.apache.hadoop.security.token.Token$TrivialRenewer v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/security/token/Token;");
<oadd.org.apache.hadoop.security.token.Token: org.slf4j.Logger LOG> = v;
v = staticinvoke <java.util.ServiceLoader: java.util.ServiceLoader load(java.lang.Class)>(class "Loadd/org/apache/hadoop/security/token/TokenRenewer;");
<oadd.org.apache.hadoop.security.token.Token: java.util.ServiceLoader renewers> = v;
v = new oadd.org.apache.hadoop.security.token.Token$TrivialRenewer;
specialinvoke v.<oadd.org.apache.hadoop.security.token.Token$TrivialRenewer: void <init>()>();
<oadd.org.apache.hadoop.security.token.Token: oadd.org.apache.hadoop.security.token.TokenRenewer TRIVIAL_RENEWER> = v;
return;
}
}