public class oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem extends oadd.org.apache.hadoop.fs.FileSystem
{
public static final org.slf4j.Logger LOG;
private oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool connectionPool;
private java.net.URI uri;
private static final int DEFAULT_SFTP_PORT;
private static final int DEFAULT_MAX_CONNECTION;
public static final int DEFAULT_BUFFER_SIZE;
public static final int DEFAULT_BLOCK_SIZE;
public static final java.lang.String FS_SFTP_USER_PREFIX;
public static final java.lang.String FS_SFTP_PASSWORD_PREFIX;
public static final java.lang.String FS_SFTP_HOST;
public static final java.lang.String FS_SFTP_HOST_PORT;
public static final java.lang.String FS_SFTP_KEYFILE;
public static final java.lang.String FS_SFTP_CONNECTION_MAX;
public static final java.lang.String E_SAME_DIRECTORY_ONLY;
public static final java.lang.String E_HOST_NULL;
public static final java.lang.String E_USER_NULL;
public static final java.lang.String E_PATH_DIR;
public static final java.lang.String E_FILE_STATUS;
public static final java.lang.String E_FILE_NOTFOUND;
public static final java.lang.String E_FILE_EXIST;
public static final java.lang.String E_CREATE_DIR;
public static final java.lang.String E_DIR_CREATE_FROMFILE;
public static final java.lang.String E_MAKE_DIR_FORPATH;
public static final java.lang.String E_DIR_NOTEMPTY;
public static final java.lang.String E_FILE_CHECK_FAILED;
public static final java.lang.String E_SPATH_NOTEXIST;
public static final java.lang.String E_DPATH_EXIST;
public static final java.lang.String E_FAILED_GETHOME;
public static final java.lang.String E_FAILED_DISCONNECT;
public void <init>()
{
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
specialinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: void <init>()>();
return;
}
private void setConfigurationFromURI(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
java.lang.IllegalStateException v;
java.lang.String[] v;
int v, 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;
java.net.URI v;
boolean v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: java.net.URI;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
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.sftp.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.sftp.host", v);
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = (int) -1;
if v != v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("fs.sftp.host.port", 22);
goto label;
label:
v = v;
label:
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void setInt(java.lang.String,int)>("fs.sftp.host.port", v);
v = virtualinvoke v.<java.net.URI: java.lang.String getUserInfo()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(":");
v = v[0];
v = staticinvoke <java.net.URLDecoder: java.lang.String decode(java.lang.String,java.lang.String)>(v, "UTF-8");
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.sftp.user.\u0001");
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>(v, v);
v = lengthof v;
if v <= 1 goto label;
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[])>("fs.sftp.password.\u.\u0001");
v = v[1];
virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void set(java.lang.String,java.lang.String)>(v, v);
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.sftp.user.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v == 0 goto label;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("No user specified for sftp connection. Expand URI or credential file.");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("fs.sftp.connection.max", 5);
v = new oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool: void <init>(int)>(v);
v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool connectionPool> = v;
return;
}
private com.jcraft.jsch.ChannelSftp connect() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
int v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v, v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("fs.sftp.host", null);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("fs.sftp.host.port", 22);
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.sftp.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,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[])>("fs.sftp.password.\u.\u0001");
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>(v, null);
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("fs.sftp.keyfile", null);
v = v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool connectionPool>;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool: com.jcraft.jsch.ChannelSftp connect(java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v);
return v;
}
private void disconnect(com.jcraft.jsch.ChannelSftp) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v = v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool connectionPool>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPConnectionPool: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
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.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
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;
}
private boolean exists(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
java.io.IOException v, v;
oadd.org.apache.hadoop.fs.Path v;
java.io.FileNotFoundException v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
return 1;
label:
v := @caughtexception;
return 0;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>("Failed to get file status", v);
throw v;
catch java.io.FileNotFoundException from label to label with label;
catch java.io.IOException from label to label with label;
}
private oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.util.Vector v;
java.net.URI v, v;
boolean v, v;
java.io.FileNotFoundException v, v, v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
java.lang.Throwable v, v;
java.lang.Object[] v, v, v;
java.lang.String v, v, v, v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
java.util.Iterator v;
java.io.IOException v;
java.lang.Object v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = null;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.Path getWorkingDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path makeQualified(java.net.URI,oadd.org.apache.hadoop.fs.Path)>(v, 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()>();
label:
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.util.Vector ls(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.FileNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("File %s does not exist.", v);
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<java.util.Vector: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: java.lang.String getFilename()>();
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.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,com.jcraft.jsch.ChannelSftp$LsEntry,oadd.org.apache.hadoop.fs.Path)>(v, v, v);
label:
if v != null goto label;
v = new java.io.FileNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("File %s does not exist.", v);
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.io.FileNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("File %s does not exist.", v);
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
private oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp, com.jcraft.jsch.ChannelSftp$LsEntry, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
com.jcraft.jsch.ChannelSftp$LsEntry v;
java.net.URI v, v;
boolean v, v;
com.jcraft.jsch.SftpATTRS v;
java.lang.Exception v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
long v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
java.io.IOException v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: com.jcraft.jsch.ChannelSftp$LsEntry;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: com.jcraft.jsch.SftpATTRS getAttrs()>();
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: long getSize()>();
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: boolean isDir()>();
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: boolean isLink()>();
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()>();
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: java.lang.String getFilename()>();
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.<com.jcraft.jsch.ChannelSftp: java.lang.String realpath(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>("/", v);
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getLen()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: int getMTime()>();
v = v * 1000L;
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: int getATime()>();
v = v * 1000L;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.permission.FsPermission getPermissions(com.jcraft.jsch.ChannelSftp$LsEntry)>(v);
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: int getUId()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: int getGId()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: java.lang.String getFilename()>();
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.sftp.SFTPFileSystem: java.net.URI getUri()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.Path getWorkingDirectory()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path makeQualified(java.net.URI,oadd.org.apache.hadoop.fs.Path)>(v, 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, v, v, v, v, v);
return v;
catch java.lang.Exception from label to label with label;
}
private oadd.org.apache.hadoop.fs.permission.FsPermission getPermissions(com.jcraft.jsch.ChannelSftp$LsEntry)
{
com.jcraft.jsch.ChannelSftp$LsEntry v;
com.jcraft.jsch.SftpATTRS v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
int v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp$LsEntry;
v = new oadd.org.apache.hadoop.fs.permission.FsPermission;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: com.jcraft.jsch.SftpATTRS getAttrs()>();
v = virtualinvoke v.<com.jcraft.jsch.SftpATTRS: int getPermissions()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.permission.FsPermission: void <init>(short)>(v);
return v;
}
private boolean mkdirs(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.permission.FsPermission) throws java.io.IOException
{
java.lang.Throwable v, v;
java.lang.Object[] v, v;
java.lang.String v, v, v, v, v, v;
java.net.URI v;
boolean v, v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.permission.FsPermission v, v;
java.io.IOException v, v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.permission.FsPermission;
v = 1;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: boolean exists(com.jcraft.jsch.ChannelSftp,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 getDefault()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean mkdirs(com.jcraft.jsch.ChannelSftp,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()>();
label:
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>(v);
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void mkdir(java.lang.String)>(v);
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Can\'t make directory for path \"%s\" under \"%s\".", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v & 1;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean isFile(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
v = new java.io.IOException;
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.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
private boolean isFile(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.io.IOException v, v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v;
boolean v, v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v := @caughtexception;
return 0;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: 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;
}
private boolean delete(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path, boolean) throws java.io.IOException
{
java.lang.Throwable v, v, v;
java.lang.Object[] v;
int v, v, v;
java.lang.String v, v, v;
java.net.URI v;
boolean v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
java.io.IOException v, v;
java.io.FileNotFoundException v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
goto label;
label:
v := @caughtexception;
return 0;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
if v != 0 goto label;
v = 1;
label:
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void rm(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = 0;
label:
return v;
label:
v = 1;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(com.jcraft.jsch.ChannelSftp,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 = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Directory: %s is not empty.", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = new oadd.org.apache.hadoop.fs.Path;
v = v[v];
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.sftp.SFTPFileSystem: boolean delete(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v);
v = v + 1;
goto label;
label:
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void rmdir(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = 0;
label:
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch java.io.FileNotFoundException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
private oadd.org.apache.hadoop.fs.FileStatus[] listStatus(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v, v;
java.lang.Object[] v;
java.util.ArrayList v;
java.util.Vector v;
int v, v, v;
java.lang.String v, v, v, v, v;
java.net.URI v;
boolean v, v, v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.FileStatus[] v, v;
java.io.IOException v, v;
oadd.org.apache.hadoop.fs.FileStatus v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
java.lang.Object v;
oadd.org.apache.hadoop.fs.Path v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: boolean isDirectory()>();
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.<com.jcraft.jsch.ChannelSftp: java.util.Vector ls(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
v = virtualinvoke v.<java.util.Vector: int size()>();
if v >= v goto label;
v = virtualinvoke v.<java.util.Vector: java.lang.Object get(int)>(v);
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp$LsEntry: java.lang.String getFilename()>();
v = ".";
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
v = "..";
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v != 0 goto label;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,com.jcraft.jsch.ChannelSftp$LsEntry,oadd.org.apache.hadoop.fs.Path)>(v, v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (oadd.org.apache.hadoop.fs.FileStatus)[v];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
private boolean rename(com.jcraft.jsch.ChannelSftp, oadd.org.apache.hadoop.fs.Path, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
java.lang.Throwable v, v;
java.lang.Object[] v, v;
java.lang.String v, v, v, v, v, v;
java.net.URI v, v;
boolean v, v, v;
com.jcraft.jsch.ChannelSftp v;
java.io.IOException v, v, v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: com.jcraft.jsch.ChannelSftp;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: boolean exists(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v != 0 goto label;
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Source path %s does not exist", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean exists(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Destination path %s already exist, cannot rename!", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 1;
label:
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>("/");
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.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void rename(java.lang.String,java.lang.String)>(v, v);
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = 0;
label:
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
public void initialize(java.net.URI, oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.hadoop.conf.Configuration v;
java.net.URI v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
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);
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void setConfigurationFromURI(java.net.URI,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void setConf(oadd.org.apache.hadoop.conf.Configuration)>(v);
v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: java.net.URI uri> = v;
return;
}
public java.net.URI getUri()
{
java.net.URI v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v = v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: java.net.URI uri>;
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, v;
java.lang.Object[] v;
oadd.org.apache.hadoop.fs.sftp.SFTPInputStream v;
int v;
java.lang.String v, v, v, v, v;
java.net.URI v, v;
boolean v;
com.jcraft.jsch.ChannelSftp v;
oadd.org.apache.hadoop.fs.FSDataInputStream v;
java.io.IOException v, v, v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
oadd.org.apache.hadoop.fs.FileStatus v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v, v, v;
java.io.InputStream v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: int;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,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.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Path %s is a directory.", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new 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.<com.jcraft.jsch.ChannelSftp: java.lang.String realpath(java.lang.String)>(v);
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String,java.lang.String)>("/", v);
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.<com.jcraft.jsch.ChannelSftp: java.io.InputStream get(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = new oadd.org.apache.hadoop.fs.FSDataInputStream;
v = new oadd.org.apache.hadoop.fs.sftp.SFTPInputStream;
v = v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPInputStream: void <init>(java.io.InputStream,com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.FileSystem$Statistics)>(v, v, v);
specialinvoke v.<oadd.org.apache.hadoop.fs.FSDataInputStream: void <init>(java.io.InputStream)>(v);
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException from label to label with label;
}
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
{
java.net.URI v;
boolean v, v, v;
oadd.org.apache.hadoop.util.Progressable v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
java.lang.Throwable v, v;
java.lang.Object[] v, v;
long v;
short v;
int v;
java.lang.String v, v, v, v, v, v;
com.jcraft.jsch.ChannelSftp v;
java.io.OutputStream v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem$1 v;
oadd.org.apache.hadoop.fs.permission.FsPermission v, v;
java.io.IOException v, v, v, 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.sftp.SFTPFileSystem;
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.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: 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.sftp.SFTPFileSystem: boolean exists(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
if v == 0 goto label;
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean delete(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, 0);
goto label;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("File already exists: %s", v);
specialinvoke v.<java.io.IOException: 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 getDefault()>();
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean mkdirs(com.jcraft.jsch.ChannelSftp,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.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
v = new java.io.IOException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("create(): Mkdirs failed to create: %s", v);
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
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.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.lang.String getName()>();
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.io.OutputStream put(java.lang.String)>(v);
virtualinvoke v.<com.jcraft.jsch.ChannelSftp: void cd(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = new oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem$1;
v = v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem$1: void <init>(oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem,java.io.OutputStream,oadd.org.apache.hadoop.fs.FileSystem$Statistics,com.jcraft.jsch.ChannelSftp)>(v, v, v, v);
return v;
catch com.jcraft.jsch.SftpException from label to label with label;
catch com.jcraft.jsch.SftpException 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.sftp.SFTPFileSystem v;
int v;
oadd.org.apache.hadoop.util.Progressable v;
oadd.org.apache.hadoop.fs.Path v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
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 SFTPFileSystem");
throw v;
}
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.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v, v;
boolean v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean rename(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
throw v;
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.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v;
boolean v, v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v := @parameter: boolean;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean delete(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
throw v;
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.IOException
{
java.lang.Throwable v;
oadd.org.apache.hadoop.fs.FileStatus[] v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus[] listStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
throw v;
catch java.lang.Throwable 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.sftp.SFTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
return;
}
public oadd.org.apache.hadoop.fs.Path getWorkingDirectory()
{
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.Path getHomeDirectory()>();
return v;
}
public oadd.org.apache.hadoop.fs.Path getHomeDirectory()
{
java.lang.Throwable v;
java.io.IOException v, v, v;
java.lang.Exception v;
oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v = null;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
v = new oadd.org.apache.hadoop.fs.Path;
v = virtualinvoke v.<com.jcraft.jsch.ChannelSftp: java.lang.String pwd()>();
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
label:
goto label;
label:
v := @caughtexception;
return null;
label:
return v;
label:
v := @caughtexception;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
label:
goto label;
label:
v := @caughtexception;
return null;
label:
return null;
label:
v := @caughtexception;
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
label:
goto label;
label:
v := @caughtexception;
return null;
label:
throw v;
catch java.io.IOException from label to label with label;
catch java.lang.Exception 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 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.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.permission.FsPermission v;
oadd.org.apache.hadoop.fs.Path v;
boolean v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
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.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: boolean mkdirs(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.permission.FsPermission)>(v, v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
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.sftp.SFTPFileSystem v;
oadd.org.apache.hadoop.fs.Path v;
com.jcraft.jsch.ChannelSftp v;
v := @this: oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: com.jcraft.jsch.ChannelSftp connect()>();
label:
v = specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: oadd.org.apache.hadoop.fs.FileStatus getFileStatus(com.jcraft.jsch.ChannelSftp,oadd.org.apache.hadoop.fs.Path)>(v, v);
label:
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
return v;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: void disconnect(com.jcraft.jsch.ChannelSftp)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
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/sftp/SFTPFileSystem;");
<oadd.org.apache.hadoop.fs.sftp.SFTPFileSystem: org.slf4j.Logger LOG> = v;
return;
}
}