public class oadd.org.apache.hadoop.fs.ftp.FTPFileSystem extends oadd.org.apache.hadoop.fs.FileSystem
{
public static final org.slf4j.Logger LOG;
public static final int DEFAULT_BUFFER_SIZE;
public static final int DEFAULT_BLOCK_SIZE;
public static final java.lang.String FS_FTP_USER_PREFIX;
public static final java.lang.String FS_FTP_HOST;
public static final java.lang.String FS_FTP_HOST_PORT;
public static final java.lang.String FS_FTP_PASSWORD_PREFIX;
public static final java.lang.String FS_FTP_DATA_CONNECTION_MODE;
public static final java.lang.String FS_FTP_TRANSFER_MODE;
public static final java.lang.String E_SAME_DIRECTORY_ONLY;
private java.net.URI uri;
public void <init>()
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void <init>()>();
return;
}
public java.lang.String getScheme()
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
return "ftp";
}
protected int getDefaultPort()
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
return 21;
}
public void initialize(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
java.lang.String[] v;
int v, v, v, v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.net.URI v;
boolean v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void initialize(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
if v != null goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("fs.ftp.host", null);
goto label;
label:
v = v;
label:
v = v;
if v != null goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Invalid host specified");
throw v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>("fs.ftp.host", v);
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = (int) -1;
if v != v goto label;
v = 21;
goto label;
label:
v = v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void setInt(java.lang.String,int)>("fs.ftp.host.port", v);
v = virtualinvoke v.<java.net.URI: java.lang.String getUserInfo()>();
if v != null goto 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[])>("fs.ftp.user.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>(v, null);
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[])>("fs.ftp.password.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>(v, null);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001:\u0001");
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = lengthof v;
if v <= 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Invalid username / password");
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[])>("fs.ftp.user.\u0001");
v = v[0];
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>(v, v);
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[])>("fs.ftp.password.\u0001");
v = v[1];
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void setConf(oadd.org.apache.hadoop.conf.Configuration)>(v);
v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: java.net.URI uri> = v;
return;
}
private oadd.org.apache.commons.net.ftp.FTPClient connect() throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v, v;
java.net.ConnectException v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v, v;
boolean v, v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("fs.ftp.host");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("fs.ftp.host.port", 21);
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[])>("fs.ftp.user.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
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[])>("fs.ftp.password.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
v = new oadd.org.apache.commons.net.ftp.FTPClient;
specialinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void <init>()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void connect(java.lang.String,int)>(v, v);
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getReplyCode()>();
v = staticinvoke <oadd.org.apache.commons.net.ftp.FTPReply: boolean isPositiveCompletion(int)>(v);
if v != 0 goto label;
v = new java.net.ConnectException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("Server response \u0001");
specialinvoke v.<java.net.ConnectException: void <init>(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.hadoop.net.NetUtils: java.io.IOException wrapException(java.lang.String,int,java.lang.String,int,java.io.IOException)>(v, v, "(unknown)", 0, v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean login(java.lang.String,java.lang.String)>(v, v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: int getTransferMode(oadd.org.apache.hadoop.conf.Configuration)>(v);
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean setFileTransferMode(int)>(v);
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean setFileType(int)>(2);
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void setBufferSize(int)>(1048576);
virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void setDataConnectionMode(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
goto label;
label:
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,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[])>("Login failed on server - \u, port - \u as user \'\u0001\'");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
int getTransferMode(oadd.org.apache.hadoop.conf.Configuration)
{
org.slf4j.Logger v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
byte v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v;
boolean v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("fs.ftp.transfer.mode");
v = 11;
if v != null goto label;
return 11;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("STREAM_TRANSFER_MODE");
if v == 0 goto label;
v = 10;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("COMPRESSED_TRANSFER_MODE");
if v == 0 goto label;
v = 12;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("BLOCK_TRANSFER_MODE");
if v != 0 goto label;
v = <oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: org.slf4j.Logger LOG>;
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[])>("Cannot parse the value for fs.ftp.transfer.mode: \u. Using default.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return v;
}
void setDataConnectionMode(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
org.slf4j.Logger v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v;
boolean v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("fs.ftp.data.connection.mode");
if v != null goto label;
return;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("PASSIVE_LOCAL_DATA_CONNECTION_MODE");
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void enterLocalPassiveMode()>();
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("PASSIVE_REMOTE_DATA_CONNECTION_MODE");
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean enterRemotePassiveMode()>();
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("ACTIVE_LOCAL_DATA_CONNECTION_MODE");
if v != 0 goto label;
v = <oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: org.slf4j.Logger LOG>;
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[])>("Cannot parse the value for fs.ftp.data.connection.mode: \u. Using default.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return;
}
private void disconnect(oadd.org.apache.commons.net.ftp.FTPClient) throws java.io.IOException
{
org.slf4j.Logger v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.ftp.FTPException v;
oadd.org.apache.commons.net.ftp.FTPClient v;
int v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean isConnected()>();
if v != 0 goto label;
v = new oadd.org.apache.hadoop.fs.ftp.FTPException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPException: void <init>(java.lang.String)>("Client not connected");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean logout()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void disconnect()>();
if v != 0 goto label;
v = <oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: org.slf4j.Logger LOG>;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getReplyCode()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("Logout failed while disconnecting, error code - \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return;
}
private oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: boolean isAbsolute()>();
if v == 0 goto label;
return v;
label:
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.FSDataInputStream open(oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v;
java.lang.String v, v, v, v, v;
java.net.URI v;
boolean v, v;
oadd.org.apache.hadoop.fs.FSDataInputStream v;
oadd.org.apache.hadoop.fs.ftp.FTPInputStream v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
java.io.InputStream v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Path \u is a directory.");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean allocate(int)>(v);
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.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean changeWorkingDirectory(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.io.InputStream retrieveFileStream(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.fs.FSDataInputStream;
v = new oadd.org.apache.hadoop.fs.ftp.FTPInputStream;
v = v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPInputStream: void <init>(java.io.InputStream,oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.FileSystem$Statistics)>(v, v, v);
specialinvoke v.<oadd.org.apache.hadoop.fs.FSDataInputStream: void <init>(java.io.InputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getReplyCode()>();
v = staticinvoke <oadd.org.apache.commons.net.ftp.FTPReply: boolean isPositivePreliminary(int)>(v);
if v != 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FSDataInputStream: void close()>();
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Unable to open file: \u, Aborting");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
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.commons.net.ftp.FTPClient v;
java.net.URI v;
boolean v, v, v, v;
oadd.org.apache.hadoop.util.Progressable v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v;
long v;
short v;
int v, v;
java.lang.String v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileAlreadyExistsException v;
java.io.OutputStream v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.permission.FsPermission v, v;
java.io.IOException v, v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem$1 v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
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 = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = null;
label:
if v == null goto label;
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v != 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean delete(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, 0);
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
v = new oadd.org.apache.hadoop.fs.FileAlreadyExistsException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("File already exists: \u0001");
specialinvoke v.<oadd.org.apache.hadoop.fs.FileAlreadyExistsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getDirDefault()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean mkdirs(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v, v);
if v != 0 goto label;
label:
if v != null goto label;
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>("/");
goto label;
label:
v = v;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("create(): Mkdirs failed to create: \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean allocate(int)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean changeWorkingDirectory(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.fs.ftp.FTPFileSystem$1;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.io.OutputStream storeFileStream(java.lang.String)>(v);
v = v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem$1: void <init>(oadd.org.apache.hadoop.fs.ftp.FTPFileSystem,java.io.OutputStream,oadd.org.apache.hadoop.fs.FileSystem$Statistics,oadd.org.apache.commons.net.ftp.FTPClient)>(v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getReplyCode()>();
v = staticinvoke <oadd.org.apache.commons.net.ftp.FTPReply: boolean isPositivePreliminary(int)>(v);
if v != 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FSDataOutputStream: void close()>();
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Unable to create file: \u, Aborting");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch java.io.FileNotFoundException from label to label with label;
}
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
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
int v;
oadd.org.apache.hadoop.util.Progressable v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v := @parameter: oadd.org.apache.hadoop.util.Progressable;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Append is not supported by FTPFileSystem");
throw v;
}
private boolean exists(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v;
java.io.FileNotFoundException v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
return 1;
label:
v := @caughtexception;
return 0;
catch java.io.FileNotFoundException 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.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean delete(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private boolean delete(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v, v;
java.lang.String v, v, v;
java.net.URI v;
boolean v, v, v, v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isFile()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean deleteFile(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
return 0;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == null goto label;
v = lengthof v;
if v <= 0 goto label;
if v != 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Directory: \u is not empty.");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean delete(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean removeDirectory(java.lang.String)>(v);
return v;
catch java.io.FileNotFoundException from label to label with label;
}
oadd.org.apache.hadoop.fs.permission.FsAction getFsAction(int, oadd.org.apache.commons.net.ftp.FTPFile)
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPFile v;
oadd.org.apache.hadoop.fs.permission.FsAction v, v, v, v;
int v;
boolean v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: int;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPFile;
v = <oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction NONE>;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: boolean hasPermission(int,int)>(v, 0);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction READ>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction or(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: boolean hasPermission(int,int)>(v, 1);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction WRITE>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction or(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: boolean hasPermission(int,int)>(v, 2);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction EXECUTE>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.permission.FsAction: oadd.org.apache.hadoop.fs.permission.FsAction or(oadd.org.apache.hadoop.fs.permission.FsAction)>(v);
label:
return v;
}
private oadd.org.apache.hadoop.fs.permission.FsPermission getPermissions(oadd.org.apache.commons.net.ftp.FTPFile)
{
oadd.org.apache.hadoop.fs.permission.FsAction v, v, v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.commons.net.ftp.FTPFile v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPFile;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.permission.FsAction getFsAction(int,oadd.org.apache.commons.net.ftp.FTPFile)>(0, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.permission.FsAction getFsAction(int,oadd.org.apache.commons.net.ftp.FTPFile)>(1, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.permission.FsAction getFsAction(int,oadd.org.apache.commons.net.ftp.FTPFile)>(2, v);
v = new oadd.org.apache.hadoop.fs.permission.FsPermission;
specialinvoke v.<oadd.org.apache.hadoop.fs.permission.FsPermission: void <init>(oadd.org.apache.hadoop.fs.permission.FsAction,oadd.org.apache.hadoop.fs.permission.FsAction,oadd.org.apache.hadoop.fs.permission.FsAction)>(v, v, v);
return v;
}
public java.net.URI getUri()
{
java.net.URI v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v = v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: java.net.URI uri>;
return v;
}
public oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private oadd.org.apache.hadoop.fs.FileStatus[] listStatus(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPFile v;
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v, v;
java.lang.String v, v;
java.net.URI v;
boolean v;
oadd.org.apache.hadoop.fs.FileStatus[] v, v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.commons.net.ftp.FTPFile[] v;
oadd.org.apache.hadoop.fs.Path v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isFile()>();
if v == 0 goto label;
v = newarray (oadd.org.apache.hadoop.fs.FileStatus)[1];
v[0] = v;
return v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: oadd.org.apache.commons.net.ftp.FTPFile[] listFiles(java.lang.String)>(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 = v[v];
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPFile,oadd.org.apache.hadoop.fs.Path)>(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.FileStatus v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPFile v;
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v;
java.lang.String v, v, v, v, v, v;
java.net.URI v;
boolean v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.FileNotFoundException v, v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.commons.net.ftp.FTPFile[] v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = null;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
if v != null goto label;
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>("/");
v = new oadd.org.apache.hadoop.fs.FileStatus;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void <init>(long,boolean,int,long,long,oadd.org.apache.hadoop.fs.Path)>(-1L, 1, 1, 4096L, -1L, v);
return v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: oadd.org.apache.commons.net.ftp.FTPFile[] listFiles(java.lang.String)>(v);
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPFile,oadd.org.apache.hadoop.fs.Path)>(v, v);
goto label;
label:
v = v + 1;
goto label;
label:
if v != null goto label;
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("File \u does not exist.");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("File \u does not exist.");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPFile, oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
long v, v;
oadd.org.apache.commons.net.ftp.FTPFile v;
java.util.Calendar v;
oadd.org.apache.hadoop.fs.FileStatus v;
java.lang.String v, v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPFile;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: long getSize()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: boolean isDirectory()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: java.util.Calendar getTimestamp()>();
v = virtualinvoke v.<java.util.Calendar: long getTimeInMillis()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.permission.FsPermission getPermissions(oadd.org.apache.commons.net.ftp.FTPFile)>(v);
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: java.lang.String getUser()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: java.lang.String getGroup()>();
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPFile: java.lang.String getName()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
v = new oadd.org.apache.hadoop.fs.FileStatus;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeQualified(oadd.org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: void <init>(long,boolean,int,long,long,long,oadd.org.apache.hadoop.fs.permission.FsPermission,java.lang.String,java.lang.String,oadd.org.apache.hadoop.fs.Path)>(v, v, 1, 4096L, v, 0L, v, v, v, v);
return v;
}
public boolean mkdirs(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean mkdirs(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private boolean mkdirs(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
java.lang.Object[] v;
oadd.org.apache.commons.net.ftp.FTPClient v;
java.lang.String v, v, v, v;
java.net.URI v;
oadd.org.apache.hadoop.fs.ParentNotDirectoryException v;
boolean v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
oadd.org.apache.hadoop.fs.permission.FsPermission v, v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = 1;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean exists(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getParent()>();
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.fs.permission.FsPermission: oadd.org.apache.hadoop.fs.permission.FsPermission getDirDefault()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean mkdirs(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v, v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean changeWorkingDirectory(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean makeDirectory(java.lang.String)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean isFile(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
v = new oadd.org.apache.hadoop.fs.ParentNotDirectoryException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Can\'t make directory for path %s since it is a file.", v);
specialinvoke v.<oadd.org.apache.hadoop.fs.ParentNotDirectoryException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private boolean isFile(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.ftp.FTPException v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isFile()>();
label:
return v;
label:
v := @caughtexception;
return 0;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.ftp.FTPException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPException: void <init>(java.lang.String,java.lang.Throwable)>("File check failed", v);
throw v;
catch java.io.FileNotFoundException from label to label with label;
catch java.io.IOException from label to label with label;
}
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.ftp.FTPFileSystem v;
oadd.org.apache.commons.net.ftp.FTPClient v;
oadd.org.apache.hadoop.fs.Path v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean rename(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
private boolean isParentOf(oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.lang.String v, v;
java.net.URI v, v;
oadd.org.apache.hadoop.fs.Path v, v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("/");
if v != 0 goto 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/");
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
return v;
}
private boolean rename(oadd.org.apache.commons.net.ftp.FTPClient, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.commons.net.ftp.FTPClient v;
java.net.URI v, v;
boolean v, v, v, v, v, v;
java.io.FileNotFoundException v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.FileAlreadyExistsException v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v, v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path makeAbsolute(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean exists(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v != 0 goto label;
v = new java.io.FileNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Source path \u does not exist");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean isDirectory(oadd.org.apache.hadoop.fs.Path)>(v);
if v == 0 goto label;
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(oadd.org.apache.hadoop.fs.Path,java.lang.String)>(v, v);
v = v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean exists(oadd.org.apache.commons.net.ftp.FTPClient,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
v = new oadd.org.apache.hadoop.fs.FileAlreadyExistsException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path)>(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[])>("Destination path \u already exists");
specialinvoke v.<oadd.org.apache.hadoop.fs.FileAlreadyExistsException: void <init>(java.lang.String)>(v);
throw v;
label:
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.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
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.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: boolean isParentOf(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,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[])>("Cannot rename \u under itself : \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.hadoop.fs.Path,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[])>("Cannot rename source: \u to \u -only same directory renames are supported");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean changeWorkingDirectory(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: boolean rename(java.lang.String,java.lang.String)>(v, v);
return v;
}
public oadd.org.apache.hadoop.fs.Path getWorkingDirectory()
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.hadoop.fs.Path getHomeDirectory()>();
return v;
}
public oadd.org.apache.hadoop.fs.Path getHomeDirectory()
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
java.io.IOException v, v, v;
oadd.org.apache.hadoop.fs.ftp.FTPException v, v, v;
oadd.org.apache.commons.net.ftp.FTPClient v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v = null;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: oadd.org.apache.commons.net.ftp.FTPClient connect()>();
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: java.lang.String printWorkingDirectory()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.ftp.FTPException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to disconnect", v);
throw v;
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.ftp.FTPException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to get home directory", v);
throw v;
label:
v := @caughtexception;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: void disconnect(oadd.org.apache.commons.net.ftp.FTPClient)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.ftp.FTPException;
specialinvoke v.<oadd.org.apache.hadoop.fs.ftp.FTPException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to disconnect", v);
throw v;
label:
throw v;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
public void setWorkingDirectory(oadd.org.apache.hadoop.fs.Path)
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.ftp.FTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.ftp.FTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/fs/ftp/FTPFileSystem;");
<oadd.org.apache.hadoop.fs.ftp.FTPFileSystem: org.slf4j.Logger LOG> = v;
return;
}
}