diff options
Diffstat (limited to 'src/mongo/db/ops/write_ops_exec.cpp')
| -rw-r--r-- | src/mongo/db/ops/write_ops_exec.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/db/ops/write_ops_exec.cpp b/src/mongo/db/ops/write_ops_exec.cpp index 2cac79f8cbe..14a94a14e89 100644 --- a/src/mongo/db/ops/write_ops_exec.cpp +++ b/src/mongo/db/ops/write_ops_exec.cpp @@ -39,6 +39,7 @@ #include "mongo/db/catalog/collection_operation_source.h" #include "mongo/db/catalog/collection_options.h" #include "mongo/db/catalog/collection_uuid_mismatch.h" +#include "mongo/db/catalog/collection_write_path.h" #include "mongo/db/catalog/database_holder.h" #include "mongo/db/catalog/document_validation.h" #include "mongo/db/catalog_raii.h" @@ -385,8 +386,8 @@ void insertDocuments(OperationContext* opCtx, return !collElem || collection->ns().ns() == collElem.str(); }); - uassertStatusOK( - collection->insertDocuments(opCtx, begin, end, &CurOp::get(opCtx)->debug(), fromMigrate)); + uassertStatusOK(collection_internal::insertDocuments( + opCtx, collection, begin, end, &CurOp::get(opCtx)->debug(), fromMigrate)); wuow.commit(); } @@ -1407,7 +1408,8 @@ Status performAtomicTimeseriesWrites( } if (!insertOps.empty()) { - auto status = coll->insertDocuments(opCtx, inserts.begin(), inserts.end(), &curOp->debug()); + auto status = collection_internal::insertDocuments( + opCtx, *coll, inserts.begin(), inserts.end(), &curOp->debug()); if (!status.isOK()) { return status; } |