diff options
author | Waley Chen <waleycz@gmail.com> | 2016-05-25 10:28:32 -0400 |
---|---|---|
committer | Waley Chen <waleycz@gmail.com> | 2016-05-25 10:28:32 -0400 |
commit | 6f72d36c1c8fc757962150713756ed2a553d817c (patch) | |
tree | 103da4a058412a277d1ac6f72dbd589504cac1ee /src/mongo/dbtests/query_stage_subplan.cpp | |
parent | 974ed0ec1799916af2ae12da1d17ac5fc920d966 (diff) | |
download | mongo-6f72d36c1c8fc757962150713756ed2a553d817c.tar.gz |
SERVER-23243 Replace Listener::getElapsedTimeMillis() in scoped_timer.cpp
Diffstat (limited to 'src/mongo/dbtests/query_stage_subplan.cpp')
-rw-r--r-- | src/mongo/dbtests/query_stage_subplan.cpp | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/src/mongo/dbtests/query_stage_subplan.cpp b/src/mongo/dbtests/query_stage_subplan.cpp index 419cd04d08d..825152c4007 100644 --- a/src/mongo/dbtests/query_stage_subplan.cpp +++ b/src/mongo/dbtests/query_stage_subplan.cpp @@ -43,11 +43,9 @@ #include "mongo/db/query/canonical_query.h" #include "mongo/db/query/get_executor.h" #include "mongo/dbtests/dbtests.h" -#include "mongo/util/clock_source_mock.h" namespace QueryStageSubplan { -const std::unique_ptr<ClockSource> clockSource = stdx::make_unique<ClockSourceMock>(); static const NamespaceString nss("unittests.QueryStageSubplan"); class QueryStageSubplanBase { @@ -89,6 +87,7 @@ protected: const ServiceContext::UniqueOperationContext _txnPtr = cc().makeOperationContext(); OperationContext& _txn = *_txnPtr; + ClockSource* _clock = _txn.getServiceContext()->getFastClockSource(); private: DBDirectClient _client; @@ -132,7 +131,7 @@ public: new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); // Plan selection should succeed due to falling back on regular planning. - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); } }; @@ -175,7 +174,7 @@ public: std::unique_ptr<SubplanStage> subplan( new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); // Nothing is in the cache yet, so neither branch should have been planned from @@ -233,7 +232,7 @@ public: std::unique_ptr<SubplanStage> subplan( new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); // Nothing is in the cache yet, so neither branch should have been planned from @@ -292,7 +291,7 @@ public: std::unique_ptr<SubplanStage> subplan( new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); // Nothing is in the cache yet, so neither branch should have been planned from @@ -549,7 +548,7 @@ public: new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); // Plan selection should succeed due to falling back on regular planning. - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); // Work the stage until it produces all results. @@ -607,7 +606,7 @@ public: std::unique_ptr<SubplanStage> subplan( new SubplanStage(&_txn, collection, &ws, plannerParams, cq.get())); - PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, clockSource.get()); + PlanYieldPolicy yieldPolicy(PlanExecutor::YIELD_MANUAL, _clock); ASSERT_OK(subplan->pickBestPlan(&yieldPolicy)); size_t numResults = 0; |