public class org.apache.nifi.processors.standard.util.TestServerSFTPTransfer extends java.lang.Object
{
private static final java.lang.String LOCALHOST;
private static final java.lang.String USERNAME;
private static final java.lang.String PASSWORD;
private static final java.lang.String DIR_1;
private static final java.lang.String DIR_2;
private static final java.lang.String LINKED_DIRECTORY;
private static final java.lang.String LINKED_FILE;
private static final java.lang.String EMPTY_DIRECTORY;
private static final java.lang.String DIR_1_CHILD_1;
private static final java.lang.String DIR_1_CHILD_2;
private static final java.lang.String FILE_1;
private static final java.lang.String FILE_2;
private static final java.lang.String DOT_FILE;
private static final boolean FILTERING_ENABLED;
java.io.File serverDirectory;
private org.apache.sshd.server.SshServer sshServer;
public void <init>()
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setupFiles() throws java.io.IOException
{
java.lang.String[] v, v, v, v, v, v, v, v, v;
java.nio.file.attribute.FileAttribute[] v, v;
java.lang.String v;
java.nio.file.Path v, v, v, v;
boolean v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child1";
v[2] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child1";
v[2] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child1";
v[2] = ".foo.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child2";
v[2] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child2";
v[2] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[3];
v[0] = "dir1";
v[1] = "child2";
v[2] = ".foo.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[2];
v[0] = "dir2";
v[1] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[2];
v[0] = "dir2";
v[1] = "file.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = newarray (java.lang.String)[2];
v[0] = "dir2";
v[1] = ".foo.txt";
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void writeFile(java.lang.String[])>(v);
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "linked-directory");
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String,java.lang.String)>(v, "dir1");
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createSymbolicLink(java.nio.file.Path,java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v, v);
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "dir2");
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "linked-file");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "file.txt");
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createSymbolicLink(java.nio.file.Path,java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v, v);
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "dir4");
v = virtualinvoke v.<java.io.File: boolean mkdirs()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: void startServer()>();
return;
}
public void stopServer() throws java.io.IOException
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.sshd.server.SshServer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
virtualinvoke v.<org.apache.sshd.server.SshServer: void stop(boolean)>(1);
return;
}
public void testGetListingSimple() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.Map v;
int v;
boolean v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.util.function.Predicate v, v;
java.util.List v;
java.util.stream.Stream v, v, v, v;
java.util.Optional v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testGetListingSimple_0__299: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: boolean isDirectory()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testGetListingSimple_1__300: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: boolean isDirectory()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingSimpleWithDotFiles() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.util.function.Predicate v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
java.util.stream.Stream v, v;
java.util.Map v;
int v;
java.util.Optional v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor IGNORE_DOTTED_FILES>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "false");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(3, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testGetListingSimpleWithDotFiles_2__301: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithoutRecursiveSearch() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir1");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "false");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithRecursiveSearch() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir1");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(4, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithoutSymlinks() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor FOLLOW_SYMLINK>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "false");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(6, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithSymlinks() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor FOLLOW_SYMLINK>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(11, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithBatchSize() throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v, v;
java.util.Map v;
int v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir1");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(4, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_POLL_BATCH_SIZE>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "2");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithFileFilter() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.function.Consumer v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir1");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor FILE_FILTER_REGEX>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "file.*");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testGetListingWithFileFilter_3__302: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWithPathFilter() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, ".");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PATH_FILTER_REGEX>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir1/child1");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetListingWhenRemotePathDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "DOES-NOT-EXIST");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testGetListingWhenRemotePathDoesNotExist_4__303: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testDeleteFileWithoutPath() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.util.Iterator v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v, v;
java.util.Map v;
int v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = interfaceinvoke v.<java.util.List: 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.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getFullPathFileName()>();
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void deleteFile(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, null, v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testDeleteFileWithPath() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.util.Iterator v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v, v;
java.util.Map v;
int v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = interfaceinvoke v.<java.util.List: 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.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getFileName()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getFullPathFileName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>(v, "");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void deleteFile(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testDeleteFileWhenDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testDeleteFileWhenDoesNotExist_5__304: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testDeleteDirectory() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir4");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void deleteDirectory(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "dir4");
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testDeleteDirectory_6__305: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testDeleteDirectoryWhenDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testDeleteDirectoryWhenDoesNotExist_7__306: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsSimple() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "DOES-NOT-EXIST");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testEnsureDirectoryExistsSimple_8__307: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "DOES-NOT-EXIST");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(null, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsMultipleLevels() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "A/B/C");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testEnsureDirectoryExistsMultipleLevels_9__308: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "A/B/C");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(null, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsWhenAlreadyExists() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "dir2");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(null, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsWithDirectoryListingDisabled() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "DOES-NOT-EXIST");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testEnsureDirectoryExistsWithDirectoryListingDisabled_10__309: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "DOES-NOT-EXIST");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(null, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsWithDirectoryListingDisabledAndAlreadyExists() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "dir2");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.util.List getListing(boolean)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "dir2");
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testEnsureDirectoryExistsWithDirectoryListingDisabledAndAlreadyExists_11__310: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,java.lang.String)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testEnsureDirectoryExistsWithDirectoryListingDisabledAndParentDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "A/B/C");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "true");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testEnsureDirectoryExistsWithDirectoryListingDisabledAndParentDoesNotExist_12__311: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String getAbsolutePath(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(null, "A/B/C");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(null, v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetRemoteFileInfo() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "file.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getFileName()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("file.txt", v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetRemoteFileInfoWhenPathDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "DOES-NOT-EXIST", "file.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetRemoteFileInfoWhenFileDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "DOES-NOT-EXIST");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetRemoteFileInfoWhenFileIsADirectory() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir1", "child1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testRename() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v, v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "file.txt-RENAMED");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void rename(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2/file.txt", "dir2/file.txt-RENAMED");
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "file.txt-RENAMED");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testRenameWhenSourceDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testRenameWhenSourceDoesNotExist_13__312: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/FileNotFoundException;", v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testRenameWhenTargetAlreadyExists() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.FileInfo v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "file.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testRenameWhenTargetAlreadyExists_14__313: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testPutWithPermissions() throws java.io.IOException
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.util.FileInfo v, v;
org.apache.nifi.components.PropertyDescriptor v;
java.io.ByteArrayInputStream v;
java.nio.charset.Charset v, v;
java.util.Map v;
java.lang.String v, v, v, v;
java.net.URI v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
java.io.File v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PERMISSIONS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "rw-rw-rw-");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = new java.io.ByteArrayInputStream;
v = "this is a test";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String put(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,java.io.InputStream)>(null, "dir4", "test-put-simple.txt", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getPermissions()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("rw-rw-rw-", v);
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "dir4/test-put-simple.txt");
v = virtualinvoke v.<java.io.File: java.net.URI toURI()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = staticinvoke <org.apache.commons.io.IOUtils: java.lang.String toString(java.net.URI,java.nio.charset.Charset)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("this is a test", v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testPutWithTempFilename() throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
byte[] v;
org.apache.nifi.processors.standard.util.FileInfo v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.io.ByteArrayInputStream v;
java.nio.charset.Charset v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PERMISSIONS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "rw-rw-rw-");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor TEMP_FILENAME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "temp-file.txt");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = new java.io.ByteArrayInputStream;
v = "this is a test";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String put(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,java.io.InputStream)>(null, "dir4", "test-put-simple.txt", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getPermissions()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("rw-rw-rw-", v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testPutWithLastModifiedTime() throws java.io.IOException, java.text.ParseException
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.util.FileInfo v, v;
java.util.Date v;
java.text.SimpleDateFormat v;
long v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.io.ByteArrayInputStream v;
java.nio.charset.Charset v;
java.util.Locale v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = new java.text.SimpleDateFormat;
v = <java.util.Locale: java.util.Locale US>;
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String,java.util.Locale)>("yyyy-MM-dd\'T\'HH:mm:ssZ", v);
v = virtualinvoke v.<java.text.DateFormat: java.util.Date parse(java.lang.String)>("2019-09-01T11:11:11-0500");
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PERMISSIONS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "rw-rw-rw-");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor LAST_MODIFIED_TIME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "2019-09-01T11:11:11-0500");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = new java.io.ByteArrayInputStream;
v = "this is a test";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: java.lang.String put(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String,java.io.InputStream)>(null, "dir4", "test-put-simple.txt", v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir4", "test-put-simple.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: java.lang.String getPermissions()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("rw-rw-rw-", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.FileInfo: long getLastModifiedTime()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(v, v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testPutWhenFileAlreadyExists() throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
byte[] v;
org.apache.nifi.processors.standard.util.FileInfo v;
org.apache.nifi.components.PropertyDescriptor v;
java.io.ByteArrayInputStream v;
java.nio.charset.Charset v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PERMISSIONS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "rw-rw-rw-");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = new java.io.ByteArrayInputStream;
v = "this is a test";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(null, "dir2", "file.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testPutWhenFileAlreadyExists_15__314: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,java.io.InputStream)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void testPutWhenDirectoryDoesNotExist() throws java.io.IOException
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
byte[] v;
org.apache.nifi.components.PropertyDescriptor v;
java.io.ByteArrayInputStream v;
java.nio.charset.Charset v;
org.junit.jupiter.api.function.Executable v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.util.Map createBaseProperties()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PERMISSIONS>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "rw-rw-rw-");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)>(v);
label:
v = new java.io.ByteArrayInputStream;
v = "this is a test";
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
label:
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_testPutWhenDirectoryDoesNotExist_16__315: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,java.io.InputStream)>(v, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private java.util.Map createBaseProperties()
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.sshd.server.SshServer v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
int v;
java.lang.Boolean v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor HOSTNAME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "127.0.0.1");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PORT>;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
v = virtualinvoke v.<org.apache.sshd.server.SshServer: int getPort()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor USERNAME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, "user");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
v = <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.lang.String PASSWORD>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor STRICT_HOST_KEY_CHECKING>;
v = <java.lang.Boolean: java.lang.Boolean FALSE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
private org.apache.nifi.processors.standard.util.SFTPTransfer createSFTPTransfer(java.util.Map)
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.nifi.util.MockPropertyContext v;
java.util.Map v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v := @parameter: java.util.Map;
v = new org.apache.nifi.util.MockPropertyContext;
specialinvoke v.<org.apache.nifi.util.MockPropertyContext: void <init>(java.util.Map)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/logging/ComponentLog;");
v = new org.apache.nifi.processors.standard.util.SFTPTransfer;
specialinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void <init>(org.apache.nifi.context.PropertyContext,org.apache.nifi.logging.ComponentLog)>(v, v);
return v;
}
private void startServer() throws java.io.IOException
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
org.apache.sshd.common.file.virtualfs.VirtualFileSystemFactory v;
org.apache.sshd.server.SshServer v, v, v, v, v, v, v;
org.apache.sshd.server.keyprovider.SimpleGeneratorHostKeyProvider v;
java.io.File v;
java.util.List v;
org.apache.sshd.sftp.server.SftpSubsystemFactory v;
java.nio.file.Path v;
org.apache.sshd.server.auth.password.PasswordAuthenticator v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v = staticinvoke <org.apache.sshd.server.SshServer: org.apache.sshd.server.SshServer setUpDefaultServer()>();
v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer> = v;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
virtualinvoke v.<org.apache.sshd.server.SshServer: void setHost(java.lang.String)>("127.0.0.1");
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
v = staticinvoke <org.apache.nifi.processors.standard.util.TestServerSFTPTransfer$lambda_startServer_17__316: org.apache.sshd.server.auth.password.PasswordAuthenticator bootstrap$()>();
virtualinvoke v.<org.apache.sshd.server.SshServer: void setPasswordAuthenticator(org.apache.sshd.server.auth.password.PasswordAuthenticator)>(v);
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
v = new org.apache.sshd.server.keyprovider.SimpleGeneratorHostKeyProvider;
specialinvoke v.<org.apache.sshd.server.keyprovider.SimpleGeneratorHostKeyProvider: void <init>()>();
virtualinvoke v.<org.apache.sshd.server.SshServer: void setKeyPairProvider(org.apache.sshd.common.keyprovider.KeyPairProvider)>(v);
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
v = new org.apache.sshd.common.file.virtualfs.VirtualFileSystemFactory;
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
specialinvoke v.<org.apache.sshd.common.file.virtualfs.VirtualFileSystemFactory: void <init>(java.nio.file.Path)>(v);
virtualinvoke v.<org.apache.sshd.server.SshServer: void setFileSystemFactory(org.apache.sshd.common.file.FileSystemFactory)>(v);
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
v = new org.apache.sshd.sftp.server.SftpSubsystemFactory;
specialinvoke v.<org.apache.sshd.sftp.server.SftpSubsystemFactory: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
virtualinvoke v.<org.apache.sshd.server.SshServer: void setSubsystemFactories(java.util.List)>(v);
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: org.apache.sshd.server.SshServer sshServer>;
virtualinvoke v.<org.apache.sshd.server.SshServer: void start()>();
return;
}
private transient void writeFile(java.lang.String[]) throws java.io.IOException
{
org.apache.nifi.processors.standard.util.TestServerSFTPTransfer v;
byte[] v;
java.lang.String[] v;
java.io.File v, v, v, v;
java.nio.charset.Charset v;
java.nio.file.OpenOption[] v;
java.lang.String v, v;
java.nio.file.Path v;
v := @this: org.apache.nifi.processors.standard.util.TestServerSFTPTransfer;
v := @parameter: java.lang.String[];
v = v.<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.io.File serverDirectory>;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: java.io.File getParentFile()>();
staticinvoke <org.apache.commons.io.FileUtils: void forceMkdir(java.io.File)>(v);
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = newarray (java.nio.file.OpenOption)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path write(java.nio.file.Path,byte[],java.nio.file.OpenOption[])>(v, v, v);
return;
}
static void <clinit>()
{
java.lang.String v;
java.util.UUID v;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
<org.apache.nifi.processors.standard.util.TestServerSFTPTransfer: java.lang.String PASSWORD> = v;
return;
}
}