diff options
Diffstat (limited to 'src/openxc/decoder.cpp')
| -rw-r--r-- | src/openxc/decoder.cpp | 108 |
1 files changed, 108 insertions, 0 deletions
diff --git a/src/openxc/decoder.cpp b/src/openxc/decoder.cpp new file mode 100644 index 0000000..c8846e8 --- /dev/null +++ b/src/openxc/decoder.cpp @@ -0,0 +1,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; +}
\ No newline at end of file |