diff options
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp')
-rw-r--r-- | src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp | 22 |
1 files changed, 7 insertions, 15 deletions
diff --git a/src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp b/src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp index 0d1526bac3f..09fc0fc00d0 100644 --- a/src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp +++ b/src/mongo/db/pipeline/process_interface/mongos_process_interface.cpp @@ -103,21 +103,6 @@ bool supportsUniqueKey(const boost::intrusive_ptr<ExpressionContext>& expCtx, } // namespace -std::unique_ptr<Pipeline, PipelineDeleter> MongosProcessInterface::attachCursorSourceToPipeline( - const boost::intrusive_ptr<ExpressionContext>& expCtx, - Pipeline* ownedPipeline, - bool allowTargetingShards) { - // On mongos we can't have local cursors. - return sharded_agg_helpers::attachCursorToPipeline(expCtx, ownedPipeline, allowTargetingShards); -} - -BSONObj MongosProcessInterface::attachCursorSourceAndExplain( - const boost::intrusive_ptr<ExpressionContext>& expCtx, - Pipeline* ownedPipeline, - ExplainOptions::Verbosity verbosity) { - return sharded_agg_helpers::targetShardsForExplain(expCtx, ownedPipeline); -} - boost::optional<Document> MongosProcessInterface::lookupSingleDocument( const boost::intrusive_ptr<ExpressionContext>& expCtx, const NamespaceString& nss, @@ -356,4 +341,11 @@ MongosProcessInterface::ensureFieldsUniqueOrResolveDocumentKey( targetCollectionVersion}; } +std::unique_ptr<Pipeline, PipelineDeleter> MongosProcessInterface::attachCursorSourceToPipeline( + const boost::intrusive_ptr<ExpressionContext>& expCtx, + Pipeline* ownedPipeline, + bool allowTargetingShards) { + return sharded_agg_helpers::attachCursorToPipeline(expCtx, ownedPipeline, allowTargetingShards); +} + } // namespace mongo |