diff options
Diffstat (limited to 'src/mongo/db/sessions_collection.cpp')
-rw-r--r-- | src/mongo/db/sessions_collection.cpp | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/src/mongo/db/sessions_collection.cpp b/src/mongo/db/sessions_collection.cpp index 4e0e121abaf..b883bebf76c 100644 --- a/src/mongo/db/sessions_collection.cpp +++ b/src/mongo/db/sessions_collection.cpp @@ -40,6 +40,7 @@ #include "mongo/db/create_indexes_gen.h" #include "mongo/db/logical_session_id.h" #include "mongo/db/ops/write_ops.h" +#include "mongo/db/repl/read_concern_args.h" #include "mongo/rpc/get_status_from_command_result.h" #include "mongo/s/write_ops/batched_command_response.h" @@ -234,7 +235,10 @@ LogicalSessionIdSet SessionsCollection::_doFindRemoved( LogicalSessionIdSet removed{sessions.begin(), sessions.end()}; auto wrappedSend = [&](BSONObj batch) { - auto swBatchResult = send(batch); + BSONObjBuilder batchWithReadConcernLocal(batch); + batchWithReadConcernLocal.append(repl::ReadConcernArgs::kReadConcernFieldName, + repl::ReadConcernArgs::kImplicitDefault); + auto swBatchResult = send(batchWithReadConcernLocal.obj()); auto result = SessionsCollectionFetchResult::parse("SessionsCollectionFetchResult"_sd, swBatchResult); @@ -279,7 +283,9 @@ BSONObj SessionsCollection::generateCreateIndexesCmd() { createIndexes.setCreateIndexes(NamespaceString::kLogicalSessionsNamespace.coll()); createIndexes.setIndexes(std::move(indexes)); - return createIndexes.toBSON(); + return BSONObjBuilder(createIndexes.toBSON()) + .append(WriteConcernOptions::kWriteConcernField, WriteConcernOptions::kImplicitDefault) + .obj(); } BSONObj SessionsCollection::generateCollModCmd() { @@ -292,6 +298,8 @@ BSONObj SessionsCollection::generateCollModCmd() { indexBuilder << "expireAfterSeconds" << localLogicalSessionTimeoutMinutes * 60; indexBuilder.done(); + collModCmdBuilder.append(WriteConcernOptions::kWriteConcernField, + WriteConcernOptions::kImplicitDefault); collModCmdBuilder.done(); return collModCmdBuilder.obj(); |