diff options
Diffstat (limited to 'src/mongo/db/pipeline/pipeline_test.cpp')
-rw-r--r-- | src/mongo/db/pipeline/pipeline_test.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/pipeline_test.cpp b/src/mongo/db/pipeline/pipeline_test.cpp index 88637498adc..6d9ba462d35 100644 --- a/src/mongo/db/pipeline/pipeline_test.cpp +++ b/src/mongo/db/pipeline/pipeline_test.cpp @@ -122,7 +122,7 @@ void assertPipelineOptimizesAndSerializesTo(std::string inputPipeJson, ASSERT_EQUALS(stageElem.type(), BSONType::Object); rawPipeline.push_back(stageElem.embeddedObject()); } - AggregateCommand request(kTestNss, rawPipeline); + AggregateCommandRequest request(kTestNss, rawPipeline); intrusive_ptr<ExpressionContextForTest> ctx = new ExpressionContextForTest(opCtx.get(), request); ctx->mongoProcessInterface = std::make_shared<StubExplainInterface>(); @@ -2470,7 +2470,7 @@ public: ASSERT_EQUALS(stageElem.type(), BSONType::Object); rawPipeline.push_back(stageElem.embeddedObject()); } - AggregateCommand request(kTestNss, rawPipeline); + AggregateCommandRequest request(kTestNss, rawPipeline); intrusive_ptr<ExpressionContextForTest> ctx = createExpressionContext(request); TempDir tempDir("PipelineTest"); ctx->tempDir = tempDir.path(); @@ -2500,7 +2500,7 @@ public: virtual ~Base() {} virtual intrusive_ptr<ExpressionContextForTest> createExpressionContext( - const AggregateCommand& request) { + const AggregateCommandRequest& request) { return new ExpressionContextForTest(&_opCtx, request); } @@ -3022,7 +3022,7 @@ class MergeWithUnshardedCollection : public ShardMergerBase { class MergeWithShardedCollection : public ShardMergerBase { intrusive_ptr<ExpressionContextForTest> createExpressionContext( - const AggregateCommand& request) override { + const AggregateCommandRequest& request) override { class ProcessInterface : public StubMongoProcessInterface { bool isSharded(OperationContext* opCtx, const NamespaceString& ns) override { return true; @@ -3256,7 +3256,7 @@ TEST(PipelineInitialSource, GeoNearInitialQuery) { const std::vector<BSONObj> rawPipeline = { fromjson("{$geoNear: {distanceField: 'd', near: [0, 0], query: {a: 1}}}")}; intrusive_ptr<ExpressionContextForTest> ctx = new ExpressionContextForTest( - &_opCtx, AggregateCommand(NamespaceString("a.collection"), rawPipeline)); + &_opCtx, AggregateCommandRequest(NamespaceString("a.collection"), rawPipeline)); auto pipe = Pipeline::parse(rawPipeline, ctx); ASSERT_BSONOBJ_EQ(pipe->getInitialQuery(), BSON("a" << 1)); } @@ -3265,7 +3265,7 @@ TEST(PipelineInitialSource, MatchInitialQuery) { OperationContextNoop _opCtx; const std::vector<BSONObj> rawPipeline = {fromjson("{$match: {'a': 4}}")}; intrusive_ptr<ExpressionContextForTest> ctx = new ExpressionContextForTest( - &_opCtx, AggregateCommand(NamespaceString("a.collection"), rawPipeline)); + &_opCtx, AggregateCommandRequest(NamespaceString("a.collection"), rawPipeline)); auto pipe = Pipeline::parse(rawPipeline, ctx); ASSERT_BSONOBJ_EQ(pipe->getInitialQuery(), BSON("a" << 4)); |