public class oadd.org.apache.drill.exec.rpc.user.UserServer extends oadd.org.apache.drill.exec.rpc.BasicServer
{
private static final org.slf4j.Logger logger;
private static final java.lang.String SERVER_NAME;
private final oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig config;
private final oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig;
private oadd.io.netty.channel.Channel sslChannel;
private final oadd.org.apache.drill.exec.work.user.UserWorker userWorker;
private static final java.util.concurrent.ConcurrentHashMap userConnectionMap;
private java.lang.String serializeUserToBitHandshakeWithoutPassword(oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake)
{
oadd.org.apache.drill.exec.proto.UserProtos$UserProperties v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcEndpointInfos v;
int v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v, v;
oadd.org.apache.drill.exec.proto.UserProtos$SaslSupport v;
java.util.Iterator v;
oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials v;
java.util.List v;
java.lang.Object v;
java.lang.StringBuilder v;
oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("rpc_version: ");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: int getRpcVersion()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\ncredentials:\n\t");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials getCredentials()>();
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)>("properties:");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: oadd.org.apache.drill.exec.proto.UserProtos$UserProperties getProperties()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserProperties: java.util.List getPropertiesList()>();
v = interfaceinvoke v.<java.util.List: 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 = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$Property: java.lang.String getKey()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("password");
if v != 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\n\tproperty:\n\t\t");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("key: \"");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$Property: java.lang.String getKey()>();
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)>("\"\n\t\tvalue: \"");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$Property: java.lang.String getValue()>();
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)>("\"");
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\nsupport_complex_types: ");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: boolean getSupportComplexTypes()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("\nsupport_timeout: ");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: boolean getSupportTimeout()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("sasl_support: ");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: oadd.org.apache.drill.exec.proto.UserProtos$SaslSupport getSaslSupport()>();
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)>("\nclient_infos:\n\t");
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: oadd.org.apache.drill.exec.proto.UserProtos$RpcEndpointInfos getClientInfos()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$RpcEndpointInfos: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("\n", "\n\t");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public void <init>(oadd.org.apache.drill.exec.server.BootStrapContext, oadd.org.apache.drill.exec.memory.BufferAllocator, oadd.io.netty.channel.EventLoopGroup, oadd.org.apache.drill.exec.work.user.UserWorker) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
java.lang.Throwable v;
oadd.org.apache.drill.exec.rpc.user.UserServerRequestHandler v;
oadd.org.apache.drill.common.config.DrillConfig v, v;
oadd.org.apache.drill.exec.ssl.SSLConfig$Mode v;
oadd.org.apache.drill.exec.exception.DrillbitStartupException v;
oadd.org.apache.drill.exec.ssl.SSLConfigBuilder v, v, v, v, v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.io.netty.buffer.ByteBufAllocator v;
java.lang.String v, v;
java.util.concurrent.ExecutorService v;
boolean v;
oadd.org.apache.drill.exec.rpc.RpcConfig v;
oadd.io.netty.channel.EventLoopGroup v;
oadd.org.apache.drill.common.exceptions.DrillException v;
org.slf4j.Logger v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.work.user.UserWorker v;
oadd.org.apache.drill.exec.rpc.RpcMetrics v;
oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.ssl.SSLConfig v, v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.org.apache.drill.exec.server.BootStrapContext;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v := @parameter: oadd.io.netty.channel.EventLoopGroup;
v := @parameter: oadd.org.apache.drill.exec.work.user.UserWorker;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: java.util.concurrent.ExecutorService getExecutor()>();
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserRpcConfig: oadd.org.apache.drill.exec.rpc.RpcConfig getMapping(oadd.org.apache.drill.common.config.DrillConfig,java.util.concurrent.Executor)>(v, v);
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: oadd.io.netty.buffer.ByteBufAllocator getAsByteBufAllocator()>();
specialinvoke v.<oadd.org.apache.drill.exec.rpc.BasicServer: void <init>(oadd.org.apache.drill.exec.rpc.RpcConfig,oadd.io.netty.buffer.ByteBufAllocator,oadd.io.netty.channel.EventLoopGroup)>(v, v, v);
v = new oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig;
v = new oadd.org.apache.drill.exec.rpc.user.UserServerRequestHandler;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServerRequestHandler: void <init>(oadd.org.apache.drill.exec.work.user.UserWorker)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig: void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator,oadd.org.apache.drill.exec.server.BootStrapContext,oadd.org.apache.drill.exec.rpc.user.UserServerRequestHandler)>(v, v, v);
v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig config> = v;
v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.io.netty.channel.Channel sslChannel> = null;
label:
v = new oadd.org.apache.drill.exec.ssl.SSLConfigBuilder;
specialinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: oadd.org.apache.drill.exec.ssl.SSLConfigBuilder config(oadd.org.apache.drill.common.config.DrillConfig)>(v);
v = <oadd.org.apache.drill.exec.ssl.SSLConfig$Mode: oadd.org.apache.drill.exec.ssl.SSLConfig$Mode SERVER>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: oadd.org.apache.drill.exec.ssl.SSLConfigBuilder mode(oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: oadd.org.apache.drill.exec.ssl.SSLConfigBuilder initializeSSLContext(boolean)>(1);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: oadd.org.apache.drill.exec.ssl.SSLConfigBuilder validateKeyStore(boolean)>(1);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigBuilder: oadd.org.apache.drill.exec.ssl.SSLConfig build()>();
v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig> = v;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfig: java.lang.String getProtocol()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Rpc server configured to use TLS protocol \'{}\'", v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.exec.exception.DrillbitStartupException;
v = virtualinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: java.lang.String getMessage()>();
v = virtualinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: java.lang.Throwable getCause()>();
specialinvoke v.<oadd.org.apache.drill.exec.exception.DrillbitStartupException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.work.user.UserWorker userWorker> = v;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserRpcMetrics: oadd.org.apache.drill.exec.rpc.RpcMetrics getInstance()>();
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig config>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig: boolean isEncryptionEnabled()>();
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserRpcMetrics: void initialize(boolean,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v);
return;
catch oadd.org.apache.drill.common.exceptions.DrillException from label to label with label;
}
protected void setupSSL(oadd.io.netty.channel.ChannelPipeline)
{
org.slf4j.Logger v, v;
oadd.io.netty.handler.ssl.SslHandler v;
javax.net.ssl.SSLEngine v;
oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
java.lang.String v;
oadd.io.netty.channel.ChannelPipeline v;
oadd.org.apache.drill.exec.ssl.SSLConfig v, v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.io.netty.channel.ChannelPipeline;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig config>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig: oadd.org.apache.drill.exec.memory.BufferAllocator getAllocator()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfig: javax.net.ssl.SSLEngine createSSLEngine(oadd.org.apache.drill.exec.memory.BufferAllocator,java.lang.String,int)>(v, null, 0);
v = new oadd.io.netty.handler.ssl.SslHandler;
specialinvoke v.<oadd.io.netty.handler.ssl.SslHandler: void <init>(javax.net.ssl.SSLEngine)>(v);
interfaceinvoke v.<oadd.io.netty.channel.ChannelPipeline: oadd.io.netty.channel.ChannelPipeline addFirst(java.lang.String,oadd.io.netty.channel.ChannelHandler)>("ssl-handler", v);
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("SSL communication between client and server is enabled.");
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfig: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
return;
}
protected boolean isSslEnabled()
{
oadd.org.apache.drill.exec.rpc.user.UserServer v;
boolean v;
oadd.org.apache.drill.exec.ssl.SSLConfig v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.ssl.SSLConfig sslConfig>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfig: boolean isUserSslEnabled()>();
return v;
}
public void setSslChannel(oadd.io.netty.channel.Channel)
{
oadd.io.netty.channel.Channel v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.io.netty.channel.Channel;
v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.io.netty.channel.Channel sslChannel> = v;
return;
}
protected void closeSSL()
{
oadd.io.netty.channel.Channel v, v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
boolean v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer: boolean isSslEnabled()>();
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.io.netty.channel.Channel sslChannel>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.io.netty.channel.Channel sslChannel>;
interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.channel.ChannelFuture close()>();
label:
return;
}
protected oadd.com.google.protobuf.MessageLite getResponseDefaultInstance(int) throws oadd.org.apache.drill.exec.rpc.RpcException
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$Ack v;
int v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: int;
lookupswitch(v)
{
case 1: goto label;
default: goto label;
};
label:
v = staticinvoke <oadd.org.apache.drill.exec.proto.GeneralRPCProtos$Ack: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$Ack getDefaultInstance()>();
return v;
label:
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public static java.util.Set getUserConnections()
{
java.util.concurrent.ConcurrentHashMap v;
java.util.Set v;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: java.util.concurrent.ConcurrentHashMap userConnectionMap>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Set entrySet()>();
return v;
}
protected oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection initRemoteConnection(oadd.io.netty.channel.socket.SocketChannel)
{
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.io.netty.channel.socket.SocketChannel v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.io.netty.channel.socket.SocketChannel;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.BasicServer: oadd.org.apache.drill.exec.rpc.ServerConnection initRemoteConnection(oadd.io.netty.channel.socket.SocketChannel)>(v);
v = specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection registerAndGetConnection(oadd.io.netty.channel.socket.SocketChannel)>(v);
return v;
}
private oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection registerAndGetConnection(oadd.io.netty.channel.socket.SocketChannel)
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnectionConfig v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.io.netty.channel.socket.SocketChannel v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.io.netty.channel.socket.SocketChannel;
v = new oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: void <init>(oadd.org.apache.drill.exec.rpc.user.UserServer,oadd.io.netty.channel.socket.SocketChannel)>(v, v);
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: java.util.concurrent.ConcurrentHashMap userConnectionMap>;
v = new oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnectionConfig;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnectionConfig: void <init>(oadd.org.apache.drill.exec.rpc.user.UserServer)>(v);
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
protected oadd.org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler getHandshakeHandler(oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection)
{
oadd.org.apache.drill.exec.proto.UserProtos$RpcType v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.com.google.protobuf.Parser v;
oadd.org.apache.drill.exec.rpc.user.UserServer$1 v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = new oadd.org.apache.drill.exec.rpc.user.UserServer$1;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType HANDSHAKE>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: oadd.com.google.protobuf.Parser PARSER>;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$1: void <init>(oadd.org.apache.drill.exec.rpc.user.UserServer,oadd.com.google.protobuf.Internal$EnumLite,oadd.com.google.protobuf.Parser,oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection)>(v, v, v, v);
return v;
}
private static oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake handleFailure(oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder, oadd.org.apache.drill.exec.proto.UserProtos$HandshakeStatus, java.lang.String, java.lang.Exception)
{
oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder v, v, v, v;
java.lang.Object[] v, v;
oadd.org.apache.drill.exec.proto.UserProtos$HandshakeStatus v;
org.slf4j.Logger v, v;
java.util.UUID v;
java.lang.Exception v;
oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake v;
java.lang.String v, v;
v := @parameter: oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder;
v := @parameter: oadd.org.apache.drill.exec.proto.UserProtos$HandshakeStatus;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Exception;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
if v == null goto label;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object[])>("Error {} in Handling handshake request: {}, {}", v);
goto label;
label:
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object[])>("Error {} in Handling handshake request: {}, {}", v);
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder: oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder setStatus(oadd.org.apache.drill.exec.proto.UserProtos$HandshakeStatus)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder: oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder setErrorId(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder: oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder setErrorMessage(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake$Builder: oadd.org.apache.drill.exec.proto.UserProtos$BitToUserHandshake build()>();
return v;
}
protected oadd.org.apache.drill.exec.rpc.ProtobufLengthDecoder getDecoder(oadd.org.apache.drill.exec.memory.BufferAllocator, oadd.org.apache.drill.exec.rpc.OutOfMemoryHandler)
{
oadd.org.apache.drill.exec.rpc.OutOfMemoryHandler v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.rpc.user.UserProtobufLengthDecoder v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v := @parameter: oadd.org.apache.drill.exec.rpc.OutOfMemoryHandler;
v = new oadd.org.apache.drill.exec.rpc.user.UserProtobufLengthDecoder;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserProtobufLengthDecoder: void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator,oadd.org.apache.drill.exec.rpc.OutOfMemoryHandler)>(v, v);
return v;
}
static void <clinit>()
{
java.util.concurrent.ConcurrentHashMap v;
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/rpc/user/UserServer;");
<oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
<oadd.org.apache.drill.exec.rpc.user.UserServer: java.util.concurrent.ConcurrentHashMap userConnectionMap> = v;
return;
}
}