diff options
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/common_process_interface.h')
-rw-r--r-- | src/mongo/db/pipeline/process_interface/common_process_interface.h | 8 |
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, |