summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec')
-rw-r--r--src/mongo/db/exec/delete.cpp2
-rw-r--r--src/mongo/db/exec/update.cpp4
2 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/exec/delete.cpp b/src/mongo/db/exec/delete.cpp
index fda4b8ba779..19de5a7a742 100644
--- a/src/mongo/db/exec/delete.cpp
+++ b/src/mongo/db/exec/delete.cpp
@@ -91,7 +91,7 @@ namespace mongo {
BSONObj deletedDoc;
- WriteUnitOfWork wunit(_txn->recoveryUnit());
+ WriteUnitOfWork wunit(_txn);
// TODO: Do we want to buffer docs and delete them in a group rather than
// saving/restoring state repeatedly?
diff --git a/src/mongo/db/exec/update.cpp b/src/mongo/db/exec/update.cpp
index 5f12324fffe..637ad9ce010 100644
--- a/src/mongo/db/exec/update.cpp
+++ b/src/mongo/db/exec/update.cpp
@@ -488,7 +488,7 @@ namespace mongo {
}
}
- WriteUnitOfWork wunit(request->getOpCtx()->recoveryUnit());
+ WriteUnitOfWork wunit(request->getOpCtx());
// Save state before making changes
saveState();
@@ -637,7 +637,7 @@ namespace mongo {
str::stream() << "Document to upsert is larger than " << BSONObjMaxUserSize,
newObj.objsize() <= BSONObjMaxUserSize);
- WriteUnitOfWork wunit(request->getOpCtx()->recoveryUnit());
+ WriteUnitOfWork wunit(request->getOpCtx());
// Only create the collection if the doc will be inserted.
if (!_collection) {
_collection = _db->getCollection(request->getOpCtx(),