summaryrefslogtreecommitdiffstats
path: root/include/framework/scheduling/Task.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/Task.h
parent77589d4cc82b766d2cf16294fab98a57f6579cb4 (diff)
downloaddynamic-extension-6c906c94e1eea6d4356b8c99b93da39029e8d95d.tar.gz
Progress
Diffstat (limited to 'include/framework/scheduling/Task.h')
-rw-r--r--include/framework/scheduling/Task.h11
1 files changed, 8 insertions, 3 deletions
diff --git a/include/framework/scheduling/Task.h b/include/framework/scheduling/Task.h
index 7242bef..1ab35d2 100644
--- a/include/framework/scheduling/Task.h
+++ b/include/framework/scheduling/Task.h
@@ -23,14 +23,19 @@
namespace de {
+enum class ReconstructionPriority {
+ FLUSH = 0,
+ CMPCT = 1,
+ MAINT = 2
+};
+
template <ShardInterface ShardType, QueryInterface<ShardType> QueryType>
struct ReconstructionArgs {
typedef typename ShardType::RECORD RecordType;
- Epoch<ShardType, QueryType> *epoch;
+ std::atomic<std::shared_ptr<Version<ShardType, QueryType>>> version;
ReconstructionVector tasks;
- std::promise<bool> result;
- bool compaction;
void *extension;
+ ReconstructionPriority priority;
};
template <ShardInterface S, QueryInterface<S> Q, typename DE> struct QueryArgs {