public class org.apache.hive.service.cli.session.SessionManager extends org.apache.hive.service.CompositeService { public static final java.lang.String INACTIVE_ERROR_MESSAGE; private static final java.lang.String FAIL_CLOSE_ERROR_MESSAGE; public static final java.lang.String HIVERCFILE; private static final org.slf4j.Logger LOG; private org.apache.hadoop.hive.conf.HiveConf hiveConf; private final java.lang.Object sessionAddLock; private boolean allowSessions; private final java.util.Map handleToSession; private final java.util.Map connectionsCount; private int userLimit; private int ipAddressLimit; private int userIpAddressLimit; private final org.apache.hive.service.cli.operation.OperationManager operationManager; private org.apache.hive.service.server.KillQueryZookeeperManager killQueryZookeeperManager; private java.util.Optional logManager; private java.util.concurrent.ThreadPoolExecutor backgroundOperationPool; private boolean isOperationLogEnabled; private java.io.File operationLogRootDir; private long checkInterval; private long sessionTimeout; private boolean checkOperation; private volatile boolean shutdown; private final org.apache.hive.service.server.HiveServer hiveServer; private java.lang.String sessionImplWithUGIclassName; private java.lang.String sessionImplclassName; private org.apache.hadoop.hive.ql.cleanup.CleanupService cleanupService; private final java.lang.Object timeoutCheckerLock; private static java.lang.ThreadLocal threadLocalIpAddress; private static java.lang.ThreadLocal threadLocalForwardedAddresses; private static java.lang.ThreadLocal threadLocalUserName; private static java.lang.ThreadLocal threadLocalProxyUserName; public void (org.apache.hive.service.server.HiveServer, boolean) { org.apache.hive.service.cli.session.SessionManager v; java.util.concurrent.ConcurrentHashMap v, v; org.apache.hive.service.cli.operation.OperationManager v; java.util.Optional v; org.apache.hive.service.server.HiveServer v; java.lang.Class v; java.lang.Object v, v; java.lang.String v; boolean v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.server.HiveServer; v := @parameter: boolean; v = class "Lorg/apache/hive/service/cli/session/SessionManager;"; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.hive.service.cli.operation.OperationManager; specialinvoke v.()>(); v. = v; v = staticinvoke (); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v. = v; v. = v; return; } public synchronized void init(org.apache.hadoop.hive.conf.HiveConf) { org.apache.hadoop.hive.common.metrics.common.Metrics v; java.lang.Integer v, v, v; org.apache.hadoop.hive.ql.cleanup.CleanupService v; boolean v, v, v, v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hadoop.hive.ql.cleanup.EventualCleanupService v; org.apache.hive.service.cli.operation.OperationManager v, v; java.lang.Object[] v; org.apache.hive.service.server.KillQueryZookeeperManager v, v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v; org.slf4j.Logger v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hadoop.hive.ql.cleanup.SyncCleanupService v; org.apache.hive.service.server.HiveServer v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hadoop.hive.conf.HiveConf; v. = v; v = ; v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(); label: specialinvoke v.(); v = v.; virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = new org.apache.hive.service.server.KillQueryZookeeperManager; v = v.; v = v.; specialinvoke v.(org.apache.hive.service.cli.operation.OperationManager,org.apache.hive.service.server.HiveServer)>(v, v); v. = v; v = v.; virtualinvoke v.(v); label: specialinvoke v.(); v = staticinvoke (); if v == null goto label; specialinvoke v.(v); specialinvoke v.(v); label: v = ; v = virtualinvoke v.(v); v. = v; v = ; v = virtualinvoke v.(v); v. = v; v = ; v = virtualinvoke v.(v); v. = v; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = staticinvoke (v); v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v = v.; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Connections limit are user: {} ipaddress: {} user-ipaddress: {}", v); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); if v <= 0 goto label; v = new org.apache.hadoop.hive.ql.cleanup.EventualCleanupService; specialinvoke v.(int,int)>(v, v); v. = v; goto label; label: v = ; v. = v; label: v = v.; interfaceinvoke v.(); specialinvoke v.(v); return; } private void registerOpenSesssionMetrics(org.apache.hadoop.hive.common.metrics.common.Metrics) { org.apache.hive.service.cli.session.SessionManager$2 v; org.apache.hadoop.hive.common.metrics.common.Metrics v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.SessionManager$1 v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hadoop.hive.common.metrics.common.Metrics; v = new org.apache.hive.service.cli.session.SessionManager$1; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); v = new org.apache.hive.service.cli.session.SessionManager$2; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); interfaceinvoke v.("hs2_open_sessions", v); interfaceinvoke v.("hs2_avg_open_session_time", v, v); return; } private void registerActiveSesssionMetrics(org.apache.hadoop.hive.common.metrics.common.Metrics) { org.apache.hadoop.hive.common.metrics.common.Metrics v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.SessionManager$3 v; org.apache.hive.service.cli.session.SessionManager$4 v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hadoop.hive.common.metrics.common.Metrics; v = new org.apache.hive.service.cli.session.SessionManager$3; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); v = new org.apache.hive.service.cli.session.SessionManager$4; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); interfaceinvoke v.("hs2_active_sessions", v); interfaceinvoke v.("hs2_avg_active_session_time", v, v); return; } private void initSessionImplClassName() { org.apache.hive.service.cli.session.SessionManager v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v; org.apache.hadoop.hive.conf.HiveConf v, v; java.lang.String v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = v.; v = ; v = virtualinvoke v.(v); v. = v; v = v.; v = ; v = virtualinvoke v.(v); v. = v; return; } private void createBackgroundOperationPool() { org.apache.hadoop.hive.common.metrics.common.Metrics v; boolean v; org.apache.hive.service.cli.session.SessionManager v; java.util.concurrent.LinkedBlockingQueue v; java.util.concurrent.ThreadPoolExecutor v, v; long v, v, v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v, v; int v, v; java.lang.String v, v, v; org.apache.hive.service.cli.session.SessionManager$5 v; org.slf4j.Logger v, v, v; org.apache.hadoop.hive.conf.HiveConf v, v, v, v, v, v; java.util.concurrent.TimeUnit v, v, v, v; org.apache.hive.service.server.ThreadFactoryWithGarbageCleanup v; org.apache.hive.service.cli.session.SessionManager$6 v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = v.; v = ; v = virtualinvoke v.(v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("HiveServer2: Background operation thread pool size: \u0001"); interfaceinvoke v.(v); v = v.; v = ; v = virtualinvoke v.(v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("HiveServer2: Background operation thread wait queue size: \u0001"); interfaceinvoke v.(v); v = v.; v = ; v = ; v = staticinvoke (v, v, v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("HiveServer2: Background operation thread keepalive time: \u seconds"); interfaceinvoke v.(v); v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.(int)>(v); v = new java.util.concurrent.ThreadPoolExecutor; v = ; v = new org.apache.hive.service.server.ThreadFactoryWithGarbageCleanup; specialinvoke v.(java.lang.String)>("HiveServer2-Background-Pool"); specialinvoke v.(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(v, v, v, v, v, v); v. = v; v = v.; virtualinvoke v.(1); v = v.; v = ; v = ; v = staticinvoke (v, v, v); v. = v; v = v.; v = ; v = ; v = staticinvoke (v, v, v); v. = v; v = v.; v = ; v = staticinvoke (v, v); v. = v; v = staticinvoke (); if v == null goto label; v = new org.apache.hive.service.cli.session.SessionManager$5; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager,java.util.concurrent.BlockingQueue)>(v, v); interfaceinvoke v.("exec_async_queue_size", v); v = new org.apache.hive.service.cli.session.SessionManager$6; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); interfaceinvoke v.("exec_async_pool_size", v); label: return; } private void initOperationLogRootDir() { boolean v, v, v, v, v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.operation.OperationManager v; java.util.Optional v; org.apache.hive.service.cli.operation.OperationLogManager v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; java.lang.String v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.hadoop.hive.conf.HiveConf v, v; java.io.IOException v; java.io.File v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = new java.io.File; v = v.; v = ; v = virtualinvoke v.(v); specialinvoke v.(java.lang.String)>(v); v. = v; v. = 1; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The operation log root directory exists, but it is not a directory: \u0001"); interfaceinvoke v.(v); v. = 0; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to create operation log root directory: \u0001"); interfaceinvoke v.(v); v. = 0; label: v = v.; if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Operation log root directory is created: \u0001"); interfaceinvoke v.(v); label: v = v.; staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to schedule cleanup HS2 operation logging root dir: \u0001"); interfaceinvoke v.(v, v); label: v = new org.apache.hive.service.cli.operation.OperationLogManager; v = v.; v = v.; specialinvoke v.(org.apache.hive.service.cli.operation.OperationManager,org.apache.hadoop.hive.conf.HiveConf)>(v, v); v = staticinvoke (v); v. = v; label: return; catch java.io.IOException from label to label with label; } public synchronized void start() { org.apache.hive.service.cli.session.SessionManager v; long v; byte v; v := @this: org.apache.hive.service.cli.session.SessionManager; specialinvoke v.(); v = v.; v = v cmp 0L; if v <= 0 goto label; specialinvoke v.(); label: return; } public org.apache.hadoop.hive.ql.cleanup.CleanupService getCleanupService() { org.apache.hadoop.hive.ql.cleanup.CleanupService v; org.apache.hive.service.cli.session.SessionManager v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = v.; return v; } private void startTimeoutChecker() { org.apache.hive.service.cli.session.SessionManager v; java.util.concurrent.ThreadPoolExecutor v; long v, v; org.apache.hive.service.cli.session.SessionManager$7 v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = v.; v = staticinvoke (v, 3000L); v = new org.apache.hive.service.cli.session.SessionManager$7; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager,long)>(v, v); v = v.; virtualinvoke v.(v); return; } private void shutdownTimeoutChecker() { java.lang.Throwable v; org.apache.hive.service.cli.session.SessionManager v; java.lang.Object v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v. = 1; v = v.; entermonitor v; label: v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public synchronized void decommission() { org.apache.hive.service.cli.session.SessionManager v; v := @this: org.apache.hive.service.cli.session.SessionManager; virtualinvoke v.(0); specialinvoke v.(); return; } public synchronized void stop() { java.util.concurrent.ThreadPoolExecutor v, v, v, v; long v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; org.apache.hadoop.hive.ql.cleanup.CleanupService v; java.lang.String v; org.apache.hive.service.cli.session.SessionManager v; org.slf4j.Logger v; org.apache.hadoop.hive.conf.HiveConf v; java.util.concurrent.TimeUnit v, v; java.util.function.Consumer v; java.lang.InterruptedException v; java.util.Optional v; v := @this: org.apache.hive.service.cli.session.SessionManager; specialinvoke v.(); specialinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = ; v = ; v = virtualinvoke v.(v, v); label: v = v.; v = ; virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("HIVE_SERVER2_ASYNC_EXEC_SHUTDOWN_TIMEOUT = \u seconds has been exceeded. RUNNING background operations will be shut down"); interfaceinvoke v.(v, v); label: v = v.; virtualinvoke v.(); v. = null; label: specialinvoke v.(); v = v.; v = staticinvoke (); virtualinvoke v.(v); return; catch java.lang.InterruptedException from label to label with label; } private void cleanupLoggingRootDir() { org.apache.hive.service.cli.session.SessionManager v; org.slf4j.Logger v; java.io.File v, v; java.lang.Exception v; java.lang.String v, v; boolean v; v := @this: org.apache.hive.service.cli.session.SessionManager; v = v.; if v == 0 goto label; label: v = v.; staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to cleanup root dir of HS2 logging: \u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public org.apache.hive.service.cli.SessionHandle openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion, java.lang.String, java.lang.String, java.lang.String, java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.SessionManager v; java.util.Map v; java.lang.String v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.rpc.thrift.TProtocolVersion; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v = virtualinvoke v.(v, v, v, v, v, 0, null); return v; } public org.apache.hive.service.cli.SessionHandle openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion, java.lang.String, java.lang.String, java.lang.String, java.util.Map, boolean, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSession v; java.util.Map v; java.lang.String v, v, v, v; boolean v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.rpc.thrift.TProtocolVersion; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: java.lang.String; v = virtualinvoke v.(null, v, v, v, v, v, v, v); v = interfaceinvoke v.(); return v; } public org.apache.hive.service.cli.session.HiveSession createSession(org.apache.hive.service.cli.SessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion, java.lang.String, java.lang.String, java.lang.String, java.util.Map, boolean, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.util.Map v, v; org.apache.hive.service.cli.session.HiveSessionImplwithUGI v; org.apache.hive.service.cli.session.SessionManager v; java.lang.Exception v, v, v, v, v; java.lang.Throwable v, v; java.lang.Object[] v, v; java.lang.reflect.Constructor v, v; org.apache.hadoop.security.UserGroupInformation v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.hive.service.rpc.thrift.TProtocolVersion v; java.lang.Class[] v, v; java.io.File v; boolean v, v, v, v, v; org.apache.hive.service.cli.SessionHandle v, v, v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.util.List v; int v; org.apache.hive.service.cli.HiveSQLException v, v, v, v, v, v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v, v, v, v; org.apache.hadoop.hive.conf.HiveConf v, v, v, v; java.lang.Class v, v; java.lang.Object v, v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.cli.SessionHandle; v := @parameter: org.apache.hive.service.rpc.thrift.TProtocolVersion; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: java.lang.String; v = v.; entermonitor v; label: v = v.; if v != 0 goto label; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String)>("Cannot open sessions on an inactive HS2 instance, or the HS2 server leader is not ready; please use service discovery to connect the server leader again"); throw v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = staticinvoke (); specialinvoke v.(v, v, v); if v == 0 goto label; v = v.; if v != null goto label; v = new org.apache.hive.service.cli.session.HiveSessionImplwithUGI; v = v.; specialinvoke v.(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.rpc.thrift.TProtocolVersion,java.lang.String,java.lang.String,org.apache.hadoop.hive.conf.HiveConf,java.lang.String,java.lang.String,java.util.List)>(v, v, v, v, v, v, v, v); goto label; label: v = v.; v = staticinvoke (v); v = newarray (java.lang.Class)[8]; v[0] = class "Lorg/apache/hive/service/cli/SessionHandle;"; v[1] = class "Lorg/apache/hive/service/rpc/thrift/TProtocolVersion;"; v[2] = class "Ljava/lang/String;"; v[3] = class "Ljava/lang/String;"; v[4] = class "Lorg/apache/hadoop/hive/conf/HiveConf;"; v[5] = class "Ljava/lang/String;"; v[6] = class "Ljava/lang/String;"; v[7] = class "Ljava/util/List;"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[8]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; v = v.; v[4] = v; v[5] = v; v[6] = v; v[7] = v; v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot initialize session class:\u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v, v); virtualinvoke v.(v); goto label; label: v = v.; if v != null goto label; v = new org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; specialinvoke v.(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.rpc.thrift.TProtocolVersion,java.lang.String,java.lang.String,org.apache.hadoop.hive.conf.HiveConf,java.lang.String,java.util.List)>(v, v, v, v, v, v, v); goto label; label: v = v.; v = staticinvoke (v); v = newarray (java.lang.Class)[7]; v[0] = class "Lorg/apache/hive/service/cli/SessionHandle;"; v[1] = class "Lorg/apache/hive/service/rpc/thrift/TProtocolVersion;"; v[2] = class "Ljava/lang/String;"; v[3] = class "Ljava/lang/String;"; v[4] = class "Lorg/apache/hadoop/hive/conf/HiveConf;"; v[5] = class "Ljava/lang/String;"; v[6] = class "Ljava/util/List;"; v = virtualinvoke v.(v); v = newarray (java.lang.Object)[7]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; v = v.; v[4] = v; v[5] = v; v[6] = v; v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot initialize session class:\u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); label: interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to open session", v); v = new org.apache.hive.service.cli.HiveSQLException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to open new session: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = v.; if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to execute session hooks", v); v = new org.apache.hive.service.cli.HiveSQLException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to execute session hooks: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = 0; v = v.; entermonitor v; label: v = v.; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = 1; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v != 0 goto label; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to close the session opened during an HA state change; ignoring", v); label: v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String)>("Cannot close the session opened during the HA state change time"); throw v; label: v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Session opened, \u, current sessions:\u0001"); interfaceinvoke v.(v); return v; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } private void incrementConnections(java.lang.String, java.lang.String, java.util.List) throws org.apache.hive.service.cli.HiveSQLException { java.util.function.Function v, v, v; java.util.Map v, v, v; java.lang.String v, v, v, v, v; boolean v, v, v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.SessionManager v; org.slf4j.Logger v; java.util.List v; java.lang.Object v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.List; v = specialinvoke v.(v, v); v = specialinvoke v.(v, v); if v != null goto label; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.(v); v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String)>(v); throw v; label: return; } private java.lang.String getOriginClientIpAddress(java.lang.String, java.util.List) { org.apache.hive.service.cli.session.SessionManager v; java.util.List v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v := @parameter: java.util.List; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: return v; label: v = interfaceinvoke v.(0); return v; } private void decrementConnections(org.apache.hive.service.cli.session.HiveSession) { java.util.function.BiFunction v, v, v; java.util.Map v, v, v; java.lang.String v, v, v, v; boolean v, v, v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSession v; java.util.List v; java.lang.Object v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.cli.session.HiveSession; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = specialinvoke v.(v, v); v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); v = staticinvoke (); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: return; } private java.lang.String anyViolations(java.lang.String, java.lang.String) { int v, v, v, v, v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v, v, v; org.apache.hive.service.cli.session.SessionManager v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = specialinvoke v.(v, v); if v != 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Connection limit per user reached (user: \u limit: \u)"); return v; label: v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = specialinvoke v.(v, v); if v != 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Connection limit per ipaddress reached (ipaddress: \u limit: \u)"); return v; label: v = specialinvoke v.(v, v); if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); v = v.; v = specialinvoke v.(v, v); if v != 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Connection limit per user:ipaddress reached (user:ipaddress: \u0001:\u limit: \u)"); return v; label: return null; } private boolean trackConnectionsPerUserIpAddress(java.lang.String, java.lang.String) { org.apache.hive.service.cli.session.SessionManager v; int v; java.lang.String v, v; boolean v, v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = v.; if v <= 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean trackConnectionsPerIpAddress(java.lang.String) { org.apache.hive.service.cli.session.SessionManager v; int v; java.lang.String v; boolean v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v = v.; if v <= 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean trackConnectionsPerUser(java.lang.String) { org.apache.hive.service.cli.session.SessionManager v; int v; java.lang.String v; boolean v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v = v.; if v <= 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean withinLimits(java.lang.String, int) { org.apache.hive.service.cli.session.SessionManager v; java.util.Map v, v; int v, v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: java.lang.String; v := @parameter: int; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v < v goto label; return 0; label: return 1; } public void closeSession(org.apache.hive.service.cli.SessionHandle) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.SessionManager v; org.slf4j.Logger v; java.util.Map v; int v; java.lang.Object v, v; java.lang.String v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.cli.SessionHandle; v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.hive.service.cli.HiveSQLException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Session does not exist: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Session closed, \u, current sessions:\u0001"); interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: specialinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } private void closeSessionInternal(org.apache.hive.service.cli.session.HiveSession) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.SessionManager v; org.slf4j.Logger v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; int v; org.apache.hive.service.server.HiveServer v, v; org.apache.hive.service.cli.session.SessionManager$8 v; boolean v, v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.cli.session.HiveSession; specialinvoke v.(v); v = v.; if v == null goto label; v = v.; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("This instance of HiveServer has been removed from the list of server instances available for dynamic service discovery. The last client session has ended - will shutdown now."); v = new org.apache.hive.service.cli.session.SessionManager$8; specialinvoke v.(org.apache.hive.service.cli.session.SessionManager)>(v); virtualinvoke v.(); label: return; } public org.apache.hive.service.cli.session.HiveSession getSession(org.apache.hive.service.cli.SessionHandle) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.SessionManager v; java.util.Map v; java.lang.Object v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.SessionManager; v := @parameter: org.apache.hive.service.cli.SessionHandle; v = v.