From f149a2459cfc2007f755d792b3c4e567d30c132f Mon Sep 17 00:00:00 2001 From: Douglas Rumbaugh Date: Fri, 24 Jan 2025 17:45:45 -0500 Subject: some progress --- include/framework/DynamicExtension.h | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) (limited to 'include/framework/DynamicExtension.h') diff --git a/include/framework/DynamicExtension.h b/include/framework/DynamicExtension.h index 62aaf88..0331353 100644 --- a/include/framework/DynamicExtension.h +++ b/include/framework/DynamicExtension.h @@ -413,8 +413,27 @@ private: static void reconstruction(void *arguments) { auto args = (ReconstructionArgs *)arguments; + auto extension = (DynamicExtension *) args->extension; + extension->SetThreadAffinity(); + + if (args->priority == ReconstructionPriority::FLUSH) { + /* we first construct a shard from the buffer */ + auto buffview = args->version->get_buffer(); + auto new_head = buffview.get_tail(); + auto new_shard = Shard(std::move(buffview)); + + /* copy the currently active version's structure */ + auto structure = extension->get_active_version()->get_structure()->clone(); + + + } + - ((DynamicExtension *)args->extension)->SetThreadAffinity(); + else { + + } + + Structure *vers = args->version->get_mutable_structure(); ReconstructionTask flush_task; -- cgit v1.2.3