public class oadd.org.apache.drill.exec.ssl.SSLConfigServer extends oadd.org.apache.drill.exec.ssl.SSLConfig
{
private static final org.slf4j.Logger logger;
private final oadd.org.apache.drill.common.config.DrillConfig config;
private final oadd.org.apache.hadoop.conf.Configuration hadoopConfig;
private final boolean userSslEnabled;
private final boolean httpsEnabled;
private final java.lang.String keyStoreType;
private final java.lang.String keyStorePath;
private final java.lang.String keyStorePassword;
private final java.lang.String keyPassword;
private final java.lang.String trustStoreType;
private final java.lang.String trustStorePath;
private final java.lang.String trustStorePassword;
private final java.lang.String protocol;
private final java.lang.String provider;
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.hadoop.conf.Configuration) throws oadd.org.apache.drill.common.exceptions.DrillException
{
java.util.function.BiFunction v, v;
oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider v;
oadd.org.apache.hadoop.conf.Configuration v, v, v, v;
boolean v, v, v, v, v, v, v, v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.ssl.SSLConfig$Mode v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfig: void <init>()>();
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.drill.common.config.DrillConfig config> = 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.common.config.DrillConfig: boolean hasPath(java.lang.String)>("drill.exec.http.ssl_enabled");
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.http.ssl_enabled");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean httpsEnabled> = v;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.ssl.useHadoopConfig");
if v == 0 goto label;
if v != null goto label;
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig> = v;
goto label;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig> = v;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.drill.exec.ssl.SSLConfig$Mode getMode()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("hadoop.ssl.{0}.conf", v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
v = <oadd.org.apache.drill.exec.ssl.SSLConfigServer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Using Hadoop configuration for SSL");
v = <oadd.org.apache.drill.exec.ssl.SSLConfigServer: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Hadoop SSL configuration file: {}", v);
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void addResource(java.lang.String)>(v);
goto label;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig> = null;
label:
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean hasPath(java.lang.String)>("drill.exec.security.user.encryption.ssl.enabled");
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.security.user.encryption.ssl.enabled");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean userSslEnabled> = v;
v = staticinvoke <oadd.org.apache.drill.exec.ssl.SSLConfigServer$getConfigParam__583: java.util.function.BiFunction bootstrap$(oadd.org.apache.drill.exec.ssl.SSLConfigServer)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.ssl.SSLConfigServer$getPasswordConfigParam__584: java.util.function.BiFunction bootstrap$(oadd.org.apache.drill.exec.ssl.SSLConfigServer)>(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.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.ssl.useMapRSSLConfig");
v = staticinvoke <oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider getSSLCredentialsProvider(java.util.function.BiFunction,java.util.function.BiFunction,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode,boolean)>(v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.truststore.type", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getTrustStoreType(java.lang.String,java.lang.String)>("drill.exec.ssl.trustStoreType", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStoreType> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.truststore.location", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getTrustStoreLocation(java.lang.String,java.lang.String)>("drill.exec.ssl.trustStorePath", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePath> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.truststore.password", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getTrustStorePassword(java.lang.String,java.lang.String)>("drill.exec.ssl.trustStorePassword", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePassword> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.keystore.type", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getKeyStoreType(java.lang.String,java.lang.String)>("drill.exec.ssl.keyStoreType", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStoreType> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.keystore.location", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getKeyStoreLocation(java.lang.String,java.lang.String)>("drill.exec.ssl.keyStorePath", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.keystore.password", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getKeyStorePassword(java.lang.String,java.lang.String)>("drill.exec.ssl.keyStorePassword", v);
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String resolveHadoopPropertyName(java.lang.String,oadd.org.apache.drill.exec.ssl.SSLConfig$Mode)>("ssl.{0}.keystore.keypassword", v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLCredentialsProvider: java.lang.String getKeyPassword(java.lang.String,java.lang.String)>("drill.exec.ssl.keyPassword", v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword>;
goto label;
label:
v = v;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyPassword> = v;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.String getString(java.lang.String)>("drill.exec.ssl.protocol");
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String protocol> = v;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.String getString(java.lang.String)>("drill.exec.ssl.provider");
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String provider> = v;
return;
}
public void validateKeyStore() throws oadd.org.apache.drill.common.exceptions.DrillException
{
oadd.org.apache.drill.common.exceptions.DrillException v, v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v, v, v, v;
boolean v, v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean isUserSslEnabled()>();
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean isHttpsEnabled()>();
if v == 0 goto label;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>(" *.ssl.keyStorePath in the configuration file is empty, but *.ssl.keyStorePassword is set");
throw v;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>(" *.ssl.keyStorePassword in the configuration file is empty, but *.ssl.keyStorePath is set ");
throw v;
label:
return;
}
public oadd.io.netty.handler.ssl.SslContext initNettySslContext() throws oadd.org.apache.drill.common.exceptions.DrillException
{
java.lang.String[] v;
java.lang.String v, v, v, v;
oadd.io.netty.handler.ssl.SslContext v;
boolean v, v;
oadd.io.netty.handler.ssl.SslProvider v;
oadd.org.apache.drill.common.exceptions.DrillException v, v;
javax.net.ssl.TrustManagerFactory v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
javax.net.ssl.KeyManagerFactory v;
java.lang.Exception v;
oadd.io.netty.handler.ssl.SslContextBuilder v, v, v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean userSslEnabled>;
if v != 0 goto label;
return null;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>("No Keystore provided.");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: javax.net.ssl.KeyManagerFactory initializeKeyManagerFactory()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: javax.net.ssl.TrustManagerFactory initializeTrustManagerFactory()>();
v = staticinvoke <oadd.io.netty.handler.ssl.SslContextBuilder: oadd.io.netty.handler.ssl.SslContextBuilder forServer(javax.net.ssl.KeyManagerFactory)>(v);
v = virtualinvoke v.<oadd.io.netty.handler.ssl.SslContextBuilder: oadd.io.netty.handler.ssl.SslContextBuilder trustManager(javax.net.ssl.TrustManagerFactory)>(v);
v = newarray (java.lang.String)[1];
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String protocol>;
v[0] = v;
v = virtualinvoke v.<oadd.io.netty.handler.ssl.SslContextBuilder: oadd.io.netty.handler.ssl.SslContextBuilder protocols(java.lang.String[])>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.io.netty.handler.ssl.SslProvider getProvider()>();
v = virtualinvoke v.<oadd.io.netty.handler.ssl.SslContextBuilder: oadd.io.netty.handler.ssl.SslContextBuilder sslProvider(oadd.io.netty.handler.ssl.SslProvider)>(v);
v = virtualinvoke v.<oadd.io.netty.handler.ssl.SslContextBuilder: oadd.io.netty.handler.ssl.SslContext build()>();
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SSL is enabled but cannot be initialized - [ \u]. ");
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.io.netty.handler.ssl.SslContext nettySslContext> = v;
return v;
catch java.lang.Exception from label to label with label;
}
public javax.net.ssl.SSLContext initJDKSSLContext() throws oadd.org.apache.drill.common.exceptions.DrillException
{
javax.net.ssl.SSLContext v;
oadd.org.apache.drill.common.exceptions.DrillException v, v;
javax.net.ssl.TrustManagerFactory v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
javax.net.ssl.KeyManagerFactory v;
java.lang.Exception v;
javax.net.ssl.TrustManager[] v;
java.lang.String v, v, v, v;
boolean v, v;
javax.net.ssl.KeyManager[] v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean userSslEnabled>;
if v != 0 goto label;
return null;
label:
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>("No Keystore provided.");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: javax.net.ssl.KeyManagerFactory initializeKeyManagerFactory()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: javax.net.ssl.TrustManagerFactory initializeTrustManagerFactory()>();
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String protocol>;
v = staticinvoke <javax.net.ssl.SSLContext: javax.net.ssl.SSLContext getInstance(java.lang.String)>(v);
v = virtualinvoke v.<javax.net.ssl.KeyManagerFactory: javax.net.ssl.KeyManager[] getKeyManagers()>();
v = virtualinvoke v.<javax.net.ssl.TrustManagerFactory: javax.net.ssl.TrustManager[] getTrustManagers()>();
virtualinvoke v.<javax.net.ssl.SSLContext: void init(javax.net.ssl.KeyManager[],javax.net.ssl.TrustManager[],java.security.SecureRandom)>(v, v, null);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.common.exceptions.DrillException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SSL is enabled but cannot be initialized - [ \u]. ");
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: javax.net.ssl.SSLContext jdkSSlContext> = v;
return v;
catch java.lang.Exception from label to label with label;
}
public javax.net.ssl.SSLEngine createSSLEngine(oadd.org.apache.drill.exec.memory.BufferAllocator, java.lang.String, int)
{
org.slf4j.Logger v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.Exception v;
javax.net.ssl.SSLEngine v;
int v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v := @parameter: java.lang.String;
v := @parameter: int;
v = specialinvoke 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, v, v);
virtualinvoke v.<javax.net.ssl.SSLEngine: void setUseClientMode(boolean)>(0);
virtualinvoke v.<javax.net.ssl.SSLEngine: void setNeedClientAuth(boolean)>(0);
label:
virtualinvoke v.<javax.net.ssl.SSLEngine: void setEnableSessionCreation(boolean)>(1);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.exec.ssl.SSLConfigServer: org.slf4j.Logger logger>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Session creation not enabled. Exception: {}", v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public java.lang.String getConfigParam(java.lang.String, java.lang.String)
{
oadd.org.apache.drill.common.config.DrillConfig v, v;
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = "";
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
if v == null goto label;
v = specialinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String getHadoopConfigParam(java.lang.String)>(v);
label:
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.drill.common.config.DrillConfig config>;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean hasPath(java.lang.String)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.drill.common.config.DrillConfig config>;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.String getString(java.lang.String)>(v);
label:
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
return v;
}
private java.lang.String getHadoopConfigParam(java.lang.String)
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
oadd.org.apache.hadoop.conf.Configuration v, v;
java.lang.String v, v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>(v, "");
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
return v;
}
public java.lang.String getPasswordConfigParam(java.lang.String, java.lang.String)
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v, v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String getPassword(java.lang.String)>(v);
if v != null goto label;
v = specialinvoke v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String getConfigParam(java.lang.String,java.lang.String)>(v, v);
label:
return v;
}
public boolean isUserSslEnabled()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean userSslEnabled>;
return v;
}
public boolean isHttpsEnabled()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: boolean httpsEnabled>;
return v;
}
public java.lang.String getKeyStoreType()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStoreType>;
return v;
}
public java.lang.String getKeyStorePath()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
return v;
}
public java.lang.String getKeyStorePassword()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword>;
return v;
}
public java.lang.String getKeyPassword()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyPassword>;
return v;
}
public java.lang.String getTrustStoreType()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStoreType>;
return v;
}
public boolean hasTrustStorePath()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getTrustStorePath()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePath>;
return v;
}
public boolean hasTrustStorePassword()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePassword>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getTrustStorePassword()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String trustStorePassword>;
return v;
}
public java.lang.String getProtocol()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String protocol>;
return v;
}
public oadd.io.netty.handler.ssl.SslProvider getProvider()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v;
boolean v;
oadd.io.netty.handler.ssl.SslProvider v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String provider>;
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("JDK");
if v == 0 goto label;
v = <oadd.io.netty.handler.ssl.SslProvider: oadd.io.netty.handler.ssl.SslProvider JDK>;
goto label;
label:
v = <oadd.io.netty.handler.ssl.SslProvider: oadd.io.netty.handler.ssl.SslProvider OPENSSL>;
label:
return v;
}
public int getHandshakeTimeout()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
return 0;
}
public oadd.org.apache.drill.exec.ssl.SSLConfig$Mode getMode()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
oadd.org.apache.drill.exec.ssl.SSLConfig$Mode v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = <oadd.org.apache.drill.exec.ssl.SSLConfig$Mode: oadd.org.apache.drill.exec.ssl.SSLConfig$Mode SERVER>;
return v;
}
public boolean disableHostVerification()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
return 0;
}
public boolean disableCertificateVerification()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
return 0;
}
public boolean useSystemTrustStore()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
return 0;
}
public boolean isSslValid()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
java.lang.String v, v;
boolean v, v, v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePath>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: java.lang.String keyStorePassword>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
oadd.org.apache.hadoop.conf.Configuration getHadoopConfig()
{
oadd.org.apache.drill.exec.ssl.SSLConfigServer v;
oadd.org.apache.hadoop.conf.Configuration v;
v := @this: oadd.org.apache.drill.exec.ssl.SSLConfigServer;
v = v.<oadd.org.apache.drill.exec.ssl.SSLConfigServer: oadd.org.apache.hadoop.conf.Configuration hadoopConfig>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/ssl/SSLConfigServer;");
<oadd.org.apache.drill.exec.ssl.SSLConfigServer: org.slf4j.Logger logger> = v;
return;
}
}