diff options
Diffstat (limited to 'src/mongo/db/commands/write_commands/batch_executor.cpp')
| -rw-r--r-- | src/mongo/db/commands/write_commands/batch_executor.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/mongo/db/commands/write_commands/batch_executor.cpp b/src/mongo/db/commands/write_commands/batch_executor.cpp index 1be8e88f502..760696862f2 100644 --- a/src/mongo/db/commands/write_commands/batch_executor.cpp +++ b/src/mongo/db/commands/write_commands/batch_executor.cpp @@ -433,7 +433,7 @@ namespace mongo { WriteOpResult* result) { const NamespaceString& nss = request.getTargetingNSS(); - txn->lockState()->assertWriteLocked( nss.ns() ); + dassert(txn->lockState()->isCollectionLockedForMode(nss.ns(), MODE_IX)); ChunkVersion requestShardVersion = request.isMetadataSet() && request.getMetadata()->isShardVersionSet() ? @@ -486,7 +486,7 @@ namespace mongo { WriteOpResult* result) { const NamespaceString& nss = request.getTargetingNSS(); - txn->lockState()->assertWriteLocked( nss.ns() ); + dassert(txn->lockState()->isCollectionLockedForMode(nss.ns(), MODE_IX)); if ( !request.isUniqueIndexRequest() ) return true; @@ -1103,8 +1103,7 @@ namespace mongo { WriteOpResult* result ) { const string& insertNS = collection->ns().ns(); - - txn->lockState()->assertWriteLocked( insertNS ); + invariant(txn->lockState()->isCollectionLockedForMode(insertNS, MODE_IX)); WriteUnitOfWork wunit(txn); StatusWith<RecordId> status = collection->insertDocument( txn, docToInsert, true ); |