summaryrefslogtreecommitdiff
path: root/src/mongo/db/catalog/multi_index_block_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/catalog/multi_index_block_test.cpp')
-rw-r--r--src/mongo/db/catalog/multi_index_block_test.cpp59
1 files changed, 31 insertions, 28 deletions
diff --git a/src/mongo/db/catalog/multi_index_block_test.cpp b/src/mongo/db/catalog/multi_index_block_test.cpp
index 5a7323991e0..86eb8c52098 100644
--- a/src/mongo/db/catalog/multi_index_block_test.cpp
+++ b/src/mongo/db/catalog/multi_index_block_test.cpp
@@ -28,9 +28,12 @@
* it in the license file.
*/
+#include "mongo/platform/basic.h"
+
+#include "mongo/db/catalog/multi_index_block.h"
+
#include "mongo/db/catalog/collection_mock.h"
#include "mongo/db/catalog/index_catalog_noop.h"
-#include "mongo/db/catalog/multi_index_block_impl.h"
#include "mongo/db/jsobj.h"
#include "mongo/db/repl/replication_coordinator_mock.h"
#include "mongo/db/service_context_test_fixture.h"
@@ -54,12 +57,12 @@ private:
protected:
OperationContext* getOpCtx() const;
Collection* getCollection() const;
- MultiIndexBlockImpl* getIndexer() const;
+ MultiIndexBlock* getIndexer() const;
private:
ServiceContext::UniqueOperationContext _opCtx;
std::unique_ptr<Collection> _collection;
- std::unique_ptr<MultiIndexBlockImpl> _indexer;
+ std::unique_ptr<MultiIndexBlock> _indexer;
};
void MultiIndexBlockTest::setUp() {
@@ -76,7 +79,7 @@ void MultiIndexBlockTest::setUp() {
std::make_unique<CollectionMock>(nss, std::make_unique<IndexCatalogNoop>());
_collection = std::make_unique<Collection>(std::move(collectionMock));
- _indexer = std::make_unique<MultiIndexBlockImpl>(_opCtx.get(), _collection.get());
+ _indexer = std::make_unique<MultiIndexBlock>(_opCtx.get(), _collection.get());
}
void MultiIndexBlockTest::tearDown() {
@@ -100,17 +103,17 @@ Collection* MultiIndexBlockTest::getCollection() const {
return _collection.get();
}
-MultiIndexBlockImpl* MultiIndexBlockTest::getIndexer() const {
+MultiIndexBlock* MultiIndexBlockTest::getIndexer() const {
return _indexer.get();
}
TEST_F(MultiIndexBlockTest, CommitWithoutInsertingDocuments) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
auto specs = unittest::assertGet(indexer->init(std::vector<BSONObj>()));
ASSERT_EQUALS(0U, specs.size());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
ASSERT_OK(indexer->dumpInsertsFromBulk());
@@ -121,16 +124,16 @@ TEST_F(MultiIndexBlockTest, CommitWithoutInsertingDocuments) {
wunit.commit();
}
ASSERT(indexer->isCommitted());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kCommitted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kCommitted, indexer->getState_forTest());
}
TEST_F(MultiIndexBlockTest, CommitAfterInsertingSingleDocument) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
auto specs = unittest::assertGet(indexer->init(std::vector<BSONObj>()));
ASSERT_EQUALS(0U, specs.size());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
ASSERT_OK(indexer->insert({}, {}, nullptr));
ASSERT_OK(indexer->dumpInsertsFromBulk());
@@ -154,80 +157,80 @@ TEST_F(MultiIndexBlockTest, AbortWithoutCleanupAfterInsertingSingleDocument) {
ASSERT_EQUALS(0U, specs.size());
ASSERT_OK(indexer->insert({}, {}, nullptr));
indexer->abortWithoutCleanup();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_FALSE(indexer->isCommitted());
}
TEST_F(MultiIndexBlockTest, InitFailsAfterAbort) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
indexer->abort("test"_sd);
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_EQUALS(ErrorCodes::IndexBuildAborted, indexer->init(std::vector<BSONObj>()).getStatus());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_FALSE(indexer->isCommitted());
}
TEST_F(MultiIndexBlockTest, InsertingSingleDocumentFailsAfterAbort) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
auto specs = unittest::assertGet(indexer->init(std::vector<BSONObj>()));
ASSERT_EQUALS(0U, specs.size());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
indexer->abort("test"_sd);
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_EQUALS(ErrorCodes::IndexBuildAborted,
indexer->insert(BSON("_id" << 123 << "a" << 456), {}, nullptr));
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_FALSE(indexer->isCommitted());
}
TEST_F(MultiIndexBlockTest, dumpInsertsFromBulkFailsAfterAbort) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
auto specs = unittest::assertGet(indexer->init(std::vector<BSONObj>()));
ASSERT_EQUALS(0U, specs.size());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
ASSERT_OK(indexer->insert(BSON("_id" << 123 << "a" << 456), {}, nullptr));
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
indexer->abort("test"_sd);
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_EQUALS(ErrorCodes::IndexBuildAborted, indexer->dumpInsertsFromBulk());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_FALSE(indexer->isCommitted());
}
TEST_F(MultiIndexBlockTest, CommitFailsAfterAbort) {
auto indexer = getIndexer();
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kUninitialized, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kUninitialized, indexer->getState_forTest());
auto specs = unittest::assertGet(indexer->init(std::vector<BSONObj>()));
ASSERT_EQUALS(0U, specs.size());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
ASSERT_OK(indexer->insert(BSON("_id" << 123 << "a" << 456), {}, nullptr));
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kRunning, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kRunning, indexer->getState_forTest());
ASSERT_OK(indexer->dumpInsertsFromBulk());
indexer->abort("test"_sd);
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_EQUALS(ErrorCodes::IndexBuildAborted, indexer->commit());
- ASSERT_EQUALS(MultiIndexBlockImpl::State::kAborted, indexer->getState_forTest());
+ ASSERT_EQUALS(MultiIndexBlock::State::kAborted, indexer->getState_forTest());
ASSERT_FALSE(indexer->isCommitted());
}
View Lorry Controller Status