diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-17 17:28:50 -0500 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-01-17 17:28:50 -0500 |
| commit | 6c906c94e1eea6d4356b8c99b93da39029e8d95d (patch) | |
| tree | 8c5cd0d5bc5186cf6f19b29a94d424224a1cde8e /include/framework/scheduling/Epoch.h | |
| parent | 77589d4cc82b766d2cf16294fab98a57f6579cb4 (diff) | |
| download | dynamic-extension-6c906c94e1eea6d4356b8c99b93da39029e8d95d.tar.gz | |
Progress
Diffstat (limited to 'include/framework/scheduling/Epoch.h')
| -rw-r--r-- | include/framework/scheduling/Epoch.h | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/include/framework/scheduling/Epoch.h b/include/framework/scheduling/Epoch.h index 95c64ea..7583727 100644 --- a/include/framework/scheduling/Epoch.h +++ b/include/framework/scheduling/Epoch.h @@ -17,7 +17,7 @@ namespace de { template <ShardInterface ShardType, QueryInterface<ShardType> QueryType> -class Epoch { +class Version { private: typedef typename ShardType::RECORD RecordType; typedef MutableBuffer<RecordType> Buffer; @@ -25,17 +25,17 @@ private: typedef BufferView<RecordType> BufView; public: - Epoch(size_t number = 0) + Version(size_t number = 0) : m_buffer(nullptr), m_structure(nullptr), m_active_merge(false), m_epoch_number(number), m_buffer_head(0) {} - Epoch(size_t number, Structure *structure, Buffer *buff, size_t head) + Version(size_t number, Structure *structure, Buffer *buff, size_t head) : m_buffer(buff), m_structure(structure), m_active_merge(false), m_epoch_number(number), m_buffer_head(head) { structure->take_reference(); } - ~Epoch() { + ~Version() { if (m_structure) { m_structure->release_reference(); } @@ -49,10 +49,10 @@ public: * Epochs are *not* copyable or movable. Only one can exist, and all users * of it work with pointers */ - Epoch(const Epoch &) = delete; - Epoch(Epoch &&) = delete; - Epoch &operator=(const Epoch &) = delete; - Epoch &operator=(Epoch &&) = delete; + Version(const Version &) = delete; + Version(Version &&) = delete; + Version &operator=(const Version &) = delete; + Version &operator=(Version &&) = delete; size_t get_epoch_number() const { return m_epoch_number; } @@ -68,9 +68,9 @@ public: * the same one. The epoch number of the new epoch will be set to the * provided argument. */ - Epoch *clone(size_t number) { + Version *clone(size_t number) { std::unique_lock<std::mutex> m_buffer_lock; - auto epoch = new Epoch(number); + auto epoch = new Version(number); epoch->m_buffer = m_buffer; epoch->m_buffer_head = m_buffer_head; |