summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/process_interface/common_process_interface.cpp
diff options
context:
space:
mode:
authorGregory Noma <gregory.noma@gmail.com>2020-02-13 16:38:33 -0500
committerGregory Noma <gregory.noma@gmail.com>2020-02-18 17:13:19 -0500
commita68508f9922ad163ff98f8fa13953b1efe9d57d0 (patch)
tree1ead40c94d7da611cbb6cd36a342cf76ffe2e452 /src/mongo/db/pipeline/process_interface/common_process_interface.cpp
parent11640b2138d40777a4b45005628b4facfba7e6b2 (diff)
downloadmongo-a68508f9922ad163ff98f8fa13953b1efe9d57d0.tar.gz
SERVER-46137 Implement ReplicaSetNodeProcessInterface methods needed for $merge46137
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/common_process_interface.cpp')
-rw-r--r--src/mongo/db/pipeline/process_interface/common_process_interface.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/process_interface/common_process_interface.cpp b/src/mongo/db/pipeline/process_interface/common_process_interface.cpp
index ae19e6a7635..b8a76b0b915 100644
--- a/src/mongo/db/pipeline/process_interface/common_process_interface.cpp
+++ b/src/mongo/db/pipeline/process_interface/common_process_interface.cpp
@@ -200,4 +200,11 @@ std::string CommonProcessInterface::getHostAndPort(OperationContext* opCtx) cons
return getHostNameCachedAndPort();
}
+void CommonProcessInterface::attachWriteConcern(BatchedCommandRequest* request,
+ const WriteConcernOptions& writeConcern) {
+ if (!writeConcern.usedDefault) {
+ request->setWriteConcern(writeConcern.toBSON());
+ }
+}
+
} // namespace mongo