diff options
Diffstat (limited to 'src/mongo/s/commands/cluster_aggregate.cpp')
| -rw-r--r-- | src/mongo/s/commands/cluster_aggregate.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mongo/s/commands/cluster_aggregate.cpp b/src/mongo/s/commands/cluster_aggregate.cpp index f187d95d677..154108b279a 100644 --- a/src/mongo/s/commands/cluster_aggregate.cpp +++ b/src/mongo/s/commands/cluster_aggregate.cpp @@ -520,10 +520,7 @@ BSONObj establishMergingMongosCursor(OperationContext* opCtx, std::unique_ptr<Pipeline, PipelineDeleter> pipelineForMerging, std::vector<ClusterClientCursorParams::RemoteCursor> cursors) { - ClusterClientCursorParams params( - requestedNss, - AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(), - ReadPreferenceSetting::get(opCtx)); + ClusterClientCursorParams params(requestedNss, ReadPreferenceSetting::get(opCtx)); params.tailableMode = pipelineForMerging->getContext()->tailableMode; params.mergePipeline = std::move(pipelineForMerging); @@ -595,12 +592,14 @@ BSONObj establishMergingMongosCursor(OperationContext* opCtx, CursorId clusterCursorId = 0; if (cursorState == ClusterCursorManager::CursorState::NotExhausted) { + auto authUsers = AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(); clusterCursorId = uassertStatusOK(Grid::get(opCtx)->getCursorManager()->registerCursor( opCtx, ccc.releaseCursor(), requestedNss, ClusterCursorManager::CursorType::MultiTarget, - ClusterCursorManager::CursorLifetime::Mortal)); + ClusterCursorManager::CursorLifetime::Mortal, + authUsers)); } responseBuilder.done(clusterCursorId, requestedNss.ns()); |