summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/geo_near.cpp
diff options
context:
space:
mode:
authorEliot Horowitz <eliot@10gen.com>2014-08-25 17:25:39 -0400
committerEliot Horowitz <eliot@10gen.com>2014-08-25 18:08:37 -0400
commitf0bb5123f50bb617eb9499539f01779c6e9f5e95 (patch)
tree98cc4abf3c89881691158345435523c5dd6ae37f /src/mongo/db/exec/geo_near.cpp
parentcb3f5cfa43d9565675d2f36c4b0f7cecbad47a49 (diff)
downloadmongo-f0bb5123f50bb617eb9499539f01779c6e9f5e95.tar.gz
SERVER-13635: OperationContext on read paths
Diffstat (limited to 'src/mongo/db/exec/geo_near.cpp')
-rw-r--r--src/mongo/db/exec/geo_near.cpp10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/mongo/db/exec/geo_near.cpp b/src/mongo/db/exec/geo_near.cpp
index c9ac11ced74..f5217d068b6 100644
--- a/src/mongo/db/exec/geo_near.cpp
+++ b/src/mongo/db/exec/geo_near.cpp
@@ -437,11 +437,12 @@ namespace mongo {
class FetchStageWithMatch : public FetchStage {
public:
- FetchStageWithMatch(WorkingSet* ws,
+ FetchStageWithMatch(OperationContext* txn,
+ WorkingSet* ws,
PlanStage* child,
MatchExpression* filter,
const Collection* collection)
- : FetchStage(ws, child, filter, collection), _matcher(filter) {
+ : FetchStage(txn, ws, child, filter, collection), _matcher(filter) {
}
virtual ~FetchStageWithMatch() {
@@ -647,7 +648,8 @@ namespace mongo {
}
// FetchStage owns index scan
- FetchStage* fetcher(new FetchStageWithMatch(workingSet,
+ FetchStage* fetcher(new FetchStageWithMatch(txn,
+ workingSet,
scan,
docMatcher,
collection));
@@ -881,7 +883,7 @@ namespace mongo {
IndexScan* scan = new IndexScanWithMatch(txn, scanParams, workingSet, keyMatcher);
// FetchStage owns index scan
- FetchStage* fetcher(new FetchStage(workingSet, scan, _nearParams.filter, collection));
+ FetchStage* fetcher(new FetchStage(txn, workingSet, scan, _nearParams.filter, collection));
return StatusWith<CoveredInterval*>(new CoveredInterval(fetcher,
true,