summaryrefslogtreecommitdiff
path: root/src/mongo/db/fle_crud.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2022-03-18 15:30:59 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-03-25 21:29:11 +0000
commit5624053e6ad1ebfa2064801e05a9c6502e21bfb9 (patch)
treec1781b33a9ad3157fea17edae3742da1a91cd813 /src/mongo/db/fle_crud.cpp
parent813a7505005437427abe011a530f003acd2e3b76 (diff)
downloadmongo-5624053e6ad1ebfa2064801e05a9c6502e21bfb9.tar.gz
SERVER-63718 Add support for FLE 2 findAndModify in MongoD
Diffstat (limited to 'src/mongo/db/fle_crud.cpp')
-rw-r--r--src/mongo/db/fle_crud.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/fle_crud.cpp b/src/mongo/db/fle_crud.cpp
index 06a7c3e06af..fae4eea151c 100644
--- a/src/mongo/db/fle_crud.cpp
+++ b/src/mongo/db/fle_crud.cpp
@@ -320,7 +320,7 @@ write_ops::DeleteCommandReply processDelete(OperationContext* opCtx,
StatusWith<write_ops::UpdateCommandReply> processUpdate(
OperationContext* opCtx,
const write_ops::UpdateCommandRequest& updateRequest,
- std::function<std::shared_ptr<txn_api::TransactionWithRetries>(OperationContext*)> getTxns) {
+ GetTxnCallback getTxns) {
auto updates = updateRequest.getUpdates();
uassert(6371502, "Only single document updates are permitted", updates.size() == 1);
@@ -529,10 +529,12 @@ void processRemovedFields(FLEQueryInterface* queryImpl,
}
}
+} // namespace
+
StatusWith<write_ops::FindAndModifyCommandReply> processFindAndModifyRequest(
OperationContext* opCtx,
const write_ops::FindAndModifyCommandRequest& findAndModifyRequest,
- std::function<std::shared_ptr<txn_api::TransactionWithRetries>(OperationContext*)> getTxns) {
+ GetTxnCallback getTxns) {
// Is this a delete
bool isDelete = findAndModifyRequest.getRemove().value_or(false);
@@ -588,8 +590,6 @@ StatusWith<write_ops::FindAndModifyCommandReply> processFindAndModifyRequest(
return reply;
}
-} // namespace
-
FLEQueryInterface::~FLEQueryInterface() {}