summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/idhack.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/idhack.cpp')
-rw-r--r--src/mongo/db/exec/idhack.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/exec/idhack.cpp b/src/mongo/db/exec/idhack.cpp
index fd392ac91ab..db24744f898 100644
--- a/src/mongo/db/exec/idhack.cpp
+++ b/src/mongo/db/exec/idhack.cpp
@@ -49,12 +49,12 @@ using stdx::make_unique;
// static
const char* IDHackStage::kStageType = "IDHACK";
-IDHackStage::IDHackStage(OperationContext* txn,
+IDHackStage::IDHackStage(OperationContext* opCtx,
const Collection* collection,
CanonicalQuery* query,
WorkingSet* ws,
const IndexDescriptor* descriptor)
- : PlanStage(kStageType, txn),
+ : PlanStage(kStageType, opCtx),
_collection(collection),
_workingSet(ws),
_key(query->getQueryObj()["_id"].wrap()),
@@ -71,12 +71,12 @@ IDHackStage::IDHackStage(OperationContext* txn,
}
}
-IDHackStage::IDHackStage(OperationContext* txn,
+IDHackStage::IDHackStage(OperationContext* opCtx,
Collection* collection,
const BSONObj& key,
WorkingSet* ws,
const IndexDescriptor* descriptor)
- : PlanStage(kStageType, txn),
+ : PlanStage(kStageType, opCtx),
_collection(collection),
_workingSet(ws),
_key(key),
@@ -208,7 +208,7 @@ void IDHackStage::doReattachToOperationContext() {
_recordCursor->reattachToOperationContext(getOpCtx());
}
-void IDHackStage::doInvalidate(OperationContext* txn, const RecordId& dl, InvalidationType type) {
+void IDHackStage::doInvalidate(OperationContext* opCtx, const RecordId& dl, InvalidationType type) {
// Since updates can't mutate the '_id' field, we can ignore mutation invalidations.
if (INVALIDATION_MUTATION == type) {
return;
@@ -220,7 +220,7 @@ void IDHackStage::doInvalidate(OperationContext* txn, const RecordId& dl, Invali
WorkingSetMember* member = _workingSet->get(_idBeingPagedIn);
if (member->hasRecordId() && (member->recordId == dl)) {
// Fetch it now and kill the RecordId.
- WorkingSetCommon::fetchAndInvalidateRecordId(txn, member, _collection);
+ WorkingSetCommon::fetchAndInvalidateRecordId(opCtx, member, _collection);
}
}
}