public class oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler extends java.lang.Object implements oadd.org.apache.drill.exec.rpc.RequestHandler
{
private static final org.slf4j.Logger logger;
private static final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap RESPONSE_PROCESSORS;
private final oadd.org.apache.drill.exec.rpc.RequestHandler requestHandler;
private final int saslRequestTypeValue;
private final oadd.com.google.protobuf.Internal$EnumLite saslResponseType;
private static final oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage SASL_FAILED_MESSAGE;
public void <init>(oadd.org.apache.drill.exec.rpc.RequestHandler, int, oadd.com.google.protobuf.Internal$EnumLite)
{
int v;
oadd.com.google.protobuf.Internal$EnumLite v;
oadd.org.apache.drill.exec.rpc.RequestHandler v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler v;
v := @this: oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler;
v := @parameter: oadd.org.apache.drill.exec.rpc.RequestHandler;
v := @parameter: int;
v := @parameter: oadd.com.google.protobuf.Internal$EnumLite;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.org.apache.drill.exec.rpc.RequestHandler requestHandler> = v;
v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: int saslRequestTypeValue> = v;
v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.com.google.protobuf.Internal$EnumLite saslResponseType> = v;
return;
}
public void handle(oadd.org.apache.drill.exec.rpc.ServerConnection, int, oadd.io.netty.buffer.ByteBuf, oadd.io.netty.buffer.ByteBuf, oadd.org.apache.drill.exec.rpc.ResponseSender) throws oadd.org.apache.drill.exec.rpc.RpcException
{
java.net.SocketAddress v;
oadd.io.netty.buffer.ByteBufInputStream v;
oadd.org.apache.drill.exec.rpc.RpcException v;
javax.security.sasl.SaslException v;
java.lang.Integer v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler v;
java.lang.Exception v;
java.lang.Object[] v;
oadd.com.google.protobuf.InvalidProtocolBufferException v;
oadd.org.apache.drill.exec.rpc.ServerConnection v;
oadd.com.google.protobuf.Parser v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus v, v;
int v, v;
oadd.com.google.protobuf.Internal$EnumLite v, v, v, v;
java.lang.String v, v, v;
oadd.io.netty.buffer.ByteBuf v, v;
oadd.org.apache.drill.exec.rpc.RequestHandler v;
org.slf4j.Logger v, v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
java.lang.Object v, v;
oadd.org.apache.drill.exec.rpc.ResponseSender v;
v := @this: oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler;
v := @parameter: oadd.org.apache.drill.exec.rpc.ServerConnection;
v := @parameter: int;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: oadd.org.apache.drill.exec.rpc.ResponseSender;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.net.SocketAddress getRemoteAddress()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: int saslRequestTypeValue>;
if v != v goto label;
label:
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage: oadd.com.google.protobuf.Parser PARSER>;
v = new oadd.io.netty.buffer.ByteBufInputStream;
specialinvoke v.<oadd.io.netty.buffer.ByteBufInputStream: void <init>(oadd.io.netty.buffer.ByteBuf)>(v);
v = interfaceinvoke v.<oadd.com.google.protobuf.Parser: java.lang.Object parseFrom(java.io.InputStream)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.com.google.protobuf.Internal$EnumLite saslResponseType>;
staticinvoke <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: void handleAuthFailure(oadd.org.apache.drill.exec.rpc.ServerConnection,oadd.org.apache.drill.exec.rpc.ResponseSender,java.lang.Exception,oadd.com.google.protobuf.Internal$EnumLite)>(v, v, v, v);
return;
label:
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus getStatus()>();
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Received SASL message {} from {}", v, v);
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap RESPONSE_PROCESSORS>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus getStatus()>();
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Unknown message type from client from {}. Will stop authentication.", v);
v = new javax.security.sasl.SaslException;
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String)>("Received unexpected message");
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.com.google.protobuf.Internal$EnumLite saslResponseType>;
staticinvoke <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: void handleAuthFailure(oadd.org.apache.drill.exec.rpc.ServerConnection,oadd.org.apache.drill.exec.rpc.ResponseSender,java.lang.Exception,oadd.com.google.protobuf.Internal$EnumLite)>(v, v, v, v);
return;
label:
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.org.apache.drill.exec.rpc.RequestHandler requestHandler>;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.com.google.protobuf.Internal$EnumLite saslResponseType>;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext: void <init>(oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage,oadd.org.apache.drill.exec.rpc.ServerConnection,oadd.org.apache.drill.exec.rpc.ResponseSender,oadd.org.apache.drill.exec.rpc.RequestHandler,oadd.com.google.protobuf.Internal$EnumLite)>(v, v, v, v, v);
label:
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseProcessor: void process(oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.com.google.protobuf.Internal$EnumLite saslResponseType>;
staticinvoke <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: void handleAuthFailure(oadd.org.apache.drill.exec.rpc.ServerConnection,oadd.org.apache.drill.exec.rpc.ResponseSender,java.lang.Exception,oadd.com.google.protobuf.Internal$EnumLite)>(v, v, v, v);
goto label;
label:
v = new oadd.org.apache.drill.exec.rpc.RpcException;
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v[1] = v;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.lang.String getEncryptionCtxtString()>();
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Request of type %d is not allowed without authentication. Client on %s must authenticate before making requests. Connection dropped. [Details: %s]", v);
specialinvoke v.<oadd.org.apache.drill.exec.rpc.RpcException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch oadd.com.google.protobuf.InvalidProtocolBufferException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static byte[] evaluateResponse(javax.security.sasl.SaslServer, byte[]) throws javax.security.sasl.SaslException
{
java.lang.Throwable v;
byte[] v;
java.lang.Object[] v, v;
javax.security.sasl.SaslException v, v;
java.lang.String v, v, v, v;
boolean v;
oadd.org.apache.hadoop.security.UserGroupInformation v;
java.lang.reflect.UndeclaredThrowableException v;
java.lang.Exception v;
java.lang.Object v;
javax.security.sasl.SaslServer v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$1 v;
v := @parameter: javax.security.sasl.SaslServer;
v := @parameter: byte[];
label:
v = staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: oadd.org.apache.hadoop.security.UserGroupInformation getLoginUser()>();
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$1;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$1: void <init>(javax.security.sasl.SaslServer,byte[])>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.security.UserGroupInformation: java.lang.Object doAs(java.security.PrivilegedExceptionAction)>(v);
label:
return v;
label:
v := @caughtexception;
v = new javax.security.sasl.SaslException;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getMechanismName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unexpected failure trying to authenticate using %s", v);
v = virtualinvoke v.<java.lang.reflect.UndeclaredThrowableException: java.lang.Throwable getCause()>();
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = v instanceof javax.security.sasl.SaslException;
if v == 0 goto label;
throw v;
label:
v = new javax.security.sasl.SaslException;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getMechanismName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unexpected failure trying to authenticate using %s", v);
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.reflect.UndeclaredThrowableException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
private static void handleSuccess(oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext, oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder, javax.security.sasl.SaslServer) throws java.io.IOException
{
java.net.SocketAddress v;
javax.security.sasl.SaslException v, v, v;
java.lang.Integer v;
boolean v, v, v, v, v;
oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection v, v;
oadd.org.apache.drill.exec.rpc.Response v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage v;
java.lang.Object[] v, v, v, v;
oadd.org.apache.drill.exec.rpc.ServerConnection v;
int v;
oadd.com.google.protobuf.Internal$EnumLite v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.drill.exec.rpc.RequestHandler v;
oadd.io.netty.buffer.ByteBuf[] v;
org.slf4j.Logger v, v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext v;
java.lang.RuntimeException v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder v;
java.lang.Object v, v;
javax.security.sasl.SaslServer v;
oadd.org.apache.drill.exec.rpc.ResponseSender v;
v := @parameter: oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder;
v := @parameter: javax.security.sasl.SaslServer;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext: oadd.org.apache.drill.exec.rpc.ServerConnection connection>;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext: oadd.org.apache.drill.exec.rpc.RequestHandler requestHandler>;
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: void changeHandlerTo(oadd.org.apache.drill.exec.rpc.RequestHandler)>(v);
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: void finalizeSaslSession()>();
label:
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.Object getNegotiatedProperty(java.lang.String)>("javax.security.sasl.qop");
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: boolean isEncryptionEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection: oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection PRIVACY>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection: java.lang.String getSaslQop()>();
goto label;
label:
v = <oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection: oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection AUTHENTICATION>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.security.SaslProperties$QualityOfProtection: java.lang.String getSaslQop()>();
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new javax.security.sasl.SaslException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Mismatch in negotiated QOP value: %s and Expected QOP value: %s", v);
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: boolean isEncryptionEnabled()>();
if v == 0 goto label;
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.Object getNegotiatedProperty(java.lang.String)>("javax.security.sasl.rawsendsize");
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
if v > 0 goto label;
v = new javax.security.sasl.SaslException;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Negotiated rawSendSize: %d is invalid. Please check the configured value of encryption.sasl.max_wrapped_size. It might be configured to a very small value.", v);
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String)>(v);
throw v;
label:
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: void setWrapSizeLimit(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new javax.security.sasl.SaslException;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<java.lang.RuntimeException: java.lang.String getMessage()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unexpected failure while retrieving negotiated property values (%s)", v);
specialinvoke v.<javax.security.sasl.SaslException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[4];
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getAuthorizationID()>();
v[0] = v;
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getMechanismName()>();
v[1] = v;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.net.SocketAddress getRemoteAddress()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v[2] = v;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.lang.String getEncryptionCtxtString()>();
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object[])>("Authenticated {} successfully using {} from {} with encryption context {}", v);
label:
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext: oadd.org.apache.drill.exec.rpc.ResponseSender sender>;
v = new oadd.org.apache.drill.exec.rpc.Response;
v = v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslResponseContext: oadd.com.google.protobuf.Internal$EnumLite saslResponseType>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage build()>();
v = newarray (oadd.io.netty.buffer.ByteBuf)[0];
specialinvoke v.<oadd.org.apache.drill.exec.rpc.Response: void <init>(oadd.com.google.protobuf.Internal$EnumLite,oadd.com.google.protobuf.MessageLite,oadd.io.netty.buffer.ByteBuf[])>(v, v, v);
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ResponseSender: void send(oadd.org.apache.drill.exec.rpc.Response)>(v);
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: boolean isEncryptionEnabled()>();
if v == 0 goto label;
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: void addSecurityHandlers()>();
goto label;
label:
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: void disposeSaslServer()>();
label:
return;
catch java.lang.IllegalStateException from label to label with label;
catch java.lang.NumberFormatException from label to label with label;
}
private static void handleAuthFailure(oadd.org.apache.drill.exec.rpc.ServerConnection, oadd.org.apache.drill.exec.rpc.ResponseSender, java.lang.Exception, oadd.com.google.protobuf.Internal$EnumLite) throws oadd.org.apache.drill.exec.rpc.RpcException
{
oadd.io.netty.buffer.ByteBuf[] v;
java.lang.Object[] v;
org.slf4j.Logger v;
java.net.SocketAddress v;
oadd.org.apache.drill.exec.rpc.ServerConnection v;
oadd.org.apache.drill.exec.rpc.RpcException v;
java.lang.Exception v;
oadd.org.apache.drill.exec.rpc.Response v;
oadd.com.google.protobuf.Internal$EnumLite v;
java.lang.String v, v, v;
javax.security.sasl.SaslServer v;
oadd.org.apache.drill.exec.rpc.ResponseSender v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage v;
v := @parameter: oadd.org.apache.drill.exec.rpc.ServerConnection;
v := @parameter: oadd.org.apache.drill.exec.rpc.ResponseSender;
v := @parameter: java.lang.Exception;
v := @parameter: oadd.com.google.protobuf.Internal$EnumLite;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.net.SocketAddress getRemoteAddress()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[4];
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: javax.security.sasl.SaslServer getSaslServer()>();
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getMechanismName()>();
v[0] = v;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ServerConnection: java.lang.String getEncryptionCtxtString()>();
v[1] = v;
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Authentication using mechanism {} with encryption context {} failed from client {} due to {}", v);
v = new oadd.org.apache.drill.exec.rpc.Response;
v = <oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage SASL_FAILED_MESSAGE>;
v = newarray (oadd.io.netty.buffer.ByteBuf)[0];
specialinvoke v.<oadd.org.apache.drill.exec.rpc.Response: void <init>(oadd.com.google.protobuf.Internal$EnumLite,oadd.com.google.protobuf.MessageLite,oadd.io.netty.buffer.ByteBuf[])>(v, v, v);
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.ResponseSender: void send(oadd.org.apache.drill.exec.rpc.Response)>(v);
v = new oadd.org.apache.drill.exec.rpc.RpcException;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.RpcException: void <init>(java.lang.Throwable)>(v);
throw v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.util.EnumMap v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslStartProcessor v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus v, v, v, v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslFailedProcessor v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslInProgressProcessor v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslSuccessProcessor v;
oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/rpc/security/ServerAuthenticationHandler;");
<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.slf4j.Logger logger> = v;
v = new java.util.EnumMap;
specialinvoke v.<java.util.EnumMap: void <init>(java.lang.Class)>(class "Loadd/org/apache/drill/exec/proto/UserBitShared$SaslStatus;");
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus SASL_START>;
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslStartProcessor;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslStartProcessor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus SASL_IN_PROGRESS>;
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslInProgressProcessor;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslInProgressProcessor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus SASL_SUCCESS>;
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslSuccessProcessor;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslSuccessProcessor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus SASL_FAILED>;
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslFailedProcessor;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler$SaslFailedProcessor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Maps: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap immutableEnumMap(java.util.Map)>(v);
<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap RESPONSE_PROCESSORS> = v;
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder newBuilder()>();
v = <oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus: oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus SASL_FAILED>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder setStatus(oadd.org.apache.drill.exec.proto.UserBitShared$SaslStatus)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage build()>();
<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: oadd.org.apache.drill.exec.proto.UserBitShared$SaslMessage SASL_FAILED_MESSAGE> = v;
return;
}
}