diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2017-09-05 11:23:54 -0400 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2017-09-13 14:44:09 -0400 |
| commit | fe125855b6b3e8feb9d7d666338a7f2d29d301ad (patch) | |
| tree | c682c408675b895bd343dd7187de8be18e875f66 /src/mongo/db/commands | |
| parent | 61d1cfbf2c8521126506c12bcd2d187a7926fbe0 (diff) | |
| download | mongo-fe125855b6b3e8feb9d7d666338a7f2d29d301ad.tar.gz | |
SERVER-29142 Support $changeStream on unsharded collections.
Diffstat (limited to 'src/mongo/db/commands')
| -rw-r--r-- | src/mongo/db/commands/run_aggregate.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp index 3350f43e4b5..c8d63487229 100644 --- a/src/mongo/db/commands/run_aggregate.cpp +++ b/src/mongo/db/commands/run_aggregate.cpp @@ -409,7 +409,7 @@ Status runAggregate(OperationContext* opCtx, expCtx->tempDir = storageGlobalParams.dbpath + "/_tmp"; if (liteParsedPipeline.hasChangeStream()) { - expCtx->tailableMode = ExpressionContext::TailableMode::kTailableAndAwaitData; + expCtx->tailableMode = TailableMode::kTailableAndAwaitData; } auto pipeline = uassertStatusOK(Pipeline::parse(request.getPipeline(), expCtx)); @@ -471,7 +471,7 @@ Status runAggregate(OperationContext* opCtx, AuthorizationSession::get(opCtx->getClient())->getAuthenticatedUserNames(), opCtx->recoveryUnit()->isReadingFromMajorityCommittedSnapshot(), cmdObj); - if (expCtx->tailableMode == ExpressionContext::TailableMode::kTailableAndAwaitData) { + if (expCtx->tailableMode == TailableMode::kTailableAndAwaitData) { cursorParams.setTailable(true); cursorParams.setAwaitData(true); } |