diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-09-25 14:42:44 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-09-25 14:42:44 -0400 |
| commit | cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71 (patch) | |
| tree | 4c17bc3169ee195c236cea9c9efda0aef7488e3c /include/framework/scheduling/LockManager.h | |
| parent | 826c1fff5accbaa6b415acc176a5acbeb5f691b6 (diff) | |
| download | dynamic-extension-cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71.tar.gz | |
Code reformatting
Diffstat (limited to 'include/framework/scheduling/LockManager.h')
| -rw-r--r-- | include/framework/scheduling/LockManager.h | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/include/framework/scheduling/LockManager.h b/include/framework/scheduling/LockManager.h index a40cf7a..820b975 100644 --- a/include/framework/scheduling/LockManager.h +++ b/include/framework/scheduling/LockManager.h @@ -3,15 +3,15 @@ */ #pragma once -#include <deque> #include <atomic> #include <cassert> +#include <deque> namespace de { class LockManager { public: - LockManager(size_t levels=1) { - for (size_t i=0; i < levels; i++) { + LockManager(size_t levels = 1) { + for (size_t i = 0; i < levels; i++) { m_lks.emplace_back(false); } @@ -20,9 +20,7 @@ public: ~LockManager() = default; - void add_lock() { - m_lks.emplace_back(false); - } + void add_lock() { m_lks.emplace_back(false); } void release_lock(size_t idx, size_t version) { if (idx < m_lks.size()) { @@ -72,17 +70,13 @@ public: return false; } - bool is_buffer_locked() { - return m_buffer_lk.load(); - } + bool is_buffer_locked() { return m_buffer_lk.load(); } - void release_buffer_lock() { - m_buffer_lk.store(false); - } + void release_buffer_lock() { m_buffer_lk.store(false); } private: std::deque<std::atomic<bool>> m_lks; std::atomic<bool> m_buffer_lk; std::atomic<size_t> m_last_unlocked_version; }; -} +} // namespace de |