diff options
Diffstat (limited to 'core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java')
-rw-r--r-- | core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java | 85 |
1 files changed, 0 insertions, 85 deletions
diff --git a/core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java b/core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java index 4f2b8f6811..b6266773bf 100644 --- a/core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java +++ b/core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java @@ -48,91 +48,6 @@ public class FileSystemUtilsTests extends ESTestCase { dst = createTempDir(); Files.createDirectories(src); Files.createDirectories(dst); - - // We first copy sources test files from src/test/resources - // Because after when the test runs, src files are moved to their destination - final Path path = getDataPath("/org/elasticsearch/common/io/copyappend"); - FileSystemUtils.copyDirectoryRecursively(path, src); - } - - public void testMoveOverExistingFileAndAppend() throws IOException { - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v1"), dst, ".new"); - assertFileContent(dst, "file1.txt", "version1"); - assertFileContent(dst, "dir/file2.txt", "version1"); - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v2"), dst, ".new"); - assertFileContent(dst, "file1.txt", "version1"); - assertFileContent(dst, "dir/file2.txt", "version1"); - assertFileContent(dst, "file1.txt.new", "version2"); - assertFileContent(dst, "dir/file2.txt.new", "version2"); - assertFileContent(dst, "file3.txt", "version1"); - assertFileContent(dst, "dir/subdir/file4.txt", "version1"); - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v3"), dst, ".new"); - assertFileContent(dst, "file1.txt", "version1"); - assertFileContent(dst, "dir/file2.txt", "version1"); - assertFileContent(dst, "file1.txt.new", "version3"); - assertFileContent(dst, "dir/file2.txt.new", "version3"); - assertFileContent(dst, "file3.txt", "version1"); - assertFileContent(dst, "dir/subdir/file4.txt", "version1"); - assertFileContent(dst, "file3.txt.new", "version2"); - assertFileContent(dst, "dir/subdir/file4.txt.new", "version2"); - assertFileContent(dst, "dir/subdir/file5.txt", "version1"); - } - - public void testMoveOverExistingFileAndIgnore() throws IOException { - Path dest = createTempDir(); - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v1"), dest, null); - assertFileContent(dest, "file1.txt", "version1"); - assertFileContent(dest, "dir/file2.txt", "version1"); - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v2"), dest, null); - assertFileContent(dest, "file1.txt", "version1"); - assertFileContent(dest, "dir/file2.txt", "version1"); - assertFileContent(dest, "file1.txt.new", null); - assertFileContent(dest, "dir/file2.txt.new", null); - assertFileContent(dest, "file3.txt", "version1"); - assertFileContent(dest, "dir/subdir/file4.txt", "version1"); - - FileSystemUtils.moveFilesWithoutOverwriting(src.resolve("v3"), dest, null); - assertFileContent(dest, "file1.txt", "version1"); - assertFileContent(dest, "dir/file2.txt", "version1"); - assertFileContent(dest, "file1.txt.new", null); - assertFileContent(dest, "dir/file2.txt.new", null); - assertFileContent(dest, "file3.txt", "version1"); - assertFileContent(dest, "dir/subdir/file4.txt", "version1"); - assertFileContent(dest, "file3.txt.new", null); - assertFileContent(dest, "dir/subdir/file4.txt.new", null); - assertFileContent(dest, "dir/subdir/file5.txt", "version1"); - } - - public void testMoveFilesDoesNotCreateSameFileWithSuffix() throws Exception { - Path[] dirs = new Path[] { createTempDir(), createTempDir(), createTempDir()}; - for (Path dir : dirs) { - Files.write(dir.resolve("file1.txt"), "file1".getBytes(StandardCharsets.UTF_8)); - Files.createDirectory(dir.resolve("dir")); - Files.write(dir.resolve("dir").resolve("file2.txt"), "file2".getBytes(StandardCharsets.UTF_8)); - } - - FileSystemUtils.moveFilesWithoutOverwriting(dirs[0], dst, ".new"); - assertFileContent(dst, "file1.txt", "file1"); - assertFileContent(dst, "dir/file2.txt", "file2"); - - // do the same operation again, make sure, no .new files have been added - FileSystemUtils.moveFilesWithoutOverwriting(dirs[1], dst, ".new"); - assertFileContent(dst, "file1.txt", "file1"); - assertFileContent(dst, "dir/file2.txt", "file2"); - assertFileNotExists(dst.resolve("file1.txt.new")); - assertFileNotExists(dst.resolve("dir").resolve("file2.txt.new")); - - // change file content, make sure it gets updated - Files.write(dirs[2].resolve("dir").resolve("file2.txt"), "UPDATED".getBytes(StandardCharsets.UTF_8)); - FileSystemUtils.moveFilesWithoutOverwriting(dirs[2], dst, ".new"); - assertFileContent(dst, "file1.txt", "file1"); - assertFileContent(dst, "dir/file2.txt", "file2"); - assertFileContent(dst, "dir/file2.txt.new", "UPDATED"); } public void testAppend() { |