diff options
| author | jannaerin <golden.janna@gmail.com> | 2021-07-15 14:05:34 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-07-29 18:51:17 +0000 |
| commit | 298d02f7432b84df2a955addc5bcdf6a366c6645 (patch) | |
| tree | cd63849097905aee03c691c1fa400c6ba801b987 /src/mongo/db/rs_local_client.cpp | |
| parent | 68f6c01d0f0452a9aef96e2da6289ce40fac2e41 (diff) | |
| download | mongo-298d02f7432b84df2a955addc5bcdf6a366c6645.tar.gz | |
SERVER-49897 Insert no-op entries into oplog buffer collections for resharding so resuming is less wasteful
Diffstat (limited to 'src/mongo/db/rs_local_client.cpp')
| -rw-r--r-- | src/mongo/db/rs_local_client.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/rs_local_client.cpp b/src/mongo/db/rs_local_client.cpp index 738edc3becd..f4a668bed7c 100644 --- a/src/mongo/db/rs_local_client.cpp +++ b/src/mongo/db/rs_local_client.cpp @@ -159,7 +159,8 @@ StatusWith<Shard::QueryResponse> RSLocalClient::queryOnce( Status RSLocalClient::runAggregation( OperationContext* opCtx, const AggregateCommandRequest& aggRequest, - std::function<bool(const std::vector<BSONObj>& batch)> callback) { + std::function<bool(const std::vector<BSONObj>& batch, + const boost::optional<BSONObj>& postBatchResumeToken)> callback) { DBDirectClient client(opCtx); auto cursor = uassertStatusOKWithContext( DBClientCursor::fromAggregationRequest( @@ -174,7 +175,8 @@ Status RSLocalClient::runAggregation( } try { - if (!callback(batchDocs)) { + // TODO SERVER-58938 pass DBClientCursor::_postBatchResumeToken to callback + if (!callback(batchDocs, boost::none)) { break; } } catch (const DBException& ex) { |