diff options
| author | Abdul Qadeer <abdul.qadeer@mongodb.com> | 2022-06-14 21:15:42 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-06-14 22:05:04 +0000 |
| commit | 01eb71cdb1ec643de2dacf439814e46b6ca0650b (patch) | |
| tree | d1be5baa3775b505a276ca2d8ef98dc8b27fcd8c /src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp | |
| parent | 731cfef274177f5a2df4b5d700ae6d62a4e54abe (diff) | |
| download | mongo-01eb71cdb1ec643de2dacf439814e46b6ca0650b.tar.gz | |
SERVER-50729 Wrap resharding_util in resharding namespace
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp')
| -rw-r--r-- | src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp b/src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp index 40f51e56e60..ac62a1cee4d 100644 --- a/src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp +++ b/src/mongo/db/s/resharding/resharding_oplog_fetcher.cpp @@ -272,9 +272,9 @@ AggregateCommandRequest ReshardingOplogFetcher::_makeAggregateCommandRequest( auto opCtx = opCtxRaii.get(); auto expCtx = _makeExpressionContext(opCtx); - auto serializedPipeline = - createOplogFetchingPipelineForResharding(expCtx, _startAt, _collUUID, _recipientShard) - ->serializeToBson(); + auto serializedPipeline = resharding::createOplogFetchingPipelineForResharding( + expCtx, _startAt, _collUUID, _recipientShard) + ->serializeToBson(); AggregateCommandRequest aggRequest(NamespaceString::kRsOplogNamespace, std::move(serializedPipeline)); @@ -368,7 +368,7 @@ bool ReshardingOplogFetcher::consume(Client* client, _onInsertFuture = std::move(f); } - if (isFinalOplog(nextOplog, _reshardingUUID)) { + if (resharding::isFinalOplog(nextOplog, _reshardingUUID)) { moreToCome = false; return false; } @@ -392,7 +392,7 @@ bool ReshardingOplogFetcher::consume(Client* client, oplog.set_id(Value(startAt.toBSON())); oplog.setObject(BSON("msg" << "Latest oplog ts from donor's cursor response")); - oplog.setObject2(BSON("type" << kReshardProgressMark)); + oplog.setObject2(BSON("type" << resharding::kReshardProgressMark)); oplog.setOpTime(OplogSlot()); oplog.setWallClockTime(opCtx->getServiceContext()->getFastClockSource()->now()); |