public class oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection extends oadd.org.apache.drill.exec.rpc.AbstractServerConnection implements oadd.org.apache.drill.exec.rpc.UserClientConnection
{
private oadd.org.apache.drill.exec.rpc.user.UserSession session;
private oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake inbound;
private java.lang.String authenticatedUser;
final oadd.org.apache.drill.exec.rpc.user.UserServer this$0;
void <init>(oadd.org.apache.drill.exec.rpc.user.UserServer, oadd.io.netty.channel.socket.SocketChannel)
{
oadd.org.apache.drill.exec.proto.UserProtos$RpcType v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler v;
oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig v, v, v, v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.rpc.RequestHandler v, v;
oadd.io.netty.channel.socket.SocketChannel v;
boolean v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: oadd.org.apache.drill.exec.rpc.user.UserServer;
v := @parameter: oadd.io.netty.channel.socket.SocketChannel;
v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0> = 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.org.apache.drill.exec.rpc.user.UserConnectionConfig config>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig: boolean isAuthEnabled()>();
if v != 0 goto label;
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.rpc.RequestHandler getMessageHandler()>();
goto label;
label:
v = new oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler;
v = v;
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.rpc.RequestHandler getMessageHandler()>();
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType SASL_MESSAGE>;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.security.ServerAuthenticationHandler: void <init>(oadd.org.apache.drill.exec.rpc.RequestHandler,int,oadd.com.google.protobuf.Internal$EnumLite)>(v, 24, v);
label:
specialinvoke v.<oadd.org.apache.drill.exec.rpc.AbstractServerConnection: void <init>(oadd.io.netty.channel.socket.SocketChannel,oadd.org.apache.drill.exec.rpc.ConnectionConfig,oadd.org.apache.drill.exec.rpc.RequestHandler)>(v, v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: void incConnectionCounter()>();
return;
}
void disableReadTimeout()
{
oadd.io.netty.channel.Channel v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.io.netty.channel.ChannelPipeline v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.io.netty.channel.Channel getChannel()>();
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<oadd.io.netty.channel.ChannelPipeline: oadd.io.netty.channel.ChannelHandler remove(java.lang.String)>("timeout-handler");
return;
}
void setHandshake(oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake)
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake;
v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake inbound> = v;
return;
}
public void finalizeSaslSession() throws java.io.IOException
{
org.slf4j.Logger v;
java.net.SocketAddress v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.hadoop.security.HadoopKerberosName v;
java.lang.String v, v, v;
javax.security.sasl.SaslServer v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: javax.security.sasl.SaslServer getSaslServer()>();
v = interfaceinvoke v.<javax.security.sasl.SaslServer: java.lang.String getAuthorizationID()>();
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()>();
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: void finalizeSession(java.lang.String)>(v);
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: java.lang.String authenticatedUser>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: java.net.SocketAddress getRemoteAddress()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("User {} logged in from {}", v, v);
return;
}
void finalizeSession(java.lang.String)
{
oadd.org.apache.drill.exec.proto.UserProtos$UserProperties v;
oadd.org.apache.drill.exec.rpc.user.InboundImpersonationManager v, v;
oadd.org.apache.drill.exec.rpc.user.UserSession v, v, v;
oadd.org.apache.drill.exec.rpc.user.UserServer v, v, v;
java.lang.String v, v;
boolean v;
oadd.org.apache.drill.exec.rpc.user.UserSession$Builder v, v, v, v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials$Builder v, v;
oadd.org.apache.drill.exec.work.user.UserWorker v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials v;
oadd.org.apache.drill.exec.server.options.OptionManager v;
oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake v, v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession$Builder newBuilder()>();
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials: oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials$Builder newBuilder()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials$Builder setUserName(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials build()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession$Builder withCredentials(oadd.org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(v);
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer: oadd.org.apache.drill.exec.work.user.UserWorker userWorker>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.work.user.UserWorker: oadd.org.apache.drill.exec.server.options.OptionManager getSystemOptions()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession$Builder withOptionManager(oadd.org.apache.drill.exec.server.options.OptionManager)>(v);
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake inbound>;
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.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession$Builder withUserProperties(oadd.org.apache.drill.exec.proto.UserProtos$UserProperties)>(v);
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake inbound>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$UserToBitHandshake: boolean getSupportComplexTypes()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession$Builder setSupportComplexTypes(boolean)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession$Builder: oadd.org.apache.drill.exec.rpc.user.UserSession build()>();
v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session> = v;
v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: java.lang.String authenticatedUser> = v;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession: java.lang.String getTargetUserName()>();
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
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.rpc.user.InboundImpersonationManager getImpersonationManager()>();
if v == null goto label;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
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.rpc.user.InboundImpersonationManager getImpersonationManager()>();
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session>;
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.InboundImpersonationManager: void replaceUserOnSession(java.lang.String,oadd.org.apache.drill.exec.rpc.user.UserSession)>(v, v);
label:
return;
}
public oadd.org.apache.drill.exec.rpc.user.UserSession getSession()
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.user.UserSession v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session>;
return v;
}
protected org.slf4j.Logger getLogger()
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
org.slf4j.Logger v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
return v;
}
public void sendResult(oadd.org.apache.drill.exec.rpc.RpcOutcomeListener, oadd.org.apache.drill.exec.proto.UserBitShared$QueryResult)
{
oadd.io.netty.buffer.ByteBuf[] v;
oadd.org.apache.drill.exec.proto.UserBitShared$QueryResult v;
org.slf4j.Logger v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcType v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.rpc.RpcOutcomeListener v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: oadd.org.apache.drill.exec.rpc.RpcOutcomeListener;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$QueryResult;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Sending result to client with {}", v);
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_RESULT>;
v = newarray (oadd.io.netty.buffer.ByteBuf)[0];
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer: void send(oadd.org.apache.drill.exec.rpc.RpcOutcomeListener,oadd.org.apache.drill.exec.rpc.RemoteConnection,oadd.com.google.protobuf.Internal$EnumLite,oadd.com.google.protobuf.MessageLite,java.lang.Class,boolean,oadd.io.netty.buffer.ByteBuf[])>(v, v, v, v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;", 1, v);
return;
}
public void sendData(oadd.org.apache.drill.exec.rpc.RpcOutcomeListener, oadd.org.apache.drill.exec.physical.impl.materialize.QueryDataPackage)
{
oadd.io.netty.buffer.ByteBuf[] v;
oadd.org.apache.drill.exec.physical.impl.materialize.QueryWritableBatch v;
org.slf4j.Logger v;
oadd.org.apache.drill.exec.proto.UserBitShared$QueryData v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcType v;
oadd.org.apache.drill.exec.rpc.RpcOutcomeListener v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
oadd.org.apache.drill.exec.physical.impl.materialize.QueryDataPackage v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: oadd.org.apache.drill.exec.rpc.RpcOutcomeListener;
v := @parameter: oadd.org.apache.drill.exec.physical.impl.materialize.QueryDataPackage;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.impl.materialize.QueryDataPackage: oadd.org.apache.drill.exec.physical.impl.materialize.QueryWritableBatch toWritableBatch()>();
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Sending data to client with {}", v);
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_DATA>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.physical.impl.materialize.QueryWritableBatch: oadd.org.apache.drill.exec.proto.UserBitShared$QueryData getHeader()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.physical.impl.materialize.QueryWritableBatch: oadd.io.netty.buffer.ByteBuf[] getBuffers()>();
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer: void send(oadd.org.apache.drill.exec.rpc.RpcOutcomeListener,oadd.org.apache.drill.exec.rpc.RemoteConnection,oadd.com.google.protobuf.Internal$EnumLite,oadd.com.google.protobuf.MessageLite,java.lang.Class,boolean,oadd.io.netty.buffer.ByteBuf[])>(v, v, v, v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;", 0, v);
return;
}
public oadd.io.netty.util.concurrent.Future getClosureFuture()
{
oadd.io.netty.util.concurrent.GenericFutureListener v;
oadd.io.netty.channel.Channel v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.io.netty.channel.ChannelFuture v, v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.io.netty.channel.Channel getChannel()>();
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.channel.ChannelFuture closeFuture()>();
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection$lambda_getClosureFuture_0__574: oadd.io.netty.util.concurrent.GenericFutureListener bootstrap$(oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection)>(v);
v = interfaceinvoke v.<oadd.io.netty.channel.ChannelFuture: oadd.io.netty.channel.ChannelFuture addListener(oadd.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
public java.net.SocketAddress getRemoteAddress()
{
oadd.io.netty.channel.Channel v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
java.net.SocketAddress v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.io.netty.channel.Channel getChannel()>();
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: java.net.SocketAddress remoteAddress()>();
return v;
}
public void channelClosed(oadd.org.apache.drill.exec.rpc.RpcException)
{
org.slf4j.Logger v;
java.net.SocketAddress v;
oadd.org.apache.drill.exec.rpc.RpcException v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.user.UserConnectionConfig v;
oadd.org.apache.drill.exec.rpc.user.UserServer v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v := @parameter: oadd.org.apache.drill.exec.rpc.RpcException;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserServer this$0>;
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 isAuthEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: java.lang.String authenticatedUser>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: java.net.SocketAddress getRemoteAddress()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("User {} logged out from {}", v, v);
label:
specialinvoke v.<oadd.org.apache.drill.exec.rpc.AbstractServerConnection: void channelClosed(oadd.org.apache.drill.exec.rpc.RpcException)>(v);
return;
}
private void cleanup()
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.user.UserSession v, v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: oadd.org.apache.drill.exec.rpc.user.UserSession session>;
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserSession: void close()>();
label:
return;
}
public void close()
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection: void cleanup()>();
specialinvoke v.<oadd.org.apache.drill.exec.rpc.AbstractServerConnection: void close()>();
return;
}
public void incConnectionCounter()
{
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.RpcMetrics v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserRpcMetrics: oadd.org.apache.drill.exec.rpc.RpcMetrics getInstance()>();
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.RpcMetrics: void addConnectionCount()>();
return;
}
public void decConnectionCounter()
{
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection v;
oadd.org.apache.drill.exec.rpc.RpcMetrics v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserServer$BitToUserConnection;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserRpcMetrics: oadd.org.apache.drill.exec.rpc.RpcMetrics getInstance()>();
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.RpcMetrics: void decConnectionCount()>();
v = <oadd.org.apache.drill.exec.rpc.user.UserServer: java.util.concurrent.ConcurrentHashMap userConnectionMap>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
return;
}
}