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.
This commit is contained in:
Botond Dénes
2018-11-28 16:39:22 +02:00
parent 5f67a065c6
commit bf0d1f4eea

View File

@@ -1428,6 +1428,12 @@ public:
std::unordered_set<sstring> get_initial_tokens();
std::experimental::optional<gms::inet_address> 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;
}