From 3e49223a0e6460c6357d810b358f38c1e71aa9bb Mon Sep 17 00:00:00 2001 From: Tor Egge Date: Thu, 13 Jan 2022 12:30:51 +0100 Subject: Rename ActiveDiskIndexes to DiskIndexes. Rename IndexDiskDirActiveState to IndexDiskDirState. --- .../tests/proton/index/diskindexcleaner_test.cpp | 32 +++++++++++----------- 1 file changed, 16 insertions(+), 16 deletions(-) (limited to 'searchcore') diff --git a/searchcore/src/tests/proton/index/diskindexcleaner_test.cpp b/searchcore/src/tests/proton/index/diskindexcleaner_test.cpp index 0510d07c086..c814bdf3f37 100644 --- a/searchcore/src/tests/proton/index/diskindexcleaner_test.cpp +++ b/searchcore/src/tests/proton/index/diskindexcleaner_test.cpp @@ -1,7 +1,7 @@ // Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. // Unit tests for diskindexcleaner. -#include +#include #include #include #include @@ -90,8 +90,8 @@ void createIndexes() { void Test::requireThatAllIndexesOlderThanLastFusionIsRemoved() { createIndexes(); - ActiveDiskIndexes active_indexes; - DiskIndexCleaner::clean(index_dir, active_indexes); + DiskIndexes disk_indexes; + DiskIndexCleaner::clean(index_dir, disk_indexes); vector indexes = readIndexes(); EXPECT_EQUAL(3u, indexes.size()); EXPECT_TRUE(contains(indexes, "index.fusion.2")); @@ -101,17 +101,17 @@ void Test::requireThatAllIndexesOlderThanLastFusionIsRemoved() { void Test::requireThatIndexesInUseAreNotRemoved() { createIndexes(); - ActiveDiskIndexes active_indexes; - active_indexes.setActive(index_dir + "/index.fusion.1", 0); - active_indexes.setActive(index_dir + "/index.flush.2", 0); - DiskIndexCleaner::clean(index_dir, active_indexes); + DiskIndexes disk_indexes; + disk_indexes.setActive(index_dir + "/index.fusion.1", 0); + disk_indexes.setActive(index_dir + "/index.flush.2", 0); + DiskIndexCleaner::clean(index_dir, disk_indexes); vector indexes = readIndexes(); EXPECT_TRUE(contains(indexes, "index.fusion.1")); EXPECT_TRUE(contains(indexes, "index.flush.2")); - active_indexes.notActive(index_dir + "/index.fusion.1"); - active_indexes.notActive(index_dir + "/index.flush.2"); - DiskIndexCleaner::clean(index_dir, active_indexes); + disk_indexes.notActive(index_dir + "/index.fusion.1"); + disk_indexes.notActive(index_dir + "/index.flush.2"); + DiskIndexCleaner::clean(index_dir, disk_indexes); indexes = readIndexes(); EXPECT_TRUE(!contains(indexes, "index.fusion.1")); EXPECT_TRUE(!contains(indexes, "index.flush.2")); @@ -120,8 +120,8 @@ void Test::requireThatIndexesInUseAreNotRemoved() { void Test::requireThatInvalidFlushIndexesAreRemoved() { createIndexes(); FastOS_File((index_dir + "/index.flush.4/serial.dat").c_str()).Delete(); - ActiveDiskIndexes active_indexes; - DiskIndexCleaner::clean(index_dir, active_indexes); + DiskIndexes disk_indexes; + DiskIndexCleaner::clean(index_dir, disk_indexes); vector indexes = readIndexes(); EXPECT_EQUAL(2u, indexes.size()); EXPECT_TRUE(contains(indexes, "index.fusion.2")); @@ -131,8 +131,8 @@ void Test::requireThatInvalidFlushIndexesAreRemoved() { void Test::requireThatInvalidFusionIndexesAreRemoved() { createIndexes(); FastOS_File((index_dir + "/index.fusion.2/serial.dat").c_str()).Delete(); - ActiveDiskIndexes active_indexes; - DiskIndexCleaner::clean(index_dir, active_indexes); + DiskIndexes disk_indexes; + DiskIndexCleaner::clean(index_dir, disk_indexes); vector indexes = readIndexes(); EXPECT_EQUAL(4u, indexes.size()); EXPECT_TRUE(contains(indexes, "index.fusion.1")); @@ -144,8 +144,8 @@ void Test::requireThatInvalidFusionIndexesAreRemoved() { void Test::requireThatRemoveDontTouchNewIndexes() { createIndexes(); FastOS_File((index_dir + "/index.flush.4/serial.dat").c_str()).Delete(); - ActiveDiskIndexes active_indexes; - DiskIndexCleaner::removeOldIndexes(index_dir, active_indexes); + DiskIndexes disk_indexes; + DiskIndexCleaner::removeOldIndexes(index_dir, disk_indexes); vector indexes = readIndexes(); EXPECT_EQUAL(3u, indexes.size()); EXPECT_TRUE(contains(indexes, "index.fusion.2")); -- cgit v1.2.3