diff options
Diffstat (limited to 'src/mongo/db/exec/working_set_common.cpp')
| -rw-r--r-- | src/mongo/db/exec/working_set_common.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/exec/working_set_common.cpp b/src/mongo/db/exec/working_set_common.cpp index a9035311bba..c4fccc9267c 100644 --- a/src/mongo/db/exec/working_set_common.cpp +++ b/src/mongo/db/exec/working_set_common.cpp @@ -41,7 +41,7 @@ namespace mongo { // static -bool WorkingSetCommon::fetchAndInvalidateRecordId(OperationContext* txn, +bool WorkingSetCommon::fetchAndInvalidateRecordId(OperationContext* opCtx, WorkingSetMember* member, const Collection* collection) { // Already in our desired state. @@ -55,7 +55,7 @@ bool WorkingSetCommon::fetchAndInvalidateRecordId(OperationContext* txn, } // Do the fetch, invalidate the DL. - member->obj = collection->docFor(txn, member->recordId); + member->obj = collection->docFor(opCtx, member->recordId); member->obj.setValue(member->obj.value().getOwned()); member->recordId = RecordId(); member->transitionToOwnedObj(); @@ -86,7 +86,7 @@ void WorkingSetCommon::prepareForSnapshotChange(WorkingSet* workingSet) { } // static -bool WorkingSetCommon::fetch(OperationContext* txn, +bool WorkingSetCommon::fetch(OperationContext* opCtx, WorkingSet* workingSet, WorkingSetID id, unowned_ptr<SeekableRecordCursor> cursor) { @@ -105,7 +105,7 @@ bool WorkingSetCommon::fetch(OperationContext* txn, return false; } - member->obj = {txn->recoveryUnit()->getSnapshotId(), record->data.releaseToBson()}; + member->obj = {opCtx->recoveryUnit()->getSnapshotId(), record->data.releaseToBson()}; if (member->isSuspicious) { // Make sure that all of the keyData is still valid for this copy of the document. |