diff options
| author | Douglas B. Rumbaugh <doug@douglasrumbaugh.com> | 2024-12-22 13:00:19 -0500 |
|---|---|---|
| committer | Douglas B. Rumbaugh <doug@douglasrumbaugh.com> | 2024-12-22 13:00:19 -0500 |
| commit | 5617bed5257506d3dfda8537b16f44b3e40f1b42 (patch) | |
| tree | b1a4bb957929b20c884a4eed070f42065828fdb6 /include/framework/scheduling | |
| parent | 9876d74e503df64eb9e82e540ca41fcf593ebf64 (diff) | |
| download | dynamic-extension-5617bed5257506d3dfda8537b16f44b3e40f1b42.tar.gz | |
Began overhauling reconstruction mechanism
Diffstat (limited to 'include/framework/scheduling')
| -rw-r--r-- | include/framework/scheduling/Epoch.h | 6 | ||||
| -rw-r--r-- | include/framework/scheduling/Task.h | 9 |
2 files changed, 6 insertions, 9 deletions
diff --git a/include/framework/scheduling/Epoch.h b/include/framework/scheduling/Epoch.h index 03675b1..303ab2f 100644 --- a/include/framework/scheduling/Epoch.h +++ b/include/framework/scheduling/Epoch.h @@ -8,7 +8,6 @@ */ #pragma once -#include <condition_variable> #include <mutex> #include "framework/structure/BufferView.h" @@ -17,13 +16,12 @@ namespace de { -template <ShardInterface ShardType, QueryInterface<ShardType> QueryType, - LayoutPolicy L> +template <ShardInterface ShardType, QueryInterface<ShardType> QueryType> class Epoch { private: typedef typename ShardType::RECORD RecordType; typedef MutableBuffer<RecordType> Buffer; - typedef ExtensionStructure<ShardType, QueryType, L> Structure; + typedef ExtensionStructure<ShardType, QueryType> Structure; typedef BufferView<RecordType> BufView; public: diff --git a/include/framework/scheduling/Task.h b/include/framework/scheduling/Task.h index 34f053a..7242bef 100644 --- a/include/framework/scheduling/Task.h +++ b/include/framework/scheduling/Task.h @@ -19,16 +19,15 @@ #include "framework/scheduling/Epoch.h" #include "framework/scheduling/statistics.h" -#include "framework/util/Configuration.h" +#include "util/types.h" namespace de { -template <ShardInterface ShardType, QueryInterface<ShardType> QueryType, - LayoutPolicy L> +template <ShardInterface ShardType, QueryInterface<ShardType> QueryType> struct ReconstructionArgs { typedef typename ShardType::RECORD RecordType; - Epoch<ShardType, QueryType, L> *epoch; - ReconstructionVector merges; + Epoch<ShardType, QueryType> *epoch; + ReconstructionVector tasks; std::promise<bool> result; bool compaction; void *extension; |