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/s/query/store_possible_cursor.cpp | |
| parent | 61d1cfbf2c8521126506c12bcd2d187a7926fbe0 (diff) | |
| download | mongo-fe125855b6b3e8feb9d7d666338a7f2d29d301ad.tar.gz | |
SERVER-29142 Support $changeStream on unsharded collections.
Diffstat (limited to 'src/mongo/s/query/store_possible_cursor.cpp')
| -rw-r--r-- | src/mongo/s/query/store_possible_cursor.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/mongo/s/query/store_possible_cursor.cpp b/src/mongo/s/query/store_possible_cursor.cpp index 506ac226636..f611e612d2a 100644 --- a/src/mongo/s/query/store_possible_cursor.cpp +++ b/src/mongo/s/query/store_possible_cursor.cpp @@ -46,7 +46,8 @@ StatusWith<BSONObj> storePossibleCursor(OperationContext* opCtx, const BSONObj& cmdResult, const NamespaceString& requestedNss, executor::TaskExecutor* executor, - ClusterCursorManager* cursorManager) { + ClusterCursorManager* cursorManager, + TailableMode tailableMode) { if (!cmdResult["ok"].trueValue() || !cmdResult.hasField("cursor")) { return cmdResult; } @@ -68,6 +69,7 @@ StatusWith<BSONObj> storePossibleCursor(OperationContext* opCtx, CursorResponse(incomingCursorResponse.getValue().getNSS(), incomingCursorResponse.getValue().getCursorId(), {})); + params.tailableMode = tailableMode; auto ccc = ClusterClientCursorImpl::make(opCtx, executor, std::move(params)); |