diff options
-rw-r--r-- | src/mongo/db/change_stream_options_manager.cpp | 2 | ||||
-rw-r--r-- | src/mongo/db/change_stream_options_manager.h | 4 |
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 |