1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#define SATDUMP_DLL_EXPORT2 1
#include <filesystem>
#include "processing.h"
#include "logger.h"
#include "core/pipeline.h"
#include "core/config.h"
#include "main_ui.h"
namespace satdump
{
// TMP, MOVE TO HEADER
extern std::shared_ptr<Application> current_app;
extern bool in_app;
std::mutex processing_mutex;
namespace processing
{
void process(std::string downlink_pipeline,
std::string input_level,
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.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);
ui_call_list_mutex->lock();
ui_call_list->clear();
ui_call_list_mutex->unlock();
try
{
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;
}
is_processing = false;
logger->info("Done! Goodbye");
if (config::main_cfg["user_interface"]["open_viewer_post_processing"]["value"].get<bool>())
{
if (std::filesystem::exists(output_file + "/dataset.json"))
{
logger->info("Opening viewer!");
viewer_app->loadDatasetInViewer(output_file + "/dataset.json");
}
}
processing_mutex.unlock();
}
SATDUMP_DLL2 std::shared_ptr<std::vector<std::shared_ptr<ProcessingModule>>> ui_call_list = std::make_shared<std::vector<std::shared_ptr<ProcessingModule>>>();
SATDUMP_DLL2 std::shared_ptr<std::mutex> ui_call_list_mutex = std::make_shared<std::mutex>();
SATDUMP_DLL2 bool is_processing = false;
}
}
|
