public class oadd.org.apache.drill.exec.server.Drillbit extends java.lang.Object implements java.lang.AutoCloseable
{
private static final org.slf4j.Logger logger;
public static final java.lang.String SYSTEM_OPTIONS_NAME;
private final oadd.org.apache.drill.exec.coord.ClusterCoordinator coord;
private final oadd.org.apache.drill.exec.service.ServiceEngine engine;
private final oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider;
private final oadd.org.apache.drill.exec.work.WorkManager manager;
private final oadd.org.apache.drill.exec.server.BootStrapContext context;
private final oadd.org.apache.drill.exec.server.rest.WebServer webServer;
private final int gracePeriod;
private final oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager;
private oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread gracefulShutdownThread;
private java.lang.Thread shutdownHook;
private volatile boolean quiescentMode;
private volatile boolean forcefulShutdown;
private volatile boolean interruptPollShutdown;
private oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle;
private volatile oadd.org.apache.drill.exec.store.StoragePluginRegistry storageRegistry;
private final oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider;
public void setQuiescentMode(boolean)
{
oadd.org.apache.drill.exec.server.Drillbit v;
boolean v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: boolean;
v.<oadd.org.apache.drill.exec.server.Drillbit: boolean quiescentMode> = v;
return;
}
public void setForcefulShutdown(boolean)
{
oadd.org.apache.drill.exec.server.Drillbit v;
boolean v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: boolean;
v.<oadd.org.apache.drill.exec.server.Drillbit: boolean forcefulShutdown> = v;
return;
}
public oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle getRegistrationHandle()
{
oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle v;
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle>;
return v;
}
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.exec.server.RemoteServiceSet) throws java.lang.Exception
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v = staticinvoke <oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.common.map.CaseInsensitiveMap createDefaultOptionDefinitions()>();
v = staticinvoke <oadd.org.apache.drill.common.scanner.ClassPathScanner: oadd.org.apache.drill.common.scanner.persistence.ScanResult fromPrescan(oadd.org.apache.drill.common.config.DrillConfig)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v, v, v);
return;
}
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.common.map.CaseInsensitiveMap, oadd.org.apache.drill.exec.server.RemoteServiceSet) throws java.lang.Exception
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.common.map.CaseInsensitiveMap;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v = staticinvoke <oadd.org.apache.drill.common.scanner.ClassPathScanner: oadd.org.apache.drill.common.scanner.persistence.ScanResult fromPrescan(oadd.org.apache.drill.common.config.DrillConfig)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v, v, v);
return;
}
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.exec.server.RemoteServiceSet, oadd.org.apache.drill.common.scanner.persistence.ScanResult) throws java.lang.Exception
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v := @parameter: oadd.org.apache.drill.common.scanner.persistence.ScanResult;
v = staticinvoke <oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.common.map.CaseInsensitiveMap createDefaultOptionDefinitions()>();
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v, v, v);
return;
}
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.common.map.CaseInsensitiveMap, oadd.org.apache.drill.exec.server.RemoteServiceSet, oadd.org.apache.drill.common.scanner.persistence.ScanResult) throws java.lang.Exception
{
oadd.org.apache.drill.exec.coord.zk.ZKACLProviderDelegate v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreRegistry v;
java.lang.Integer v;
java.lang.Long v;
boolean v, v, v, v, v, v, v;
oadd.org.apache.drill.exec.service.ServiceEngine v;
javax.tools.JavaCompiler v;
oadd.org.apache.drill.exec.server.BootStrapContext v, v, v, v, v;
oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v, v;
oadd.org.apache.drill.exec.store.sys.store.provider.InMemoryStoreProvider v;
oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator v;
org.apache.drill.shaded.guava.com.google.common.base.Stopwatch v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v, v;
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
long v;
oadd.org.apache.drill.exec.server.rest.WebServer v;
oadd.org.apache.drill.exec.exception.DrillbitStartupException v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.server.DrillbitStateManager v;
int v, v, v;
oadd.org.apache.drill.exec.work.WorkManager v, v, v;
java.lang.String v, v, v;
org.slf4j.Logger v, v, v;
oadd.org.apache.drill.exec.store.sys.store.provider.CachingPersistentStoreProvider v;
oadd.org.apache.drill.exec.store.sys.store.provider.LocalPersistentStoreProvider v;
java.util.concurrent.TimeUnit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.common.map.CaseInsensitiveMap;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v := @parameter: oadd.org.apache.drill.common.scanner.persistence.ScanResult;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.drill.exec.server.Drillbit: boolean interruptPollShutdown> = 1;
v = staticinvoke <javax.tools.ToolProvider: javax.tools.JavaCompiler getSystemJavaCompiler()>();
if v != null goto label;
v = new oadd.org.apache.drill.exec.exception.DrillbitStartupException;
specialinvoke v.<oadd.org.apache.drill.exec.exception.DrillbitStartupException: void <init>(java.lang.String)>("JDK Java compiler not available. Ensure Drill is running with the java executable from a JDK and not a JRE");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: int getInt(java.lang.String)>("drill.exec.grace_period_ms");
v.<oadd.org.apache.drill.exec.server.Drillbit: int gracePeriod> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch createStarted()>();
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Construction started.");
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.port_hunt");
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.allow_loopback_address_binding");
if v != null goto label;
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = new oadd.org.apache.drill.exec.server.BootStrapContext;
specialinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context> = v;
v = new oadd.org.apache.drill.exec.work.WorkManager;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
specialinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: void <init>(oadd.org.apache.drill.exec.server.BootStrapContext)>(v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager> = v;
v = new oadd.org.apache.drill.exec.server.rest.WebServer;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
specialinvoke v.<oadd.org.apache.drill.exec.server.rest.WebServer: void <init>(oadd.org.apache.drill.exec.server.BootStrapContext,oadd.org.apache.drill.exec.work.WorkManager,oadd.org.apache.drill.exec.server.Drillbit)>(v, v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer> = v;
if v != null goto label;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: oadd.org.apache.drill.exec.coord.ClusterCoordinator getCoordinator()>();
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord> = v;
v = new oadd.org.apache.drill.exec.store.sys.store.provider.CachingPersistentStoreProvider;
v = new oadd.org.apache.drill.exec.store.sys.store.provider.LocalPersistentStoreProvider;
specialinvoke v.<oadd.org.apache.drill.exec.store.sys.store.provider.LocalPersistentStoreProvider: void <init>(oadd.org.apache.drill.common.config.DrillConfig)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.store.sys.store.provider.CachingPersistentStoreProvider: void <init>(oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider)>(v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.String getString(java.lang.String)>("drill.exec.cluster-id");
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.String getString(java.lang.String)>("drill.exec.zk.root");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("/\u0001/\u0001");
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = staticinvoke <oadd.org.apache.drill.exec.coord.zk.ZKACLProviderFactory: oadd.org.apache.drill.exec.coord.zk.ZKACLProviderDelegate getACLProvider(oadd.org.apache.drill.common.config.DrillConfig,java.lang.String,oadd.org.apache.drill.exec.server.BootStrapContext)>(v, v, v);
v = new oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator;
specialinvoke v.<oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.curator.framework.api.ACLProvider)>(v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord> = v;
v = new oadd.org.apache.drill.exec.store.sys.PersistentStoreRegistry;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
specialinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreRegistry: void <init>(oadd.org.apache.drill.exec.coord.ClusterCoordinator,oadd.org.apache.drill.common.config.DrillConfig)>(v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider newPStoreProvider()>();
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider> = v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.profiles.store.inmemory");
if v == 0 goto label;
v = new oadd.org.apache.drill.exec.store.sys.store.provider.InMemoryStoreProvider;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: int getInt(java.lang.String)>("drill.exec.profiles.store.capacity");
specialinvoke v.<oadd.org.apache.drill.exec.store.sys.store.provider.InMemoryStoreProvider: void <init>(int)>(v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider> = v;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: int getInt(java.lang.String)>("drill.exec.profiles.store.capacity");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Upto {} latest query profiles will be retained in-memory", v);
goto label;
label:
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider> = v;
label:
v = new oadd.org.apache.drill.exec.service.ServiceEngine;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
specialinvoke v.<oadd.org.apache.drill.exec.service.ServiceEngine: void <init>(oadd.org.apache.drill.exec.work.WorkManager,oadd.org.apache.drill.exec.server.BootStrapContext,boolean,boolean)>(v, v, v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine> = v;
v = new oadd.org.apache.drill.exec.server.DrillbitStateManager;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState STARTUP>;
specialinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void <init>(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager> = v;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: long elapsed(java.util.concurrent.TimeUnit)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Construction completed ({} ms).", v);
return;
}
public int getUserPort()
{
int v;
oadd.org.apache.drill.exec.service.ServiceEngine v;
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.service.ServiceEngine: int getUserPort()>();
return v;
}
public int getWebServerPort()
{
int v;
oadd.org.apache.drill.exec.server.rest.WebServer v;
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.rest.WebServer: int getPort()>();
return v;
}
public oadd.org.apache.drill.exec.work.WorkManager getManager()
{
oadd.org.apache.drill.exec.work.WorkManager v;
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
return v;
}
public oadd.org.apache.drill.exec.server.rest.WebServer getWebServer()
{
oadd.org.apache.drill.exec.server.rest.WebServer v;
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer>;
return v;
}
public void run() throws java.lang.Exception
{
oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread v, v;
oadd.org.apache.drill.exec.store.StoragePluginRegistry v, v;
oadd.org.apache.drill.exec.rpc.control.Controller v;
java.lang.Integer v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle v;
java.lang.Long v;
java.lang.Thread v;
boolean v;
oadd.org.apache.drill.exec.service.ServiceEngine v, v, v;
oadd.org.apache.drill.common.StackTrace v, v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
java.lang.Runtime v;
oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState v;
oadd.org.apache.drill.exec.server.Drillbit$ShutdownThread v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v, v, v, v, v, v, v;
oadd.org.apache.drill.exec.server.DrillbitContext v, v;
org.apache.drill.shaded.guava.com.google.common.base.Stopwatch v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v, v, v, v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
long v;
oadd.org.apache.drill.exec.server.rest.WebServer v, v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.server.DrillbitStateManager v;
int v, v;
oadd.org.apache.drill.exec.work.WorkManager v, v, v;
oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry v;
org.slf4j.Logger v, v;
oadd.org.apache.drill.exec.server.options.SystemOptionManager v;
java.util.concurrent.TimeUnit v;
oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch createStarted()>();
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Startup begun.");
v = new oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread;
v = new oadd.org.apache.drill.common.StackTrace;
specialinvoke v.<oadd.org.apache.drill.common.StackTrace: void <init>()>();
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread: void <init>(oadd.org.apache.drill.exec.server.Drillbit,oadd.org.apache.drill.common.StackTrace)>(v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread gracefulShutdownThread> = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: void start(long)>(10000L);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState ONLINE>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void setState(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider: void start()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
if v == v goto label;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider: void start()>();
label:
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.service.ServiceEngine: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint start()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.service.ServiceEngine: oadd.org.apache.drill.exec.rpc.control.Controller getController()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.service.ServiceEngine: oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator getDataConnectionCreator()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider>;
virtualinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: void start(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint,oadd.org.apache.drill.exec.rpc.control.Controller,oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator,oadd.org.apache.drill.exec.coord.ClusterCoordinator,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider)>(v, v, v, v, v, v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: oadd.org.apache.drill.exec.server.DrillbitContext getContext()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.StoragePluginRegistry getStorage()>();
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.StoragePluginRegistry storageRegistry> = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.StoragePluginRegistry storageRegistry>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.StoragePluginRegistry: void init()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager getOptionManager()>();
virtualinvoke v.<oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.exec.server.options.SystemOptionManager init()>();
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void javaPropertiesToSystemOptions()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: oadd.org.apache.drill.exec.server.DrillbitContext getContext()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry getRemoteFunctionRegistry()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
virtualinvoke v.<oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry: void init(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider,oadd.org.apache.drill.exec.coord.ClusterCoordinator)>(v, v, v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.rest.WebServer: void start()>();
v = (int) -1;
v = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.rest.WebServer: boolean isRunning()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: int getWebServerPort()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder toBuilder()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder setHttpPort(int)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint build()>();
label:
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle register(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle> = v;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: void startRM()>();
v = new oadd.org.apache.drill.exec.server.Drillbit$ShutdownThread;
v = new oadd.org.apache.drill.common.StackTrace;
specialinvoke v.<oadd.org.apache.drill.common.StackTrace: void <init>()>();
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit$ShutdownThread: void <init>(oadd.org.apache.drill.exec.server.Drillbit,oadd.org.apache.drill.common.StackTrace)>(v, v);
v.<oadd.org.apache.drill.exec.server.Drillbit: java.lang.Thread shutdownHook> = v;
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: java.lang.Thread shutdownHook>;
virtualinvoke v.<java.lang.Runtime: void addShutdownHook(java.lang.Thread)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread gracefulShutdownThread>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread: void start()>();
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: long elapsed(java.util.concurrent.TimeUnit)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Startup completed in {} ms and running on port: {}", v, v);
return;
}
private void waitForGracePeriod()
{
int v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.concurrent.ExtendedLatch v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = new oadd.org.apache.drill.common.concurrent.ExtendedLatch;
specialinvoke v.<oadd.org.apache.drill.common.concurrent.ExtendedLatch: void <init>()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: int gracePeriod>;
virtualinvoke v.<oadd.org.apache.drill.common.concurrent.ExtendedLatch: boolean awaitUninterruptibly(long)>(v);
return;
}
private void updateState(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State)
{
oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle v, v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle>;
virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle update(oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle,oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State)>(v, v);
label:
return;
}
public void shutdown()
{
oadd.org.apache.drill.exec.server.Drillbit v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
return;
}
public synchronized void close()
{
oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread v;
oadd.org.apache.drill.exec.store.StoragePluginRegistry v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle v, v;
java.lang.Long v;
java.lang.Thread v, v, v;
boolean v, v, v, v;
oadd.org.apache.drill.exec.service.ServiceEngine v;
oadd.org.apache.drill.exec.server.BootStrapContext v, v;
java.lang.Runtime v;
oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState v, v, v, v, v, v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v, v, v, v;
java.lang.Exception v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State v, v;
org.apache.drill.shaded.guava.com.google.common.base.Stopwatch v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v, v, v;
java.lang.Object[] v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
long v, v;
oadd.org.apache.drill.exec.server.rest.WebServer v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.server.DrillbitStateManager v, v, v, v, v;
int v;
oadd.org.apache.drill.exec.work.WorkManager v, v;
org.slf4j.Logger v, v, v, v;
java.lang.IllegalArgumentException v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState getState()>();
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState ONLINE>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return;
label:
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch createStarted()>();
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Shutdown begun.");
v = v.<oadd.org.apache.drill.exec.server.Drillbit: java.lang.Thread shutdownHook>;
if v == null goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
if v == v goto label;
label:
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
virtualinvoke v.<java.lang.Runtime: boolean removeShutdownHook(java.lang.Thread)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = <oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State QUIESCENT>;
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void updateState(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState GRACE>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void setState(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void waitForGracePeriod()>();
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState DRAINING>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void setState(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: boolean forcefulShutdown>;
virtualinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: void waitToExit(boolean)>(v);
v = <oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State OFFLINE>;
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void updateState(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState OFFLINE>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void setState(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: boolean quiescentMode>;
if v == 0 goto label;
return;
label:
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle registrationHandle>;
virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: void unregister(oadd.org.apache.drill.exec.coord.ClusterCoordinator$RegistrationHandle)>(v);
label:
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
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.common.config.DrillConfig: int getInt(java.lang.String)>("drill.exec.zk.refresh");
v = v * 2L;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Interrupted while sleeping during coordination deregistration.");
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
v = newarray (java.lang.AutoCloseable)[7];
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.rest.WebServer webServer>;
v[0] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.service.ServiceEngine engine>;
v[1] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
v[2] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v[3] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v[4] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.StoragePluginRegistry storageRegistry>;
v[5] = v;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v[6] = v;
staticinvoke <oadd.org.apache.drill.common.AutoCloseables: void close(java.lang.AutoCloseable[])>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider storeProvider>;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider>;
if v == v goto label;
v = newarray (java.lang.AutoCloseable)[1];
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider profileStoreProvider>;
v[0] = v;
staticinvoke <oadd.org.apache.drill.common.AutoCloseables: void close(java.lang.AutoCloseable[])>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failure on close()", v);
label:
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: long elapsed(java.util.concurrent.TimeUnit)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Shutdown completed ({} ms).", v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitStateManager stateManager>;
v = <oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState: oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState SHUTDOWN>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitStateManager: void setState(oadd.org.apache.drill.exec.server.DrillbitStateManager$DrillbitState)>(v);
v = v.<oadd.org.apache.drill.exec.server.Drillbit: boolean interruptPollShutdown>;
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread gracefulShutdownThread>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread: void interrupt()>();
label:
return;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private void javaPropertiesToSystemOptions()
{
java.lang.String[] v, v;
oadd.org.apache.drill.exec.server.options.OptionValue$AccessibleScopes v;
oadd.org.apache.drill.exec.server.options.OptionValue$OptionScope v;
oadd.org.apache.drill.exec.server.Drillbit v;
int v, v, v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v, v, v;
oadd.org.apache.drill.exec.server.options.OptionValue v;
oadd.org.apache.drill.exec.server.options.OptionValue$Kind v;
oadd.org.apache.drill.exec.server.options.SystemOptionManager v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("oadd.org.apache.drill.exec.server.Drillbit.system_options");
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
return;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.DrillbitContext getContext()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager getOptionManager()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("=");
v = lengthof v;
if v == 2 goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "does not contain a key=value assignment");
label:
v = v[0];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "does not contain a key before the assignment");
label:
v = v[1];
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: java.lang.String stripQuotes(java.lang.String,java.lang.String)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "does not contain a value after the assignment");
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.exec.server.options.OptionValue getOption(java.lang.String)>(v);
if v != null goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "does not specify a valid option name");
label:
v = v.<oadd.org.apache.drill.exec.server.options.OptionValue: oadd.org.apache.drill.exec.server.options.OptionValue$AccessibleScopes accessibleScopes>;
v = <oadd.org.apache.drill.exec.server.options.OptionValue$OptionScope: oadd.org.apache.drill.exec.server.options.OptionValue$OptionScope SYSTEM>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.options.OptionValue$AccessibleScopes: boolean inScopeOf(oadd.org.apache.drill.exec.server.options.OptionValue$OptionScope)>(v);
if v != 0 goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "does not specify a SYSTEM option ");
label:
v = v.<oadd.org.apache.drill.exec.server.options.OptionValue: oadd.org.apache.drill.exec.server.options.OptionValue$Kind kind>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.options.SystemOptionManager: void setLocalOption(oadd.org.apache.drill.exec.server.options.OptionValue$Kind,java.lang.String,java.lang.String)>(v, v, v);
v = v + 1;
goto label;
label:
return;
}
public oadd.org.apache.drill.exec.server.DrillbitContext getContext()
{
oadd.org.apache.drill.exec.work.WorkManager v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.work.WorkManager manager>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.work.WorkManager: oadd.org.apache.drill.exec.server.DrillbitContext getContext()>();
return v;
}
public oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread getGracefulShutdownThread()
{
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread v;
v := @this: oadd.org.apache.drill.exec.server.Drillbit;
v = v.<oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit$GracefulShutdownThread gracefulShutdownThread>;
return v;
}
public static void main(java.lang.String[]) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
java.lang.String[] v;
oadd.org.apache.drill.exec.server.StartupOptions v;
v := @parameter: java.lang.String[];
v = staticinvoke <oadd.org.apache.drill.exec.server.StartupOptions: oadd.org.apache.drill.exec.server.StartupOptions parse(java.lang.String[])>(v);
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.exec.server.StartupOptions)>(v);
return;
}
public static oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.exec.server.StartupOptions) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.StartupOptions v;
java.lang.String v;
v := @parameter: oadd.org.apache.drill.exec.server.StartupOptions;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.StartupOptions: java.lang.String getConfigLocation()>();
v = staticinvoke <oadd.org.apache.drill.common.config.DrillConfig: oadd.org.apache.drill.common.config.DrillConfig create(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.common.map.CaseInsensitiveMap createDefaultOptionDefinitions()>();
v = staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet)>(v, v, null);
return v;
}
public static oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v = staticinvoke <oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.common.map.CaseInsensitiveMap createDefaultOptionDefinitions()>();
v = staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet)>(v, v, null);
return v;
}
public static oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.exec.server.RemoteServiceSet) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.exec.server.Drillbit v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v = staticinvoke <oadd.org.apache.drill.exec.server.options.SystemOptionManager: oadd.org.apache.drill.common.map.CaseInsensitiveMap createDefaultOptionDefinitions()>();
v = staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet)>(v, v, v);
return v;
}
public static oadd.org.apache.drill.exec.server.Drillbit start(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.common.map.CaseInsensitiveMap, oadd.org.apache.drill.exec.server.RemoteServiceSet) throws oadd.org.apache.drill.exec.exception.DrillbitStartupException
{
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
org.slf4j.Logger v, v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
oadd.org.apache.drill.exec.exception.DrillbitStartupException v, v;
java.lang.Exception v, v;
oadd.org.apache.drill.exec.server.Drillbit v;
boolean v;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.common.map.CaseInsensitiveMap;
v := @parameter: oadd.org.apache.drill.exec.server.RemoteServiceSet;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Starting new Drillbit.");
v = staticinvoke <oadd.org.apache.drill.common.scanner.ClassPathScanner: oadd.org.apache.drill.common.scanner.persistence.ScanResult fromPrescan(oadd.org.apache.drill.common.config.DrillConfig)>(v);
label:
v = new oadd.org.apache.drill.exec.server.Drillbit;
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap,oadd.org.apache.drill.exec.server.RemoteServiceSet,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = v instanceof oadd.org.apache.drill.exec.exception.DrillbitStartupException;
if v == 0 goto label;
throw v;
label:
v = new oadd.org.apache.drill.exec.exception.DrillbitStartupException;
specialinvoke v.<oadd.org.apache.drill.exec.exception.DrillbitStartupException: void <init>(java.lang.String,java.lang.Throwable)>("Failure while initializing values in Drillbit.", v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void run()>();
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failure during initial startup of Drillbit.", v);
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
v = new oadd.org.apache.drill.exec.exception.DrillbitStartupException;
specialinvoke v.<oadd.org.apache.drill.exec.exception.DrillbitStartupException: void <init>(java.lang.String,java.lang.Throwable)>("Failure during initial startup of Drillbit.", v);
throw v;
label:
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Started new Drillbit.");
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static void throwInvalidSystemOption(java.lang.String, java.lang.String)
{
java.lang.IllegalStateException v;
java.lang.String v, v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Property \"org.apache.drill.exec.server.Drillbit.system_options\" part \"\u0001\" \u.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
}
private static java.lang.String stripQuotes(java.lang.String, java.lang.String)
{
char v, v;
int v, v, v, v;
java.lang.String v, v, v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
return v;
label:
v = virtualinvoke v.<java.lang.String: char charAt(int)>(0);
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 1;
v = virtualinvoke v.<java.lang.String: char charAt(int)>(v);
if v == 34 goto label;
if v != 39 goto label;
label:
if v == v goto label;
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "quoted value does not have closing quote");
label:
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 2;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(1, v);
return v;
label:
if v == 34 goto label;
if v != 39 goto label;
label:
staticinvoke <oadd.org.apache.drill.exec.server.Drillbit: void throwInvalidSystemOption(java.lang.String,java.lang.String)>(v, "value has unbalanced closing quote");
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/server/Drillbit;");
<oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger> = v;
staticinvoke <oadd.org.apache.drill.common.util.ProtobufPatcher: void patch()>();
staticinvoke <oadd.org.apache.drill.common.util.GuavaPatcher: void patch()>();
v = <oadd.org.apache.drill.exec.server.Drillbit: org.slf4j.Logger logger>;
staticinvoke <oadd.org.apache.zookeeper.Environment: void logEnv(java.lang.String,org.slf4j.Logger)>("Drillbit environment: ", v);
staticinvoke <org.slf4j.bridge.SLF4JBridgeHandler: void removeHandlersForRootLogger()>();
staticinvoke <org.slf4j.bridge.SLF4JBridgeHandler: void install()>();
return;
}
}