SERVER-46137 Implement ReplicaSetNodeProcessInterface methods needed for $merge46137

1 files changed, 8 insertions, 0 deletions

diff --git a/src/mongo/db/pipeline/process_interface/common_process_interface.h b/src/mongo/db/pipeline/process_interface/common_process_interface.h
index 7f68f8d201f..ca83c99a0e9 100644
--- a/src/mongo/db/pipeline/process_interface/common_process_interface.h
+++ b/src/mongo/db/pipeline/process_interface/common_process_interface.h
@@ -33,6 +33,7 @@
 
 #include "mongo/bson/bsonobj.h"
 #include "mongo/db/pipeline/process_interface/mongo_process_interface.h"
+#include "mongo/s/write_ops/batched_command_request.h"
 
 namespace mongo {
 
@@ -52,6 +53,13 @@ public:
     static bool keyPatternNamesExactPaths(const BSONObj& keyPattern,
                                           const std::set<FieldPath>& uniqueKeyPaths);
 
+    /**
+     * Attaches the write concern to the given batch request. If 'writeConcern' has been default
+     * initialized to {w: 0, wtimeout: 0} then we do not bother attaching it.
+     */
+    static void attachWriteConcern(BatchedCommandRequest* request,
+                                   const WriteConcernOptions& writeConcern);
+
     std::vector<BSONObj> getCurrentOps(const boost::intrusive_ptr<ExpressionContext>& expCtx,
                                        CurrentOpConnectionsMode connMode,
                                        CurrentOpSessionsMode sessionMode,