final class oadd.org.apache.hadoop.fs.viewfs.NflyFSystem extends oadd.org.apache.hadoop.fs.FileSystem
{
private static final oadd.org.apache.commons.logging.Log LOG;
private static final java.lang.String NFLY_TMP_PREFIX;
private static final int DEFAULT_MIN_REPLICATION;
private static java.net.URI nflyURI;
private final oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes;
private final int minReplication;
private final java.util.EnumSet nflyFlags;
private final oadd.org.apache.hadoop.net.Node myNode;
private final oadd.org.apache.hadoop.net.NetworkTopology topology;
private oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] workSet()
{
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
int v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v, v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode)[v];
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = v[v];
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: void <init>(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode)>(v);
v[v] = v;
v = v + 1;
goto label;
label:
return v;
}
private static java.lang.String getRack(java.lang.String)
{
java.lang.String v, v;
v := @parameter: java.lang.String;
if v != null goto label;
v = "/default-rack";
goto label;
label:
v = v;
label:
return v;
}
private void <init>(java.net.URI[], oadd.org.apache.hadoop.conf.Configuration, int, java.util.EnumSet) throws java.io.IOException
{
java.net.URI[] v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
java.util.EnumSet v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: java.net.URI[];
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: int;
v := @parameter: java.util.EnumSet;
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void <init>(java.net.URI[],oadd.org.apache.hadoop.conf.Configuration,int,java.util.EnumSet,oadd.org.apache.hadoop.fs.viewfs.FsGetter)>(v, v, v, v, null);
return;
}
private void <init>(java.net.URI[], oadd.org.apache.hadoop.conf.Configuration, int, java.util.EnumSet, oadd.org.apache.hadoop.fs.viewfs.FsGetter) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.viewfs.FsGetter v;
java.net.InetAddress v;
java.net.URI[] v;
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v, v, v, v, v;
java.util.EnumSet v;
java.util.List v;
oadd.org.apache.hadoop.fs.FileSystem v;
oadd.org.apache.hadoop.net.Node v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.net.NetworkTopology v, v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v, v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.util.Iterator v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v, v, v, v, v, v;
java.lang.Class v, v;
java.lang.Object v, v, v, v, v, v;
oadd.org.apache.hadoop.net.NodeBase v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: java.net.URI[];
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: int;
v := @parameter: java.util.EnumSet;
v := @parameter: oadd.org.apache.hadoop.fs.viewfs.FsGetter;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void <init>()>();
v = lengthof v;
if v >= v goto label;
v = new java.io.IOException;
v = lengthof v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,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: Minimum replication < #destinations");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void setConf(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLocalHost()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostName()>();
v = new java.util.ArrayList;
v = lengthof v;
v = v + 1;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
if v != null goto label;
v = v;
goto label;
label:
v = v;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.Class getClass(java.lang.String,java.lang.Class,java.lang.Class)>("oadd.net.topology.node.switch.mapping.impl", class "Loadd/org/apache/hadoop/net/ScriptBasedMapping;", class "Loadd/org/apache/hadoop/net/DNSToSwitchMapping;");
v = staticinvoke <oadd.org.apache.hadoop.util.ReflectionUtils: java.lang.Object newInstance(java.lang.Class,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = interfaceinvoke v.<oadd.org.apache.hadoop.net.DNSToSwitchMapping: java.util.List resolve(java.util.List)>(v);
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode)[v];
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes> = v;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = 0;
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
if v >= v goto label;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.FsGetter: oadd.org.apache.hadoop.fs.FileSystem getNewInstance(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = v[v];
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: void <init>(oadd.org.apache.hadoop.fs.FileSystem,java.net.URI)>(v, v);
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: void <init>(java.lang.String,java.lang.String,oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem)>(v, v, v);
v[v] = v;
goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v[v];
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: void <init>(java.lang.String,java.lang.String,java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v, v, v);
v[v] = v;
label:
v = v + 1;
goto label;
label:
v = new oadd.org.apache.hadoop.net.NodeBase;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.lang.String getRack(java.lang.String)>(v);
specialinvoke v.<oadd.org.apache.hadoop.net.NodeBase: void <init>(java.lang.String,java.lang.String)>(v, v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.Node myNode> = v;
v = staticinvoke <oadd.org.apache.hadoop.net.NetworkTopology: oadd.org.apache.hadoop.net.NetworkTopology getInstance(oadd.org.apache.hadoop.conf.Configuration)>(v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.NetworkTopology topology> = v;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.NetworkTopology topology>;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.Node myNode>;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
virtualinvoke v.<oadd.org.apache.hadoop.net.NetworkTopology: void sortByDistance(oadd.org.apache.hadoop.net.Node,oadd.org.apache.hadoop.net.Node[],int)>(v, v, v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: int minReplication> = v;
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags> = v;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.net.URI nflyURI>;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics getStatistics(java.lang.String,java.lang.Class)>(v, v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics> = v;
return;
}
private oadd.org.apache.hadoop.fs.Path getNflyTmpPath(oadd.org.apache.hadoop.fs.Path)
{
java.lang.String v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
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[])>("_nfly_tmp_\u0001");
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
return v;
}
public java.net.URI getUri()
{
java.net.URI v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.net.URI nflyURI>;
return v;
}
public oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.Path[] v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey v, v, v;
int v, v, v, v, v;
java.util.EnumSet v, v, v;
boolean v, v, v;
oadd.org.apache.hadoop.fs.FSDataInputStream v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = new java.util.ArrayList;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] workSet()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags>;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey repairOnRead>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags>;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey readMostRecent>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: void updateFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path,int)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.FileStatus notFoundStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status> = v;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "open", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "open", v, v, v);
label:
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags>;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey readMostRecent>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
staticinvoke <java.util.Arrays: void sort(java.lang.Object[])>(v);
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.FSDataInputStream repairAndOpen(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[],oadd.org.apache.hadoop.fs.Path,int)>(v, v, v);
if v == null goto label;
return v;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
v = staticinvoke <oadd.org.apache.hadoop.io.MultipleIOException: java.io.IOException createIOException(java.util.List)>(v);
throw v;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static oadd.org.apache.hadoop.fs.FileStatus notFoundStatus(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.FileStatus v;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.FileStatus;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void <init>(long,boolean,int,long,long,oadd.org.apache.hadoop.fs.Path)>(-1L, 0, 0, 0L, 0L, v);
return v;
}
private oadd.org.apache.hadoop.fs.FSDataInputStream repairAndOpen(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[], oadd.org.apache.hadoop.fs.Path, int)
{
byte v, v, v, v, v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.hadoop.fs.FileStatus v, v, v, v, v, v, v, v, v, v, v;
java.lang.Throwable v;
java.lang.Object[] v;
oadd.org.apache.hadoop.net.Node v;
long v, v, v, v, v, v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
oadd.org.apache.hadoop.fs.FSDataInputStream v;
java.io.IOException v, v;
oadd.org.apache.commons.logging.Log v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode v, v, v, v;
java.net.URI v;
boolean v;
oadd.org.apache.hadoop.net.NetworkTopology v;
int v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] v, v, v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[];
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = 0L;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
v = v cmp 0L;
if v < 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
v = v cmp v;
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: int compareTo(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode)>(v);
if v == 0 goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus cloneStatus()>();
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void setPath(oadd.org.apache.hadoop.fs.Path)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.Path getNflyTmpPath(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
staticinvoke <oadd.org.apache.hadoop.fs.FileUtil: boolean copy(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.FileStatus,oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean,boolean,oadd.org.apache.hadoop.conf.Configuration)>(v, v, v, v, 0, 1, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: boolean delete(oadd.org.apache.hadoop.fs.Path,boolean)>(v, 0);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: boolean rename(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getAccessTime()>();
virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: void setTimes(oadd.org.apache.hadoop.fs.Path,long,long)>(v, v, v);
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void setPath(oadd.org.apache.hadoop.fs.Path)>(v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status> = v;
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void setPath(oadd.org.apache.hadoop.fs.Path)>(v);
v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status> = v;
throw v;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.commons.logging.Log LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode,oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode)>(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[])>("\u \u0001->\u0001: Failed to repair");
interfaceinvoke v.<oadd.org.apache.commons.logging.Log: void info(java.lang.Object,java.lang.Throwable)>(v, v);
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = v cmp 0L;
if v <= 0 goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
v = v cmp 0L;
if v < 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
v = v cmp v;
if v != 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
v = newarray (oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.NetworkTopology topology>;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.net.Node myNode>;
v = lengthof v;
virtualinvoke v.<oadd.org.apache.hadoop.net.NetworkTopology: void sortByDistance(oadd.org.apache.hadoop.net.Node,oadd.org.apache.hadoop.net.Node[],int)>(v, v, v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path,int)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.commons.logging.Log LOG>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: java.net.URI getUri()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,java.net.URI)>(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: Failed to open at \u0001");
interfaceinvoke v.<oadd.org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return null;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
private void mayThrowFileNotFound(java.util.List, int) throws java.io.FileNotFoundException
{
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
java.util.List v;
int v, v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v, v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: java.util.List;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
if v != v goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
throw v;
label:
return;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream create(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission, boolean, int, short, long, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyOutputStream v;
oadd.org.apache.hadoop.util.Progressable v;
long v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
short v;
oadd.org.apache.hadoop.fs.FSDataOutputStream v;
int v;
oadd.org.apache.hadoop.fs.Path v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: short;
v := @parameter: long;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = new oadd.org.apache.hadoop.fs.FSDataOutputStream;
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyOutputStream;
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyOutputStream: void <init>(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission,boolean,int,short,long,oadd.org.apache.hadoop.util.Progressable)>(v, v, v, v, v, v, v, v);
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
specialinvoke v.<oadd.org.apache.hadoop.fs.FSDataOutputStream: void <init>(java.io.OutputStream,oadd.org.apache.hadoop.fs.FileSystem$Statistics)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataOutputStream append(oadd.org.apache.hadoop.fs.Path, int, oadd.org.apache.hadoop.util.Progressable) throws java.io.IOException
{
int v;
oadd.org.apache.hadoop.util.Progressable v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
return null;
}
public boolean rename(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.Path[] v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
int v, v, v, v, v;
boolean v, v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v, v;
oadd.org.apache.hadoop.fs.Path v, v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
v = 1;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: boolean rename(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = v & v;
label:
goto label;
label:
v := @caughtexception;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[2];
v[0] = v;
v[1] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "rename", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[2];
v[0] = v;
v[1] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "rename", v, v, v);
v = 0;
label:
v = v + 1;
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
if v != v goto label;
v = staticinvoke <oadd.org.apache.hadoop.io.MultipleIOException: java.io.IOException createIOException(java.util.List)>(v);
throw v;
label:
return v;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public boolean delete(oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.Path[] v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
int v, v, v, v, v;
boolean v, v, v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v, v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
v = 1;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: boolean delete(oadd.org.apache.hadoop.fs.Path)>(v);
v = v & v;
label:
goto label;
label:
v := @caughtexception;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "delete", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "delete", v, v, v);
v = 0;
label:
v = v + 1;
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
if v != v goto label;
v = staticinvoke <oadd.org.apache.hadoop.io.MultipleIOException: java.io.IOException createIOException(java.util.List)>(v);
throw v;
label:
return v;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.Path[] v, v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey v;
java.util.EnumSet v;
boolean v;
oadd.org.apache.hadoop.fs.FileStatus[] v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyStatus v;
java.io.FileNotFoundException v, v;
oadd.org.apache.hadoop.fs.FileStatus v;
java.lang.Throwable v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v, v;
int v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.util.ArrayList;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] workSet()>();
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags>;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey readMostRecent>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = 0;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: void updateFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "listStatus", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "listStatus", v, v, v);
label:
v = v + 1;
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
staticinvoke <java.util.Arrays: void sort(java.lang.Object[])>(v);
label:
v = 0;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.fs.FileStatus)[v];
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyStatus;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem getFs()>();
v = v[v];
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyStatus: void <init>(oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem,oadd.org.apache.hadoop.fs.FileStatus)>(v, v);
v[v] = v;
v = v + 1;
goto label;
label:
return v;
label:
v := @caughtexception;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "listStatus", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "listStatus", v, v, v);
label:
v = v + 1;
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
v = staticinvoke <oadd.org.apache.hadoop.io.MultipleIOException: java.io.IOException createIOException(java.util.List)>(v);
throw v;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.hadoop.fs.RemoteIterator listLocatedStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.FileNotFoundException, java.io.IOException
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.RemoteIterator v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.fs.RemoteIterator listLocatedStatus(oadd.org.apache.hadoop.fs.Path)>(v);
return v;
}
public void setWorkingDirectory(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
int v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: void setWorkingDirectory(oadd.org.apache.hadoop.fs.Path)>(v);
v = v + 1;
goto label;
label:
return;
}
public oadd.org.apache.hadoop.fs.Path getWorkingDirectory()
{
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = v[0];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: oadd.org.apache.hadoop.fs.Path getWorkingDirectory()>();
return v;
}
public boolean mkdirs(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
int v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = 1;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: boolean mkdirs(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v);
v = v & v;
v = v + 1;
goto label;
label:
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.Path[] v, v;
long v, v;
java.util.ArrayList v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
byte v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey v;
int v, v, v, v, v;
java.util.EnumSet v;
boolean v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v, v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new java.util.ArrayList;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode[] nodes>;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode[] workSet()>();
v = -9223372036854775808L;
v = -2147483648;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: void updateFileStatus(oadd.org.apache.hadoop.fs.Path)>(v);
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.util.EnumSet nflyFlags>;
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey readMostRecent>;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus status>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
v = v cmp v;
if v <= 0 goto label;
v = v;
v = v;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus nflyStatus()>();
label:
return v;
label:
v := @caughtexception;
v = v + 1;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "getFileStatus", v, v, v);
goto label;
label:
v := @caughtexception;
v = newarray (oadd.org.apache.hadoop.fs.Path)[1];
v[0] = v;
staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode,java.lang.String,java.lang.Throwable,java.util.List,oadd.org.apache.hadoop.fs.Path[])>(v, "getFileStatus", v, v, v);
label:
v = v + 1;
goto label;
label:
if v < 0 goto label;
v = v[v];
v = specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$MRNflyNode: oadd.org.apache.hadoop.fs.FileStatus nflyStatus()>();
return v;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void mayThrowFileNotFound(java.util.List,int)>(v, v);
v = staticinvoke <oadd.org.apache.hadoop.io.MultipleIOException: java.io.IOException createIOException(java.util.List)>(v);
throw v;
catch java.io.FileNotFoundException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static transient void processThrowable(oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode, java.lang.String, java.lang.Throwable, java.util.List, oadd.org.apache.hadoop.fs.Path[])
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.Path[] v;
java.io.IOException v, v;
java.io.FileNotFoundException v;
java.util.List v;
oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode v;
java.lang.String v, v, v;
java.net.URI v;
boolean v;
v := @parameter: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Throwable;
v := @parameter: java.util.List;
v := @parameter: oadd.org.apache.hadoop.fs.Path[];
v = staticinvoke <java.util.Arrays: java.lang.String toString(java.lang.Object[])>(v);
v = v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyNode: oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem fs>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.ChRootedFileSystem: java.net.URI getUri()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.net.URI)>(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: failed to \u \u0001");
v = v instanceof java.io.FileNotFoundException;
if v == 0 goto label;
v = new java.io.FileNotFoundException;
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
v = v;
virtualinvoke v.<java.io.IOException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
goto label;
label:
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = v;
label:
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
}
static oadd.org.apache.hadoop.fs.FileSystem createFileSystem(java.net.URI[], oadd.org.apache.hadoop.conf.Configuration, java.lang.String, oadd.org.apache.hadoop.fs.viewfs.FsGetter) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.viewfs.FsGetter v;
java.lang.String[] v, v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem v;
java.net.URI[] v;
int[] v;
oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey v;
int v, v, v, v, v, v;
java.lang.Boolean v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v;
java.util.EnumSet v;
boolean v;
java.lang.IllegalArgumentException v, v;
v := @parameter: java.net.URI[];
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.hadoop.fs.viewfs.FsGetter;
v = 2;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet noneOf(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/viewfs/NflyFSystem$NflyKey;");
v = staticinvoke <oadd.org.apache.hadoop.util.StringUtils: java.lang.String[] split(java.lang.String)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = staticinvoke <oadd.org.apache.hadoop.util.StringUtils: java.lang.String[] split(java.lang.String,char)>(v, 61);
v = lengthof v;
if v == 2 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v[0];
v = staticinvoke <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey valueOf(java.lang.String)>(v);
v = <oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$1: int[] $SwitchMap$org$apache$hadoop$fs$viewfs$NflyFSystem$NflyKey>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v[1];
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
goto label;
label:
v = v[1];
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
virtualinvoke v.<java.util.EnumSet: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.viewfs.NflyFSystem$NflyKey)>(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: Infeasible");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + 1;
goto label;
label:
v = new oadd.org.apache.hadoop.fs.viewfs.NflyFSystem;
specialinvoke v.<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: void <init>(java.net.URI[],oadd.org.apache.hadoop.conf.Configuration,int,java.util.EnumSet,oadd.org.apache.hadoop.fs.viewfs.FsGetter)>(v, v, v, v, v);
return v;
}
static void <clinit>()
{
java.net.URI v;
oadd.org.apache.commons.logging.Log v;
v = staticinvoke <oadd.org.apache.commons.logging.LogFactory: oadd.org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/viewfs/NflyFSystem;");
<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: oadd.org.apache.commons.logging.Log LOG> = v;
v = staticinvoke <java.net.URI: java.net.URI create(java.lang.String)>("nfly:///");
<oadd.org.apache.hadoop.fs.viewfs.NflyFSystem: java.net.URI nflyURI> = v;
return;
}
}