Begin new call

plugins/volume/src/NewDatRawReader.cpp

@@ -0,0 +1,108 @@
+/*
+ * VolumetricDataSource.cpp
+ *
+ * Copyright (C) 2024 by Visualisierungsinstitut der Universit�t Stuttgart.
+ * Alle rechte vorbehalten.
+ */
+
+#include "NewDatRawReader.h"
+
+#include "mmcore/param/BoolParam.h"
+#include "mmcore/param/EnumParam.h"
+#include "mmcore/param/FilePathParam.h"
+#include "mmcore/param/FloatParam.h"
+#include "mmcore/param/IntParam.h"
+#include "mmcore/param/StringParam.h"
+
+#include "datraw.h"
+#include "mmcore/utility/log/Log.h"
+
+megamol::volume::NewDatRawReader::NewDatRawReader()
+ : core::Module()
+ , slotGetData("GetData", "Slot for requesting data.")
+ , paramFileName("FileName", "Path to file.") {
+ using geocalls::VolumetricDataCall;
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_GET_DATA), &NewDatRawReader::onGetData);
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_GET_EXTENTS), &NewDatRawReader::onGetExtents);
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_GET_METADATA), &NewDatRawReader::onGetMetadata);
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_START_ASYNC), &NewDatRawReader::onStartAsync);
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_STOP_ASYNC), &NewDatRawReader::onStopAsync);
+ this->slotGetData.SetCallback(VolumetricDataCall::ClassName(),
+ VolumetricDataCall::FunctionName(VolumetricDataCall::IDX_TRY_GET_DATA), &NewDatRawReader::onTryGetData);
+
+ this->MakeSlotAvailable(&this->slotGetData);
+
+ this->paramFileName.SetParameter(new core::param::FilePathParam(""));
+ this->paramFileName.SetUpdateCallback(&NewDatRawReader::onFileNameChange);
+ this->MakeSlotAvailable(&this->paramFileName);
+}
+
+megamol::volume::NewDatRawReader::~NewDatRawReader() {}
+
+bool megamol::volume::NewDatRawReader::create() {
+ return true;
+}
+
+void megamol::volume::NewDatRawReader::release() {}
+
+bool megamol::volume::NewDatRawReader::onGetData(core::Call& call) {
+ geocalls::VolumetricDataCall& c = dynamic_cast<geocalls::VolumetricDataCall&>(call);
+ return true;
+}
+
+bool megamol::volume::NewDatRawReader::onGetMetadata(core::Call& call) {
+ return false;
+}
+
+bool megamol::volume::NewDatRawReader::onGetExtents(core::Call& call) {
+ try {
+ std::vector<float> volExt;
+ volExt.push_back(datInfo.slice_thickness()[0] * datInfo.resolution()[0]);
+ volExt.push_back(datInfo.slice_thickness()[1] * datInfo.resolution()[1]);
+ volExt.push_back(datInfo.slice_thickness()[2] * datInfo.resolution()[2]);
+
+ geocalls::VolumetricDataCall& c = dynamic_cast<geocalls::VolumetricDataCall&>(call);
+ c.SetExtent(datInfo.time_steps(), datInfo.origin()[0], datInfo.origin()[1], datInfo.origin()[2]
+ , datInfo.origin()[0] + volExt[0], datInfo.origin()[1] + volExt[1], datInfo.origin()[2] + volExt[2]);
+ return true;
+ } catch (vislib::Exception e) {
+ //TODO exception
+ return false;
+ }
+}
+
+bool megamol::volume::NewDatRawReader::onStartAsync(core::Call& call) {
+ return true;
+}
+
+bool megamol::volume::NewDatRawReader::onStopAsync(core::Call& call) {
+ return true;
+}
+
+bool megamol::volume::NewDatRawReader::onTryGetData(core::Call& call) {
+ try {
+
+ }
+ catch (std::exception e) {
+ geocalls::VolumetricDataCall& c = dynamic_cast<geocalls::VolumetricDataCall&>(call);
+ //what does this do?
+ c.SetDataHash(12345u);
+ return false;
+ }
+ return false;
+}
+
+bool megamol::volume::NewDatRawReader::onFileNameChange(core::param::ParamSlot& slot) {
+ // does this actually throw file not found exceptions?
+ try {
+ datInfo = datraw::info<char>::load(slot.Param<core::param::FilePathParam>()->Value().generic_string().c_str());
+ } catch (std::exception e) {
+ megamol::core::utility::log::Log::DefaultLog.WriteInfo("%s\n", e.what());
+ }
+ return true;
+}

plugins/volume/src/NewDatRawReader.h

@@ -0,0 +1,61 @@
+/*
+ * VolumetricDataSource.h
+ *
+ * Copyright (C) 2024 by Visualisierungsinstitut der Universität Stuttgart.
+ * Alle rechte vorbehalten.
+ */
+
+#pragma once
+
+#include <atomic>
+#include <memory>
+#include <vector>
+
+#include "datraw/raw_reader.h"
+
+#include "geometry_calls/VolumetricDataCall.h"
+
+#include "mmcore/param/ParamSlot.h"
+
+#include "mmcore/Call.h"
+#include "mmcore/CalleeSlot.h"
+#include "mmcore/Module.h"
+
+#include "vislib/PtrArray.h"
+#include "vislib/RawStorage.h"
+#include "vislib/sys/Event.h"
+#include "vislib/sys/Thread.h"
+
+namespace megamol::volume {
+class NewDatRawReader : public core::Module {
+
+public:
+ static inline const char* ClassName() {
+ return "NewDatRawReader";
+ }
+ static inline const char* Description() {
+ return "Data source for DatRaw volumetric data.";
+ }
+ static inline bool IsAvailable() {
+ return true;
+ }
+ NewDatRawReader();
+ ~NewDatRawReader() override;
+
+protected:
+ bool create() override;
+ void release() override;
+
+private:
+ core::CalleeSlot slotGetData;
+ core::param::ParamSlot paramFileName;
+ datraw::info<char> datInfo;
+ bool onGetData(core::Call& call);
+ bool onGetMetadata(core::Call& call);
+ bool onGetExtents(core::Call& call);
+ bool onStartAsync(core::Call& call);
+ bool onStopAsync(core::Call& call);
+ bool onTryGetData(core::Call& call);
+ bool onFileNameChange(core::param::ParamSlot& slot);
+};
+} // namespace megamol::volume

plugins/volume/src/volume.cpp

@@ -11,6 +11,7 @@
 #include "DatRawWriter.h"
 #include "DifferenceVolume.h"
 #include "VolumetricDataSource.h"
+#include "NewDatRawReader.h"
 
 namespace megamol::volume {
 class VolumePluginInstance : public megamol::core::factories::AbstractPluginInstance {
@@ -30,6 +31,7 @@ class VolumePluginInstance : public megamol::core::factories::AbstractPluginInst
  this->module_descriptions.RegisterAutoDescription<megamol::volume::DatRawWriter>();
  this->module_descriptions.RegisterAutoDescription<megamol::volume::DifferenceVolume>();
  this->module_descriptions.RegisterAutoDescription<megamol::volume::VolumetricDataSource>();
+ this->module_descriptions.RegisterAutoDescription<megamol::volume::NewDatRawReader>();
 
  // register calls
  }