summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/mongo/db/change_stream_options_manager.cpp2
-rw-r--r--src/mongo/db/change_stream_options_manager.h4
2 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/change_stream_options_manager.cpp b/src/mongo/db/change_stream_options_manager.cpp
index a9a417aede6..4832b1dc2e4 100644
--- a/src/mongo/db/change_stream_options_manager.cpp
+++ b/src/mongo/db/change_stream_options_manager.cpp
@@ -57,7 +57,7 @@ void ChangeStreamOptionsManager::create(ServiceContext* service) {
getChangeStreamOptionsManager(service).emplace(service);
}
-const ChangeStreamOptions& ChangeStreamOptionsManager::getOptions(OperationContext* opCtx) {
+ChangeStreamOptions ChangeStreamOptionsManager::getOptions(OperationContext* opCtx) const {
stdx::lock_guard<Latch> L(_mutex);
return _changeStreamOptions;
}
diff --git a/src/mongo/db/change_stream_options_manager.h b/src/mongo/db/change_stream_options_manager.h
index 28580deb810..364c51c535c 100644
--- a/src/mongo/db/change_stream_options_manager.h
+++ b/src/mongo/db/change_stream_options_manager.h
@@ -68,7 +68,7 @@ public:
/**
* Returns the change-streams options.
*/
- const ChangeStreamOptions& getOptions(OperationContext* opCtx);
+ ChangeStreamOptions getOptions(OperationContext* opCtx) const;
/**
* Sets the provided change-streams options. Returns OK on success, otherwise appropriate error
@@ -87,7 +87,7 @@ public:
private:
ChangeStreamOptions _changeStreamOptions;
- Mutex _mutex = MONGO_MAKE_LATCH("ChangeStreamOptionsManager::mutex");
+ mutable Mutex _mutex = MONGO_MAKE_LATCH("ChangeStreamOptionsManager::mutex");
};
} // namespace mongo