diff --git a/src/test/java/org/elasticsearch/index/store/StoreTest.java b/src/test/java/org/elasticsearch/index/store/StoreTest.java index c1199f09a66..3a60b62ea3a 100644 --- a/src/test/java/org/elasticsearch/index/store/StoreTest.java +++ b/src/test/java/org/elasticsearch/index/store/StoreTest.java @@ -45,14 +45,12 @@ import org.junit.Test; import java.io.FileNotFoundException; import java.io.IOException; -import java.nio.file.Files; import java.nio.file.NoSuchFileException; import java.util.*; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.zip.Adler32; -import static com.carrotsearch.randomizedtesting.RandomizedTest.*; import static org.hamcrest.Matchers.*; public class StoreTest extends ElasticsearchTestCase { @@ -481,7 +479,7 @@ public class StoreTest extends ElasticsearchTestCase { output.close(); } store.renameFile("foo.bar", "bar.foo"); - assertThat(store.directory().listAll().length, is(1)); + assertThat(numNonExtraFiles(store), is(1)); final long lastChecksum; try (IndexInput input = store.directory().openInput("bar.foo", IOContext.DEFAULT)) { lastChecksum = CodecUtil.checksumEntireFile(input); @@ -504,7 +502,7 @@ public class StoreTest extends ElasticsearchTestCase { output.close(); } store.renameFile("foo.bar", "bar.foo"); - assertThat(store.directory().listAll().length, is(1)); + assertThat(numNonExtraFiles(store), is(1)); assertDeleteContent(store, directoryService); IOUtils.close(store); } @@ -925,7 +923,7 @@ public class StoreTest extends ElasticsearchTestCase { Store.LegacyChecksums checksums = new Store.LegacyChecksums(); Map legacyMeta = new HashMap<>(); for (String file : store.directory().listAll()) { - if (file.equals("write.lock") || file.equals(IndexFileNames.OLD_SEGMENTS_GEN)) { + if (file.equals("write.lock") || file.equals(IndexFileNames.OLD_SEGMENTS_GEN) || file.startsWith("extra")) { continue; } BytesRef hash = new BytesRef(); @@ -944,6 +942,9 @@ public class StoreTest extends ElasticsearchTestCase { int numChecksums = 0; int numNotFound = 0; for (String file : strings) { + if (file.startsWith("extra")) { + continue; + } assertTrue(firstMeta.contains(file) || Store.isChecksum(file) || file.equals("write.lock")); if (Store.isChecksum(file)) { numChecksums++; @@ -960,6 +961,9 @@ public class StoreTest extends ElasticsearchTestCase { int numChecksums = 0; int numNotFound = 0; for (String file : strings) { + if (file.startsWith("extra")) { + continue; + } assertTrue(file, secondMeta.contains(file) || Store.isChecksum(file) || file.equals("write.lock")); if (Store.isChecksum(file)) { numChecksums++; @@ -1044,7 +1048,7 @@ public class StoreTest extends ElasticsearchTestCase { length = output.getFilePointer(); } - assertTrue(store.directory().listAll().length > 0); + assertTrue(numNonExtraFiles(store) > 0); stats = store.stats(); assertEquals(stats.getSizeInBytes(), length); @@ -1067,4 +1071,14 @@ public class StoreTest extends ElasticsearchTestCase { } ExceptionsHelper.rethrowAndSuppress(exceptions); } + + public int numNonExtraFiles(Store store) throws IOException { + int numNonExtra = 0; + for (String file : store.directory().listAll()) { + if (file.startsWith("extra") == false) { + numNonExtra++; + } + } + return numNonExtra; + } }