summaryrefslogtreecommitdiff
path: root/src/mongo/db/fle_crud.cpp
diff options
context:
space:
mode:
authorDavis Haupt <davis.haupt@mongodb.com>2022-08-10 12:58:30 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-08-10 14:14:00 +0000
commitcd10f966669131d9efdc202f444c41fb2d5afd18 (patch)
tree7add84b62eb33c8abc4963e61be48de4bcdbc7f6 /src/mongo/db/fle_crud.cpp
parent92c4d0cf38b1bd20be3c600c1fa4b103d81fdd1b (diff)
downloadmongo-cd10f966669131d9efdc202f444c41fb2d5afd18.tar.gz
SERVER-68636 rename HighCardinalityMode to EncryptedCollScanMode
Diffstat (limited to 'src/mongo/db/fle_crud.cpp')
-rw-r--r--src/mongo/db/fle_crud.cpp34
1 files changed, 17 insertions, 17 deletions
diff --git a/src/mongo/db/fle_crud.cpp b/src/mongo/db/fle_crud.cpp
index 6a4f16c2461..4e48c683f66 100644
--- a/src/mongo/db/fle_crud.cpp
+++ b/src/mongo/db/fle_crud.cpp
@@ -874,16 +874,16 @@ write_ops::UpdateCommandReply processUpdate(FLEQueryInterface* queryImpl,
std::vector<EDCServerPayloadInfo> serverPayload;
auto newUpdateOpEntry = updateRequest.getUpdates()[0];
- auto highCardinalityModeAllowed = newUpdateOpEntry.getUpsert()
- ? fle::HighCardinalityModeAllowed::kDisallow
- : fle::HighCardinalityModeAllowed::kAllow;
+ auto encryptedCollScanModeAllowed = newUpdateOpEntry.getUpsert()
+ ? fle::EncryptedCollScanModeAllowed::kDisallow
+ : fle::EncryptedCollScanModeAllowed::kAllow;
newUpdateOpEntry.setQ(fle::rewriteEncryptedFilterInsideTxn(queryImpl,
updateRequest.getDbName(),
efc,
expCtx,
newUpdateOpEntry.getQ(),
- highCardinalityModeAllowed));
+ encryptedCollScanModeAllowed));
if (updateModification.type() == write_ops::UpdateModification::Type::kModifier) {
auto updateModifier = updateModification.getUpdateModifier();
@@ -1060,16 +1060,16 @@ std::unique_ptr<BatchedCommandRequest> processFLEBatchExplain(
deleteRequest.getEncryptionInformation().value(),
newDeleteOp.getQ(),
&getTransactionWithRetriesForMongoS,
- fle::HighCardinalityModeAllowed::kAllow));
+ fle::EncryptedCollScanModeAllowed::kAllow));
deleteRequest.setDeletes({newDeleteOp});
deleteRequest.getWriteCommandRequestBase().setEncryptionInformation(boost::none);
return std::make_unique<BatchedCommandRequest>(deleteRequest);
} else if (request.getBatchType() == BatchedCommandRequest::BatchType_Update) {
auto updateRequest = request.getUpdateRequest();
auto newUpdateOp = updateRequest.getUpdates()[0];
- auto highCardinalityModeAllowed = newUpdateOp.getUpsert()
- ? fle::HighCardinalityModeAllowed::kDisallow
- : fle::HighCardinalityModeAllowed::kAllow;
+ auto encryptedCollScanModeAllowed = newUpdateOp.getUpsert()
+ ? fle::EncryptedCollScanModeAllowed::kDisallow
+ : fle::EncryptedCollScanModeAllowed::kAllow;
newUpdateOp.setQ(fle::rewriteQuery(opCtx,
getExpCtx(newUpdateOp),
@@ -1077,7 +1077,7 @@ std::unique_ptr<BatchedCommandRequest> processFLEBatchExplain(
updateRequest.getEncryptionInformation().value(),
newUpdateOp.getQ(),
&getTransactionWithRetriesForMongoS,
- highCardinalityModeAllowed));
+ encryptedCollScanModeAllowed));
updateRequest.setUpdates({newUpdateOp});
updateRequest.getWriteCommandRequestBase().setEncryptionInformation(boost::none);
return std::make_unique<BatchedCommandRequest>(updateRequest);
@@ -1105,9 +1105,9 @@ write_ops::FindAndModifyCommandReply processFindAndModify(
// Step 0 ----
// Rewrite filter
- auto highCardinalityModeAllowed = findAndModifyRequest.getUpsert().value_or(false)
- ? fle::HighCardinalityModeAllowed::kDisallow
- : fle::HighCardinalityModeAllowed::kAllow;
+ auto encryptedCollScanModeAllowed = findAndModifyRequest.getUpsert().value_or(false)
+ ? fle::EncryptedCollScanModeAllowed::kDisallow
+ : fle::EncryptedCollScanModeAllowed::kAllow;
newFindAndModifyRequest.setQuery(
fle::rewriteEncryptedFilterInsideTxn(queryImpl,
@@ -1115,7 +1115,7 @@ write_ops::FindAndModifyCommandReply processFindAndModify(
efc,
expCtx,
findAndModifyRequest.getQuery(),
- highCardinalityModeAllowed));
+ encryptedCollScanModeAllowed));
// Make sure not to inherit the command's writeConcern, this should be set at the transaction
// level.
@@ -1242,9 +1242,9 @@ write_ops::FindAndModifyCommandRequest processFindAndModifyExplain(
auto efc = EncryptionInformationHelpers::getAndValidateSchema(edcNss, ei);
auto newFindAndModifyRequest = findAndModifyRequest;
- auto highCardinalityModeAllowed = findAndModifyRequest.getUpsert().value_or(false)
- ? fle::HighCardinalityModeAllowed::kDisallow
- : fle::HighCardinalityModeAllowed::kAllow;
+ auto encryptedCollScanModeAllowed = findAndModifyRequest.getUpsert().value_or(false)
+ ? fle::EncryptedCollScanModeAllowed::kDisallow
+ : fle::EncryptedCollScanModeAllowed::kAllow;
newFindAndModifyRequest.setQuery(
fle::rewriteEncryptedFilterInsideTxn(queryImpl,
@@ -1252,7 +1252,7 @@ write_ops::FindAndModifyCommandRequest processFindAndModifyExplain(
efc,
expCtx,
findAndModifyRequest.getQuery(),
- highCardinalityModeAllowed));
+ encryptedCollScanModeAllowed));
newFindAndModifyRequest.setEncryptionInformation(boost::none);
return newFindAndModifyRequest;