summaryrefslogtreecommitdiffstats
path: root/include/framework/scheduling/Epoch.h
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-01-17 17:28:50 -0500
committerDouglas Rumbaugh <dbr4@psu.edu>2025-01-17 17:28:50 -0500
commit6c906c94e1eea6d4356b8c99b93da39029e8d95d (patch)
tree8c5cd0d5bc5186cf6f19b29a94d424224a1cde8e /include/framework/scheduling/Epoch.h
parent77589d4cc82b766d2cf16294fab98a57f6579cb4 (diff)
downloaddynamic-extension-6c906c94e1eea6d4356b8c99b93da39029e8d95d.tar.gz
Progress
Diffstat (limited to 'include/framework/scheduling/Epoch.h')
-rw-r--r--include/framework/scheduling/Epoch.h20
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;