diff options
| author | Bernard Gorman <bernard.gorman@gmail.com> | 2021-03-24 14:07:04 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-04-02 21:51:14 +0000 |
| commit | ea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98 (patch) | |
| tree | a3866340e9e80201eb9c9b675200700cc30ad53d /src/mongo/s/catalog/sharding_catalog_client_impl.cpp | |
| parent | 0198bcfb938ccd788f90a2f5e6156871cf18330f (diff) | |
| download | mongo-ea51edf33aa685e8b8d4692ee42b8c0e8e9cfb98.tar.gz | |
SERVER-54975 Rename IDL parser classes to use CommandRequest and CommandReply suffixes
Diffstat (limited to 'src/mongo/s/catalog/sharding_catalog_client_impl.cpp')
| -rw-r--r-- | src/mongo/s/catalog/sharding_catalog_client_impl.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/mongo/s/catalog/sharding_catalog_client_impl.cpp b/src/mongo/s/catalog/sharding_catalog_client_impl.cpp index d2ce143b13c..c93a9c5d473 100644 --- a/src/mongo/s/catalog/sharding_catalog_client_impl.cpp +++ b/src/mongo/s/catalog/sharding_catalog_client_impl.cpp @@ -111,7 +111,7 @@ void sendRetryableWriteBatchRequestToConfig(OperationContext* opCtx, auto configShard = Grid::get(opCtx)->shardRegistry()->getConfigShard(); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments(docs); return insertOp; }()); @@ -135,9 +135,9 @@ void sendRetryableWriteBatchRequestToConfig(OperationContext* opCtx, uassertStatusOK(writeStatus); } -AggregateCommand makeCollectionAndChunksAggregation(OperationContext* opCtx, - const NamespaceString& nss, - const ChunkVersion& sinceVersion) { +AggregateCommandRequest makeCollectionAndChunksAggregation(OperationContext* opCtx, + const NamespaceString& nss, + const ChunkVersion& sinceVersion) { auto expCtx = make_intrusive<ExpressionContext>(opCtx, nullptr, nss); StringMap<ExpressionContext::ResolvedNamespace> resolvedNamespaces; resolvedNamespaces[CollectionType::ConfigNS.coll()] = {CollectionType::ConfigNS, @@ -408,7 +408,7 @@ AggregateCommand makeCollectionAndChunksAggregation(OperationContext* opCtx, auto pipeline = Pipeline::create(std::move(stages), expCtx); auto serializedPipeline = pipeline->serializeToBson(); - return AggregateCommand(CollectionType::ConfigNS, std::move(serializedPipeline)); + return AggregateCommandRequest(CollectionType::ConfigNS, std::move(serializedPipeline)); } } // namespace @@ -1043,7 +1043,7 @@ Status ShardingCatalogClientImpl::insertConfigDocument(OperationContext* opCtx, const BSONElement idField = doc.getField("_id"); BatchedCommandRequest request([&] { - write_ops::Insert insertOp(nss); + write_ops::InsertCommandRequest insertOp(nss); insertOp.setDocuments({doc}); return insertOp; }()); @@ -1170,7 +1170,7 @@ StatusWith<bool> ShardingCatalogClientImpl::_updateConfigDocument( invariant(nss.db() == NamespaceString::kConfigDb); BatchedCommandRequest request([&] { - write_ops::Update updateOp(nss); + write_ops::UpdateCommandRequest updateOp(nss); updateOp.setUpdates({[&] { write_ops::UpdateOpEntry entry; entry.setQ(query); @@ -1204,7 +1204,7 @@ Status ShardingCatalogClientImpl::removeConfigDocuments(OperationContext* opCtx, invariant(nss.db() == NamespaceString::kConfigDb); BatchedCommandRequest request([&] { - write_ops::Delete deleteOp(nss); + write_ops::DeleteCommandRequest deleteOp(nss); deleteOp.setDeletes({[&] { write_ops::DeleteOpEntry entry; entry.setQ(query); |