summaryrefslogtreecommitdiff
path: root/src/mongo/db/catalog/collection_compact.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/catalog/collection_compact.cpp')
-rw-r--r--src/mongo/db/catalog/collection_compact.cpp11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/mongo/db/catalog/collection_compact.cpp b/src/mongo/db/catalog/collection_compact.cpp
index f143dd89d1d..dbb1130ce2c 100644
--- a/src/mongo/db/catalog/collection_compact.cpp
+++ b/src/mongo/db/catalog/collection_compact.cpp
@@ -50,14 +50,13 @@ using logv2::LogComponent;
namespace {
-const Collection* getCollectionForCompact(OperationContext* opCtx,
- Database* database,
- const NamespaceString& collectionNss) {
+CollectionPtr getCollectionForCompact(OperationContext* opCtx,
+ Database* database,
+ const NamespaceString& collectionNss) {
invariant(opCtx->lockState()->isCollectionLockedForMode(collectionNss, MODE_IX));
CollectionCatalog& collectionCatalog = CollectionCatalog::get(opCtx);
- const Collection* collection =
- collectionCatalog.lookupCollectionByNamespace(opCtx, collectionNss);
+ CollectionPtr collection = collectionCatalog.lookupCollectionByNamespace(opCtx, collectionNss);
if (!collection) {
std::shared_ptr<ViewDefinition> view =
@@ -82,7 +81,7 @@ StatusWith<int64_t> compactCollection(OperationContext* opCtx,
boost::optional<Lock::CollectionLock> collLk;
collLk.emplace(opCtx, collectionNss, MODE_X);
- const Collection* collection = getCollectionForCompact(opCtx, database, collectionNss);
+ CollectionPtr collection = getCollectionForCompact(opCtx, database, collectionNss);
DisableDocumentValidation validationDisabler(opCtx);
auto recordStore = collection->getRecordStore();