From bf0d1f4eeae7dfe276da7b6cbba6a95a3179ecbc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Botond=20D=C3=A9nes?= Date: Wed, 28 Nov 2018 16:39:22 +0200 Subject: [PATCH] database: add accessors for user and streaming concurrency semaphores These will soon be needed to register inactive user and streaming reads with the respective semaphores. --- database.hh | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/database.hh b/database.hh index 3cb08f8fbd..1842795c1c 100644 --- a/database.hh +++ b/database.hh @@ -1428,6 +1428,12 @@ public: std::unordered_set get_initial_tokens(); std::experimental::optional get_replace_address(); bool is_replacing(); + reader_concurrency_semaphore& user_read_concurrency_sem() { + return _read_concurrency_sem; + } + reader_concurrency_semaphore& streaming_read_concurrency_sem() { + return _streaming_concurrency_sem; + } reader_concurrency_semaphore& system_keyspace_read_concurrency_sem() { return _system_read_concurrency_sem; }