summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/common/io/FileSystemUtilsTests.java
diff options
context:
space:
mode:
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.java85
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() {