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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
#include "decoder.hpp"
map_decoders decoder_t::decoders_states_;
std::string decoder_t::patchs_;
void decoder_t::init_decoder()
{
decoder_t::decoders_states_.insert(pair_decoder("decode_state", states::NATIVE));
decoder_t::decoders_states_.insert(pair_decoder("decode_boolean", states::NATIVE));
decoder_t::decoders_states_.insert(pair_decoder("decode_ignore", states::NATIVE));
decoder_t::decoders_states_.insert(pair_decoder("decode_noop", states::NATIVE));
decoder_t::decoders_states_.insert(pair_decoder("decode_bytes", states::NATIVE));
decoder_t::decoders_states_.insert(pair_decoder("decode_obd2_response", states::NATIVE));
}
std::string decoder_t::add_decoder(std::string decoder, std::string version_file, std::string version_low_can)
{
if(decoder.compare("nullptr"))
{
std::string key = "decoder_t::";
std::size_t pos = decoder.find(key);
std::string decoder_split = decoder.substr(pos+key.size()); // only name of decoder
if ( decoder_t::decoders_states_.find(decoder_split) == decoder_t::decoders_states_.end() ) { // Not found signal
decoder_t::decoders_states_.insert(pair_decoder(decoder_split,states::NEW));
std::string ret = key + decoder_t::patch_version(decoder_split,version_file,version_low_can);
decoder_t::decoders_states_[decoder_split] = states::PROCESSED;
return ret;
}
else
{
if(decoder_t::decoders_states_[decoder_split] == states::PROCESSED)
{
return key + decoder_t::patch_version(decoder_split,version_file,version_low_can);
}
}
}
return decoder;
}
std::string decoder_t::patch_version(std::string decoder, std::string version_file, std::string version_low_can)
{
std::size_t pos = version_file.find(".");
int main_value_version_file = std::stoi(version_file.substr(0,pos));
std::size_t pos2 = version_low_can.find(".");
int main_value_version_low_can = std::stoi(version_low_can.substr(0,pos2));
if(main_value_version_file != main_value_version_low_can) // Not same version
{
if(decoder_t::decoders_states_[decoder] == states::NEW)
{
if(main_value_version_low_can == 2)
{
if(main_value_version_file == 1)
{
decoder_t::v1_to_v2(decoder); // add wrap
}
else
{
throw "Version not implemented";
}
}
else
{
throw "Version not implemented";
}
}
return decoder_t::generate_name_decoder(decoder,version_file,version_low_can);
}
else
{
return decoder;
}
}
std::string decoder_t::generate_name_decoder(std::string decoder, std::string version_file, std::string version_low_can)
{
std::size_t pos = version_file.find(".");
std::string main_value_version_file = version_file.substr(0,pos);
std::size_t pos2 = version_low_can.find(".");
std::string main_value_version_low_can = version_low_can.substr(0,pos2);
return "v"+main_value_version_file+"_to_v"+main_value_version_low_can+"_"+decoder;
}
std::string decoder_t::apply_patch()
{
return decoder_t::patchs_;
}
void decoder_t::v1_to_v2(std::string decoder)
{
std::string patch = "";
patch = patch + "openxc_DynamicField decoder_t::v1_to_v2_"+decoder+"(signal_t& signal, std::shared_ptr<message_t> message, bool* send){\n";
patch = patch + "\tfloat value = decoder_t::parse_signal_bitfield(signal, message);\n";
patch = patch + "\topenxc_DynamicField ret = decoder_t::"+decoder+"(signal, value, send);\n";
patch = patch + "\tif ((signal.get_last_value() == value && !signal.get_send_same()) || !*send ){\n";
patch = patch + "\t\t*send = false;\n";
patch = patch + "\t}\n";
patch = patch + "\tsignal.set_last_value(value);\n";
patch = patch + "\treturn ret;\n";
patch = patch + "}\n";
decoder_t::patchs_ = decoder_t::patchs_ + "\n" + patch;
}
|
