summaryrefslogtreecommitdiff
path: root/src/mongo/db/fle_crud.cpp
diff options
context:
space:
mode:
authorMihai Andrei <mihai.andrei@10gen.com>2022-06-30 20:38:44 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-30 21:39:25 +0000
commit17f49ab8b16a6f45371771d8c152cfbf4ed186af (patch)
tree882643f79f42b6b0267cbc870eb03b135f231e1c /src/mongo/db/fle_crud.cpp
parent69ce17c6b02c009fc2d0502c6761f8a3e2e541ee (diff)
downloadmongo-17f49ab8b16a6f45371771d8c152cfbf4ed186af.tar.gz
SERVER-50301 Delete code which handles $v:1 update oplog entries
Diffstat (limited to 'src/mongo/db/fle_crud.cpp')
-rw-r--r--src/mongo/db/fle_crud.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/fle_crud.cpp b/src/mongo/db/fle_crud.cpp
index f1f9cf96f2d..761efbeb843 100644
--- a/src/mongo/db/fle_crud.cpp
+++ b/src/mongo/db/fle_crud.cpp
@@ -842,7 +842,7 @@ write_ops::UpdateCommandReply processUpdate(FLEQueryInterface* queryImpl,
auto pushUpdate = EDCServerCollection::finalizeForUpdate(updateModifier, serverPayload);
newUpdateOpEntry.setU(mongo::write_ops::UpdateModification(
- pushUpdate, write_ops::UpdateModification::ClassicTag(), false));
+ pushUpdate, write_ops::UpdateModification::ModifierUpdateTag{}));
} else {
auto replacementDocument = updateModification.getUpdateReplacement();
EDCServerCollection::validateEncryptedFieldInfo(
@@ -857,7 +857,7 @@ write_ops::UpdateCommandReply processUpdate(FLEQueryInterface* queryImpl,
EDCServerCollection::finalizeForInsert(replacementDocument, serverPayload);
newUpdateOpEntry.setU(mongo::write_ops::UpdateModification(
- safeContentReplace, write_ops::UpdateModification::ClassicTag(), true));
+ safeContentReplace, write_ops::UpdateModification::ReplacementTag{}));
}
// Step 3 ----
@@ -908,7 +908,7 @@ write_ops::UpdateCommandReply processUpdate(FLEQueryInterface* queryImpl,
pullUpdateOpEntry.setMulti(false);
pullUpdateOpEntry.setQ(BSON("_id"_sd << idElement));
pullUpdateOpEntry.setU(mongo::write_ops::UpdateModification(
- pullUpdate, write_ops::UpdateModification::ClassicTag(), false));
+ pullUpdate, write_ops::UpdateModification::ModifierUpdateTag{}));
newUpdateRequest.setUpdates({pullUpdateOpEntry});
newUpdateRequest.getWriteCommandRequestBase().setStmtId(boost::none);
newUpdateRequest.setLegacyRuntimeConstants(boost::none);
@@ -1089,7 +1089,7 @@ write_ops::FindAndModifyCommandReply processFindAndModify(
// Step 2 ----
newUpdateModification = write_ops::UpdateModification(
- pushUpdate, write_ops::UpdateModification::ClassicTag(), false);
+ pushUpdate, write_ops::UpdateModification::ModifierUpdateTag{});
} else {
auto replacementDocument = updateModification.getUpdateReplacement();
EDCServerCollection::validateEncryptedFieldInfo(
@@ -1104,7 +1104,7 @@ write_ops::FindAndModifyCommandReply processFindAndModify(
EDCServerCollection::finalizeForInsert(replacementDocument, serverPayload);
newUpdateModification = write_ops::UpdateModification(
- safeContentReplace, write_ops::UpdateModification::ClassicTag(), true);
+ safeContentReplace, write_ops::UpdateModification::ReplacementTag{});
}
// Step 3 ----
@@ -1165,7 +1165,7 @@ write_ops::FindAndModifyCommandReply processFindAndModify(
pullUpdateOpEntry.setMulti(false);
pullUpdateOpEntry.setQ(BSON("_id"_sd << idElement));
pullUpdateOpEntry.setU(mongo::write_ops::UpdateModification(
- pullUpdate, write_ops::UpdateModification::ClassicTag(), false));
+ pullUpdate, write_ops::UpdateModification::ModifierUpdateTag{}));
newUpdateRequest.setUpdates({pullUpdateOpEntry});
newUpdateRequest.setLegacyRuntimeConstants(boost::none);
newUpdateRequest.getWriteCommandRequestBase().setStmtId(boost::none);