summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/idempotency_test_fixture.cpp
diff options
context:
space:
mode:
authorXiangyu Yao <xiangyu.yao@mongodb.com>2019-06-14 22:27:55 -0400
committerXiangyu Yao <xiangyu.yao@mongodb.com>2019-06-21 20:01:19 -0400
commit77ccfbefcd740051597d1cb4eb36d25776926f72 (patch)
treec2c74f14e5acb9a52b39a5bca875d51b89ac9f6c /src/mongo/db/repl/idempotency_test_fixture.cpp
parent957f32bcbd3b3485516acdff5c6e99f5b8f790b2 (diff)
downloadmongo-77ccfbefcd740051597d1cb4eb36d25776926f72.tar.gz
SERVER-41819 Move methods from KVCollectionCatalogEntry to KVCatalog
Diffstat (limited to 'src/mongo/db/repl/idempotency_test_fixture.cpp')
-rw-r--r--src/mongo/db/repl/idempotency_test_fixture.cpp9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/db/repl/idempotency_test_fixture.cpp b/src/mongo/db/repl/idempotency_test_fixture.cpp
index ac0a2510718..cf367c53a30 100644
--- a/src/mongo/db/repl/idempotency_test_fixture.cpp
+++ b/src/mongo/db/repl/idempotency_test_fixture.cpp
@@ -57,6 +57,7 @@
#include "mongo/db/repl/replication_consistency_markers_mock.h"
#include "mongo/db/repl/replication_coordinator_mock.h"
#include "mongo/db/repl/storage_interface.h"
+#include "mongo/db/storage/durable_catalog.h"
#include "mongo/util/md5.hpp"
namespace mongo {
@@ -620,13 +621,13 @@ CollectionState IdempotencyTest::validate(const NamespaceString& nss) {
std::string dataHash = computeDataHash(collection);
- auto collectionCatalog = collection->getCatalogEntry();
- auto collectionOptions = collectionCatalog->getCollectionOptions(_opCtx.get());
+ auto durableCatalog = DurableCatalog::get(_opCtx.get());
+ auto collectionOptions = durableCatalog->getCollectionOptions(_opCtx.get(), collection->ns());
std::vector<std::string> allIndexes;
BSONObjSet indexSpecs = SimpleBSONObjComparator::kInstance.makeBSONObjSet();
- collectionCatalog->getAllIndexes(_opCtx.get(), &allIndexes);
+ durableCatalog->getAllIndexes(_opCtx.get(), collection->ns(), &allIndexes);
for (auto const& index : allIndexes) {
- indexSpecs.insert(collectionCatalog->getIndexSpec(_opCtx.get(), index));
+ indexSpecs.insert(durableCatalog->getIndexSpec(_opCtx.get(), collection->ns(), index));
}
ASSERT_EQUALS(indexSpecs.size(), allIndexes.size());