summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/pipeline_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/pipeline_test.cpp')
-rw-r--r--src/mongo/db/pipeline/pipeline_test.cpp12
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));