diff options
Diffstat (limited to 'src/mongo/db/repl/storage_interface_impl.cpp')
-rw-r--r-- | src/mongo/db/repl/storage_interface_impl.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/repl/storage_interface_impl.cpp b/src/mongo/db/repl/storage_interface_impl.cpp index 9182c310c02..6e16222e547 100644 --- a/src/mongo/db/repl/storage_interface_impl.cpp +++ b/src/mongo/db/repl/storage_interface_impl.cpp @@ -245,7 +245,7 @@ StorageInterfaceImpl::createCollectionForBulkLoading( { // Create the collection. WriteUnitOfWork wunit(opCtx.get()); - auto db = autoDb.ensureDbExists(); + auto db = autoDb.ensureDbExists(opCtx.get()); fassert(40332, db->createCollection(opCtx.get(), nss, options, false)); wunit.commit(); } @@ -475,7 +475,7 @@ Status StorageInterfaceImpl::createCollection(OperationContext* opCtx, const BSONObj& idIndexSpec) { return writeConflictRetry(opCtx, "StorageInterfaceImpl::createCollection", nss.ns(), [&] { AutoGetDb databaseWriteGuard(opCtx, nss.db(), MODE_IX); - auto db = databaseWriteGuard.ensureDbExists(); + auto db = databaseWriteGuard.ensureDbExists(opCtx); invariant(db); if (CollectionCatalog::get(opCtx)->lookupCollectionByNamespace(opCtx, nss)) { return Status(ErrorCodes::NamespaceExists, |