diff options
Diffstat (limited to 'src/mongo/db/catalog/multi_index_block.cpp')
| -rw-r--r-- | src/mongo/db/catalog/multi_index_block.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/catalog/multi_index_block.cpp b/src/mongo/db/catalog/multi_index_block.cpp index 91f4d9e383d..d2722cb0368 100644 --- a/src/mongo/db/catalog/multi_index_block.cpp +++ b/src/mongo/db/catalog/multi_index_block.cpp @@ -40,6 +40,7 @@ #include "mongo/db/catalog/collection.h" #include "mongo/db/catalog/index_timestamp_helper.h" #include "mongo/db/catalog/multi_index_block_gen.h" +#include "mongo/db/catalog/uncommitted_collections.h" #include "mongo/db/client.h" #include "mongo/db/concurrency/write_conflict_exception.h" #include "mongo/db/index/multikey_paths.h" @@ -116,8 +117,8 @@ void MultiIndexBlock::cleanUpAfterBuild(OperationContext* opCtx, } auto nss = collection->ns(); - - invariant(opCtx->lockState()->isCollectionLockedForMode(nss, MODE_X), nss.toString()); + invariant(UncommittedCollections::get(opCtx).hasExclusiveAccessToCollection(opCtx, nss), + nss.toString()); while (true) { try { |