ham-ref/satdump
1
0
Fork 0
mirror of https://github.com/SatDump/SatDump synced 2026-08-13 17:47:30 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

A bunch of pipeline work

Browse source
This commit is contained in:
Jamie Vital 2024-07-21 14:58:03 -04:00
parent 6bc22851af
commit 7841bfea74
20 changed files with 165 additions and 119 deletions
Download patch file Download diff file Expand all files Collapse all files

44
src-interface/processing.cpp
View file

@ -22,40 +22,48 @@ namespace satdump
std::string input_file,
std::string output_file,
nlohmann::json parameters)
{
// Get pipeline
std::optional<Pipeline> pipeline = getPipelineFromName(downlink_pipeline);
if (!pipeline.has_value())
{
logger->critical("Pipeline " + downlink_pipeline + " does not exist!");
return;
}
process(pipeline.value(), input_level, input_file, output_file, parameters);
}
void process(Pipeline downlink_pipeline,
std::string input_level,
std::string input_file,
std::string output_file,
nlohmann::json parameters)
{
processing_mutex.lock();
is_processing = true;
logger->info("Starting processing pipeline " + downlink_pipeline + "...");
logger->info("Starting processing pipeline " + downlink_pipeline.name + "...");
logger->debug("Input file (" + input_level + ") : " + input_file);
logger->debug("Output file : " + output_file);
if (!std::filesystem::exists(output_file))
std::filesystem::create_directories(output_file);
// Get pipeline
std::optional<Pipeline> pipeline = getPipelineFromName(downlink_pipeline);
ui_call_list_mutex->lock();
ui_call_list->clear();
ui_call_list_mutex->unlock();
if (pipeline.has_value())
try
{
try
{
pipeline.value().run(input_file, output_file, parameters, input_level, true, ui_call_list, ui_call_list_mutex);
}
catch (std::exception &e)
{
logger->error("Fatal error running pipeline : " + std::string(e.what()));
is_processing = false;
processing_mutex.unlock();
return;
}
downlink_pipeline.run(input_file, output_file, parameters, input_level, true, ui_call_list, ui_call_list_mutex);
}
catch (std::exception &e)
{
logger->error("Fatal error running pipeline : " + std::string(e.what()));
is_processing = false;
processing_mutex.unlock();
return;
}
else
logger->critical("Pipeline " + downlink_pipeline + " does not exist!");
is_processing = false;