summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_list_local_sessions.h
diff options
context:
space:
mode:
authorBernard Gorman <bernard.gorman@gmail.com>2017-09-26 23:23:48 -0400
committerBernard Gorman <bernard.gorman@gmail.com>2017-10-04 10:14:35 +0100
commit939f2bcda18db41b774bbe3cf16e1d4928c58e5d (patch)
tree7b99539bf440a9d76030a07c79b3347792fb5f7d /src/mongo/db/pipeline/document_source_list_local_sessions.h
parent284d80ba6ee928cdf3d8f23c161a7ee1bf4a8faf (diff)
downloadmongo-939f2bcda18db41b774bbe3cf16e1d4928c58e5d.tar.gz
SERVER-29141 Extend StageConstraints to allow kLocalOnly and kMongos host requirements, given pipeline split state
Diffstat (limited to 'src/mongo/db/pipeline/document_source_list_local_sessions.h')
-rw-r--r--src/mongo/db/pipeline/document_source_list_local_sessions.h5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/document_source_list_local_sessions.h b/src/mongo/db/pipeline/document_source_list_local_sessions.h
index 01321d596a6..9674feb6e66 100644
--- a/src/mongo/db/pipeline/document_source_list_local_sessions.h
+++ b/src/mongo/db/pipeline/document_source_list_local_sessions.h
@@ -93,15 +93,14 @@ public:
return Value(Document{{getSourceName(), _spec.toBSON()}});
}
- StageConstraints constraints() const final {
+ StageConstraints constraints(Pipeline::SplitState pipeState) const final {
StageConstraints constraints(StreamType::kStreaming,
PositionRequirement::kFirst,
- HostTypeRequirement::kNone,
+ HostTypeRequirement::kLocalOnly,
DiskUseRequirement::kNoDiskUse,
FacetRequirement::kNotAllowed);
constraints.isIndependentOfAnyCollection = true;
- constraints.allowedToForwardFromMongos = false;
constraints.requiresInputDocSource = false;
return constraints;
}