public abstract class oadd.org.apache.hadoop.conf.ReconfigurableBase extends oadd.org.apache.hadoop.conf.Configured implements oadd.org.apache.hadoop.conf.Reconfigurable
{
private static final org.slf4j.Logger LOG;
private oadd.org.apache.hadoop.conf.ReconfigurationUtil reconfigurationUtil;
private java.lang.Thread reconfigThread;
private volatile boolean shouldRun;
private java.lang.Object reconfigLock;
private long startTime;
private long endTime;
private java.util.Map status;
public void <init>()
{
oadd.org.apache.hadoop.conf.ReconfigurationUtil v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
specialinvoke v.<oadd.org.apache.hadoop.conf.Configured: void <init>(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = new oadd.org.apache.hadoop.conf.ReconfigurationUtil;
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationUtil: void <init>()>();
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.ReconfigurationUtil reconfigurationUtil> = v;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread> = null;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: boolean shouldRun> = 1;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Object reconfigLock> = v;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long startTime> = 0L;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long endTime> = 0L;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.util.Map status> = null;
return;
}
public void <init>(oadd.org.apache.hadoop.conf.Configuration)
{
oadd.org.apache.hadoop.conf.ReconfigurationUtil v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v, v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
if v != null goto label;
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
goto label;
label:
v = v;
label:
specialinvoke v.<oadd.org.apache.hadoop.conf.Configured: void <init>(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = new oadd.org.apache.hadoop.conf.ReconfigurationUtil;
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationUtil: void <init>()>();
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.ReconfigurationUtil reconfigurationUtil> = v;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread> = null;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: boolean shouldRun> = 1;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Object reconfigLock> = v;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long startTime> = 0L;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long endTime> = 0L;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.util.Map status> = null;
return;
}
public void setReconfigurationUtil(oadd.org.apache.hadoop.conf.ReconfigurationUtil)
{
java.lang.Object v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
oadd.org.apache.hadoop.conf.ReconfigurationUtil v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v := @parameter: oadd.org.apache.hadoop.conf.ReconfigurationUtil;
v = staticinvoke <oadd.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.ReconfigurationUtil reconfigurationUtil> = v;
return;
}
protected abstract oadd.org.apache.hadoop.conf.Configuration getNewConf();
public java.util.Collection getChangedProperties(oadd.org.apache.hadoop.conf.Configuration, oadd.org.apache.hadoop.conf.Configuration)
{
java.util.Collection v;
oadd.org.apache.hadoop.conf.ReconfigurationUtil v;
oadd.org.apache.hadoop.conf.Configuration v, v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.ReconfigurationUtil reconfigurationUtil>;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationUtil: java.util.Collection parseChangedProperties(oadd.org.apache.hadoop.conf.Configuration,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
return v;
}
public void startReconfigurationTask() throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.conf.ReconfigurableBase$ReconfigurationThread v;
org.slf4j.Logger v, v;
java.io.IOException v, v;
long v;
java.lang.Thread v, v, v, v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
boolean v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Object reconfigLock>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: boolean shouldRun>;
if v != 0 goto label;
v = <oadd.org.apache.hadoop.conf.ReconfigurableBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("The server is stopped.");
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("The server is stopped.");
throw v;
label:
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
if v == null goto label;
v = <oadd.org.apache.hadoop.conf.ReconfigurableBase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Another reconfiguration task is running.");
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Another reconfiguration task is running.");
throw v;
label:
v = new oadd.org.apache.hadoop.conf.ReconfigurableBase$ReconfigurationThread;
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase$ReconfigurationThread: void <init>(oadd.org.apache.hadoop.conf.ReconfigurableBase)>(v);
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread> = v;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
virtualinvoke v.<java.lang.Thread: void setDaemon(boolean)>(1);
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
virtualinvoke v.<java.lang.Thread: void setName(java.lang.String)>("Reconfiguration Task");
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
virtualinvoke v.<java.lang.Thread: void start()>();
v = staticinvoke <oadd.org.apache.hadoop.util.Time: long now()>();
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long startTime> = 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 oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus getReconfigurationTaskStatus()
{
java.lang.Throwable v;
long v, v, v;
java.lang.Thread v;
java.util.Map v;
oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus v, v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Object reconfigLock>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
if v == null goto label;
v = new oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long startTime>;
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus: void <init>(long,long,java.util.Map)>(v, 0L, null);
exitmonitor v;
label:
return v;
label:
v = new oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long startTime>;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: long endTime>;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.util.Map status>;
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationTaskStatus: void <init>(long,long,java.util.Map)>(v, v, v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void shutdownReconfigurationTask()
{
java.lang.Throwable v;
java.lang.InterruptedException v;
java.lang.Thread v, v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Object reconfigLock>;
entermonitor v;
label:
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: boolean shouldRun> = 0;
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
if v != null goto label;
exitmonitor v;
label:
return;
label:
v = v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread>;
v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.Thread reconfigThread> = null;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
virtualinvoke v.<java.lang.Thread: void join()>();
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public final void reconfigureProperty(java.lang.String, java.lang.String) throws oadd.org.apache.hadoop.conf.ReconfigurationException
{
java.lang.Throwable v;
org.slf4j.Logger v;
oadd.org.apache.hadoop.conf.ReconfigurationException v;
oadd.org.apache.hadoop.conf.Configuration v, v, v, v, v;
java.lang.String v, v, v, v, v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
boolean v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: boolean isPropertyReconfigurable(java.lang.String)>(v);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.conf.ReconfigurableBase: org.slf4j.Logger LOG>;
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[])>("changing property \u to \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.Configuration getConf()>();
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.Configuration getConf()>();
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.lang.String reconfigurePropertyImpl(java.lang.String,java.lang.String)>(v, v);
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.Configuration getConf()>();
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.Configuration getConf()>();
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void unset(java.lang.String)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = new oadd.org.apache.hadoop.conf.ReconfigurationException;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
specialinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurationException: void <init>(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public abstract java.util.Collection getReconfigurableProperties();
public boolean isPropertyReconfigurable(java.lang.String)
{
java.util.Collection v;
java.lang.String v;
oadd.org.apache.hadoop.conf.ReconfigurableBase v;
boolean v;
v := @this: oadd.org.apache.hadoop.conf.ReconfigurableBase;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.ReconfigurableBase: java.util.Collection getReconfigurableProperties()>();
v = interfaceinvoke v.<java.util.Collection: boolean contains(java.lang.Object)>(v);
return v;
}
protected abstract java.lang.String reconfigurePropertyImpl(java.lang.String, java.lang.String) throws oadd.org.apache.hadoop.conf.ReconfigurationException;
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/conf/ReconfigurableBase;");
<oadd.org.apache.hadoop.conf.ReconfigurableBase: org.slf4j.Logger LOG> = v;
return;
}
}