public class oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink extends java.lang.Object implements oadd.org.apache.hadoop.metrics.MetricsSink, java.io.Closeable
{
private static final java.lang.String BASEPATH_KEY;
private static final java.lang.String SOURCE_KEY;
private static final java.lang.String IGNORE_ERROR_KEY;
private static final boolean DEFAULT_IGNORE_ERROR;
private static final java.lang.String ALLOW_APPEND_KEY;
private static final boolean DEFAULT_ALLOW_APPEND;
private static final java.lang.String KEYTAB_PROPERTY_KEY;
private static final java.lang.String USERNAME_PROPERTY_KEY;
private static final java.lang.String ROLL_INTERVAL_KEY;
private static final java.lang.String DEFAULT_ROLL_INTERVAL;
private static final java.lang.String ROLL_OFFSET_INTERVAL_MILLIS_KEY;
private static final int DEFAULT_ROLL_OFFSET_INTERVAL_MILLIS;
private static final java.lang.String SOURCE_DEFAULT;
private static final java.lang.String BASEPATH_DEFAULT;
private static final oadd.org.apache.commons.lang.time.FastDateFormat DATE_FORMAT;
private final java.lang.Object lock;
private boolean initialized;
private oadd.org.apache.commons.configuration.SubsetConfiguration properties;
private oadd.org.apache.hadoop.conf.Configuration conf;
protected java.lang.String source;
protected boolean ignoreError;
protected boolean allowAppend;
protected oadd.org.apache.hadoop.fs.Path basePath;
private oadd.org.apache.hadoop.fs.FileSystem fileSystem;
private oadd.org.apache.hadoop.fs.Path currentDirPath;
private oadd.org.apache.hadoop.fs.Path currentFilePath;
private java.io.PrintStream currentOutStream;
private oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream;
private java.util.Timer flushTimer;
protected long rollIntervalMillis;
protected long rollOffsetIntervalMillis;
protected java.util.Calendar nextFlush;
protected static boolean forceFlush;
protected static volatile boolean hasFlushed;
protected static oadd.org.apache.hadoop.conf.Configuration suppliedConf;
protected static oadd.org.apache.hadoop.fs.FileSystem suppliedFilesystem;
public void <init>()
{
java.lang.Object v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.Object lock> = v;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initialized> = 0;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush> = null;
return;
}
protected void <init>(long, long)
{
java.lang.Object v;
long v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.Object lock> = v;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initialized> = 0;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush> = null;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis> = v;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollOffsetIntervalMillis> = v;
return;
}
public void init(oadd.org.apache.commons.configuration.SubsetConfiguration)
{
long v, v;
oadd.org.apache.hadoop.conf.Configuration v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v;
oadd.org.apache.hadoop.metrics.MetricsException v;
java.io.IOException v;
oadd.org.apache.commons.configuration.SubsetConfiguration v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.commons.configuration.SubsetConfiguration;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties> = v;
v = new oadd.org.apache.hadoop.fs.Path;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String,java.lang.String)>("basepath", "/tmp");
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath> = v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String,java.lang.String)>("source", "unknown");
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.String source> = v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: boolean getBoolean(java.lang.String,boolean)>("ignore-error", 0);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError> = v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: boolean getBoolean(java.lang.String,boolean)>("allow-append", 0);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean allowAppend> = v;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long getNonNegative(java.lang.String,int)>("roll-offset-interval-millis", 30000);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollOffsetIntervalMillis> = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long getRollInterval()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis> = v;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration loadConf()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration conf> = v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration conf>;
staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: void setConfiguration(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.hadoop.security.UserGroupInformation: boolean isSecurityEnabled()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void checkIfPropertyExists(java.lang.String)>("keytab-key");
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void checkIfPropertyExists(java.lang.String)>("principal-key");
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration conf>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>("keytab-key");
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>("principal-key");
staticinvoke <oadd.org.apache.hadoop.security.SecurityUtil: void login(oadd.org.apache.hadoop.conf.Configuration,java.lang.String,java.lang.String)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = virtualinvoke v.<java.io.IOException: java.lang.String toString()>();
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[])>("Error logging in securely: [\u]");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
private boolean initFs()
{
java.util.Date v;
java.util.Timer v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v, v;
oadd.org.apache.hadoop.metrics.MetricsException v;
java.lang.Exception v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v, v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = 0;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem getFileSystem()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem> = v;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path)>(v);
v = 1;
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError>;
if v != 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.String source>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean allowAppend>;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.String stringifySecurityProperty(java.lang.String)>("keytab-key");
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.String stringifySecurityProperty(java.lang.String)>("principal-key");
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,java.lang.String,boolean,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, 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[])>("Failed to create \u[source=\u, allow-append=\u, \u, \u] -- \u0001");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean allowAppend>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean checkAppend(oadd.org.apache.hadoop.fs.FileSystem)>(v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean allowAppend> = v;
label:
v = new java.util.Timer;
specialinvoke v.<java.util.Timer: void <init>(java.lang.String,boolean)>("RollingFileSystemSink Flusher", 1);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Timer flushTimer> = v;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
virtualinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void setInitialFlushTime(java.util.Date)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
private java.lang.String stringifySecurityProperty(java.lang.String)
{
oadd.org.apache.commons.configuration.SubsetConfiguration v, v, v, v, v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: boolean containsKey(java.lang.String)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>(v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration conf>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, 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=\u, \u0001=\u0001");
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, 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=\u, \u0001=<NOT SET>");
goto label;
label:
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[])>("\u0001=<NOT SET>");
label:
return v;
}
protected long getRollInterval()
{
java.util.regex.Matcher v;
byte v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.metrics.MetricsException v, v, v, v;
oadd.org.apache.commons.configuration.SubsetConfiguration v;
java.util.regex.Pattern v;
long v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
java.lang.NumberFormatException v;
java.util.concurrent.TimeUnit v, v, v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: java.lang.String getString(java.lang.String,java.lang.String)>("roll-interval", "1h");
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("^\\s*(\\d+)\\s*([A-Za-z]*)\\s*$");
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(2);
label:
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
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[])>("Unrecognized flush interval: \u. Must be a number followed by an optional unit. The unit must be one of: minute, hour, day");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = "";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit HOURS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1074026988: goto label;
case 100: goto label;
case 104: goto label;
case 109: goto label;
case 3338: goto label;
case 99228: goto label;
case 108114: goto label;
case 3076183: goto label;
case 3208676: goto label;
case 99469071: goto label;
case 1064901855: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("m");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("min");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("minute");
if v == 0 goto label;
v = 2;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("minutes");
if v == 0 goto label;
v = 3;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("h");
if v == 0 goto label;
v = 4;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("hr");
if v == 0 goto label;
v = 5;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("hour");
if v == 0 goto label;
v = 6;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("hours");
if v == 0 goto label;
v = 7;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("d");
if v == 0 goto label;
v = 8;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("day");
if v == 0 goto label;
v = 9;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("days");
if v == 0 goto label;
v = 10;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 9: goto label;
case 10: goto label;
default: goto label;
};
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MINUTES>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
goto label;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit HOURS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
goto label;
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit DAYS>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
goto label;
label:
v = new oadd.org.apache.hadoop.metrics.MetricsException;
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[])>("Unrecognized unit for flush interval: \u. Must be one of: minute, hour, day");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new oadd.org.apache.hadoop.metrics.MetricsException;
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[])>("Unrecognized flush interval: \u. Must be a number followed by an optional unit. The unit must be one of: minute, hour, day");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v cmp 60000L;
if v >= 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
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[])>("The flush interval property must be at least 1 minute. Value was \u0001");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch java.lang.NumberFormatException from label to label with label;
}
private long getNonNegative(java.lang.String, int)
{
oadd.org.apache.hadoop.metrics.MetricsException v;
oadd.org.apache.commons.configuration.SubsetConfiguration v;
int v, v;
java.lang.String v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: int getInt(java.lang.String,int)>(v, v);
if v >= 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(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[])>("The \u property must be non-negative. Value was \u0001");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private void checkIfPropertyExists(java.lang.String)
{
oadd.org.apache.hadoop.metrics.MetricsException v;
oadd.org.apache.commons.configuration.SubsetConfiguration v;
java.lang.String v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.configuration.SubsetConfiguration properties>;
v = virtualinvoke v.<oadd.org.apache.commons.configuration.SubsetConfiguration: boolean containsKey(java.lang.String)>(v);
if v != 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
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[])>("Metrics configuration is missing \u property");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private oadd.org.apache.hadoop.conf.Configuration loadConf()
{
oadd.org.apache.hadoop.conf.Configuration v, v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration suppliedConf>;
if v == null goto label;
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration suppliedConf>;
goto label;
label:
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
v = v;
label:
return v;
}
private oadd.org.apache.hadoop.fs.FileSystem getFileSystem() throws oadd.org.apache.hadoop.metrics.MetricsException
{
java.net.URISyntaxException v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v;
java.net.URI v;
oadd.org.apache.hadoop.metrics.MetricsException v, v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem suppliedFilesystem>;
if v == null goto label;
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem suppliedFilesystem>;
goto label;
label:
v = new java.net.URI;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String toString()>();
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration conf>;
v = staticinvoke <oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FileSystem get(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String toString()>();
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[])>("The supplied filesystem base path URI is not a valid URI: \u0001");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
v = virtualinvoke v.<java.io.IOException: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,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[])>("Error connecting to file system: \u [\u]");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return v;
catch java.net.URISyntaxException from label to label with label;
catch java.io.IOException from label to label with label;
}
private boolean checkAppend(oadd.org.apache.hadoop.fs.FileSystem)
{
java.lang.UnsupportedOperationException v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.hadoop.fs.FileSystem;
v = 1;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path)>(v);
label:
goto label;
label:
v := @caughtexception;
v = 0;
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.lang.UnsupportedOperationException from label to label with label;
catch java.io.IOException from label to label with label;
}
private void rollLogDirIfNeeded() throws oadd.org.apache.hadoop.metrics.MetricsException
{
java.util.Date v, v, v, v;
java.util.Calendar v, v;
boolean v, v, v, v, v;
java.io.PrintStream v, v, v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: java.util.Date getTime()>();
v = virtualinvoke v.<java.util.Date: boolean after(java.util.Date)>(v);
if v == 0 goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initialized>;
if v != 0 goto label;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initFs()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initialized> = v;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean initialized>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
virtualinvoke v.<java.io.PrintStream: void close()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path findCurrentDirectory(java.util.Date)>(v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentDirPath> = v;
label:
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void rollLogDir()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void throwMetricsException(java.lang.String,java.lang.Throwable)>("Failed to create new log file", v);
label:
virtualinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void updateFlushTime(java.util.Date)>(v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: java.util.Date getTime()>();
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void scheduleFlush(java.util.Date)>(v);
goto label;
label:
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean forceFlush>;
if v == 0 goto label;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void scheduleFlush(java.util.Date)>(v);
label:
return;
catch java.io.IOException from label to label with label;
}
private oadd.org.apache.hadoop.fs.Path findCurrentDirectory(java.util.Date)
{
java.util.Date v, v;
long v, v, v, v, v, v, v, v, v;
oadd.org.apache.commons.lang.time.FastDateFormat v;
java.util.Calendar v, v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.util.Date;
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = v - v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v / v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v * v;
v = <oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.lang.time.FastDateFormat DATE_FORMAT>;
v = new java.util.Date;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = v + v;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<oadd.org.apache.commons.lang.time.FastDateFormat: java.lang.String format(java.util.Date)>(v);
v = new oadd.org.apache.hadoop.fs.Path;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path basePath>;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
return v;
}
private void scheduleFlush(java.util.Date)
{
java.io.PrintStream v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink$1 v;
java.util.Date v;
java.util.Timer v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.util.Date;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Timer flushTimer>;
v = new oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink$1;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink$1: void <init>(oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink,java.io.PrintStream)>(v, v);
virtualinvoke v.<java.util.Timer: void schedule(java.util.TimerTask,java.util.Date)>(v, v);
return;
}
protected void updateFlushTime(java.util.Date)
{
java.util.Date v;
long v, v, v, v, v, v, v, v;
java.util.Calendar v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.util.Date;
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = v - v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v / v;
v = v + 1L;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v * v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void add(int,int)>(14, v);
return;
}
protected void setInitialFlushTime(java.util.Date)
{
java.util.Date v;
long v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Calendar v, v, v, v, v, v, v, v;
byte v, v;
java.util.concurrent.ThreadLocalRandom v;
int v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.util.Date;
v = staticinvoke <java.util.Calendar: java.util.Calendar getInstance()>();
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush> = v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void setTime(java.util.Date)>(v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void set(int,int)>(14, 0);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void set(int,int)>(13, 0);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void set(int,int)>(12, 0);
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = v - v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v / v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollIntervalMillis>;
v = v * v;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollOffsetIntervalMillis>;
v = v cmp 0L;
if v <= 0 goto label;
v = staticinvoke <java.util.concurrent.ThreadLocalRandom: java.util.concurrent.ThreadLocalRandom current()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: long rollOffsetIntervalMillis>;
virtualinvoke v.<java.util.concurrent.ThreadLocalRandom: long nextLong(long)>(v);
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = v + v;
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v cmp v;
if v > 0 goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.util.Calendar nextFlush>;
virtualinvoke v.<java.util.Calendar: void add(int,int)>(14, v);
return;
}
private void rollLogDir() throws java.io.IOException
{
java.net.InetAddress v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.String source>;
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLocalHost()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostName()>();
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-\u.log");
v = new oadd.org.apache.hadoop.fs.Path;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentDirPath>;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentDirPath>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path)>(v);
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean allowAppend>;
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void createOrAppendLogFile(oadd.org.apache.hadoop.fs.Path)>(v);
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void createLogFile(oadd.org.apache.hadoop.fs.Path)>(v);
label:
return;
}
private void createLogFile(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.nio.charset.Charset v;
int v;
java.lang.String v, v, v;
boolean v;
java.io.PrintStream v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = v;
v = 0;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 0);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream> = v;
v = new java.io.PrintStream;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream> = v;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentFilePath> = v;
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: boolean exists(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: int getNextIdToTry(oadd.org.apache.hadoop.fs.Path,int)>(v, v);
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(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[])>("\u.\u0001");
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = v;
goto label;
label:
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
private int getNextIdToTry(oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RemoteIterator v;
int v, v, v, v;
java.lang.Object v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentDirPath>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.RemoteIterator listFiles(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 1);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String toString()>();
v = v;
label:
v = interfaceinvoke v.<oadd.org.apache.hadoop.fs.RemoteIterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<oadd.org.apache.hadoop.fs.RemoteIterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.LocatedFileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: int extractId(java.lang.String)>(v);
if v <= v goto label;
v = v;
goto label;
label:
v = v + 1;
return v;
}
private int extractId(java.lang.String)
{
java.lang.NumberFormatException v;
int v, v, v, v;
java.lang.String v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: int lastIndexOf(java.lang.String)>(".");
v = (int) -1;
v = v;
if v <= 0 goto label;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.lang.NumberFormatException from label to label with label;
}
private void createOrAppendLogFile(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.nio.charset.Charset v, v;
java.lang.String v, v;
java.io.PrintStream v, v;
java.io.IOException v, v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v, v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileSystem v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 0);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream> = v;
v = new java.io.PrintStream;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream> = v;
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem fileSystem>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path)>(v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream> = v;
v = new java.io.PrintStream;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<java.io.PrintStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream> = v;
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.io.IOException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
throw v;
label:
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentFilePath> = v;
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public void putMetrics(oadd.org.apache.hadoop.metrics.MetricsRecord)
{
java.lang.Long v;
boolean v, v, v;
java.util.Collection v;
oadd.org.apache.hadoop.metrics.MetricsRecord v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
java.lang.Throwable v;
java.lang.Object[] v, v, v;
long v;
java.lang.Iterable v;
java.lang.String v, v, v, v, v, v;
java.lang.Number v;
java.io.PrintStream v, v, v, v, v;
java.util.Iterator v, v;
java.io.IOException v;
java.lang.Object v, v, v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: oadd.org.apache.hadoop.metrics.MetricsRecord;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.Object lock>;
entermonitor v;
label:
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void rollLogDirIfNeeded()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
v = newarray (java.lang.Object)[3];
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecord: long timestamp()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecord: java.lang.String context()>();
v[1] = v;
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecord: java.lang.String name()>();
v[2] = v;
virtualinvoke v.<java.io.PrintStream: java.io.PrintStream printf(java.lang.String,java.lang.Object[])>("%d %s.%s", v);
v = ": ";
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecord: java.util.Collection tags()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.MetricsTag: java.lang.String name()>();
v[1] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.MetricsTag: java.lang.String value()>();
v[2] = v;
virtualinvoke v.<java.io.PrintStream: java.io.PrintStream printf(java.lang.String,java.lang.Object[])>("%s%s=%s", v);
v = ", ";
goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecord: java.lang.Iterable metrics()>();
v = interfaceinvoke v.<java.lang.Iterable: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.AbstractMetric: java.lang.String name()>();
v[1] = v;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.AbstractMetric: java.lang.Number value()>();
v[2] = v;
virtualinvoke v.<java.io.PrintStream: java.io.PrintStream printf(java.lang.String,java.lang.Object[])>("%s%s=%s", v);
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
virtualinvoke v.<java.io.PrintStream: void println()>();
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FSDataOutputStream: void hflush()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void throwMetricsException(java.lang.String,java.lang.Throwable)>("Failed flushing the stream", v);
label:
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void checkForErrors(java.lang.String)>("Unable to write to log file");
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError>;
if v != 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void throwMetricsException(java.lang.String)>("Unable to write to log file");
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void flush()
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v, v;
java.io.IOException v;
java.lang.Object v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.Object lock>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
if v == null goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FSDataOutputStream: void hflush()>();
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void throwMetricsException(java.lang.String,java.lang.Throwable)>("Unable to flush log file", v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void close()
{
java.io.PrintStream v, v;
java.lang.Throwable v, v;
java.lang.Object v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.lang.Object lock>;
entermonitor v;
label:
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
virtualinvoke v.<java.io.PrintStream: void close()>();
label:
specialinvoke v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: void checkForErrors(java.lang.String)>("Unable to close log file");
label:
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream> = null;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream> = null;
goto label;
label:
v := @caughtexception;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream> = null;
v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FSDataOutputStream currentFSOutStream> = null;
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void checkForErrors(java.lang.String) throws oadd.org.apache.hadoop.metrics.MetricsException
{
java.io.PrintStream v;
oadd.org.apache.hadoop.metrics.MetricsException v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError>;
if v != 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: java.io.PrintStream currentOutStream>;
v = virtualinvoke v.<java.io.PrintStream: boolean checkError()>();
if v == 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentFilePath>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,oadd.org.apache.hadoop.fs.Path)>(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");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private void throwMetricsException(java.lang.String, java.lang.Throwable)
{
java.lang.Throwable v;
oadd.org.apache.hadoop.metrics.MetricsException v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Throwable;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError>;
if v != 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentFilePath>;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, 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: \u [\u]");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
}
private void throwMetricsException(java.lang.String)
{
oadd.org.apache.hadoop.metrics.MetricsException v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink v;
boolean v;
v := @this: oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean ignoreError>;
if v != 0 goto label;
v = new oadd.org.apache.hadoop.metrics.MetricsException;
v = v.<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.Path currentFilePath>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,oadd.org.apache.hadoop.fs.Path)>(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");
specialinvoke v.<oadd.org.apache.hadoop.metrics.MetricsException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
static void <clinit>()
{
oadd.org.apache.commons.lang.time.FastDateFormat v;
java.util.TimeZone v;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("GMT");
v = staticinvoke <oadd.org.apache.commons.lang.time.FastDateFormat: oadd.org.apache.commons.lang.time.FastDateFormat getInstance(java.lang.String,java.util.TimeZone)>("yyyyMMddHHmm", v);
<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.commons.lang.time.FastDateFormat DATE_FORMAT> = v;
<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean forceFlush> = 0;
<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: boolean hasFlushed> = 0;
<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.conf.Configuration suppliedConf> = null;
<oadd.org.apache.hadoop.metrics.sink.RollingFileSystemSink: oadd.org.apache.hadoop.fs.FileSystem suppliedFilesystem> = null;
return;
}
}