X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=low-can-binding%2Fbinding%2Fapplication.cpp;h=063a11da05f42da7ac5167c24f7e6fe71bee62bb;hb=5492ff0bfedfadffc10bcbf172cade47f9450beb;hp=bcb8d73236a64daded23d552386540558ffe0140;hpb=8b3af0fccba13e4098590322975bbd475d3d4f9e;p=apps%2Fagl-service-can-low-level.git diff --git a/low-can-binding/binding/application.cpp b/low-can-binding/binding/application.cpp index bcb8d732..063a11da 100644 --- a/low-can-binding/binding/application.cpp +++ b/low-can-binding/binding/application.cpp @@ -54,25 +54,12 @@ uint8_t application_t::get_active_message_set() const int application_t::add_message_set(std::shared_ptr new_message_set) { - - vect_ptr_msg_def_t messages_definition = new_message_set->get_messages_definition(); - for(std::shared_ptr cmd : messages_definition) - { - cmd->set_parent(new_message_set); - std::vector> signals = cmd->get_signals(); - for(std::shared_ptr sig: signals) - sig->set_parent(cmd); - } - - std::vector> diagnostic_messages = new_message_set->get_diagnostic_messages(); - for(std::shared_ptr dm : diagnostic_messages) - dm->set_parent(new_message_set); + set_parents(new_message_set); for(auto old_msg_set : message_set_) { if(old_msg_set->get_index() == new_message_set->get_index()) { - for(auto new_msg_def : new_message_set->get_messages_definition()) { if(old_msg_set->add_message_definition(new_msg_def) < 0) @@ -84,7 +71,6 @@ int application_t::add_message_set(std::shared_ptr new_message_se if(old_msg_set->add_diagnostic_message(new_diag_msg) < 0) return -1; } - return 0; } } @@ -145,7 +131,7 @@ void application_t::set_active_message_set(uint8_t id) active_message_set_ = id; } -bool application_t::isEngineOn() +bool application_t::is_engine_on() { struct utils::signals_found sf; openxc_DynamicField search_key = build_DynamicField("engine.speed"); @@ -196,6 +182,22 @@ bool application_t::isEngineOn() return engine_on; } +void application_t::set_parents(std::shared_ptr new_message_set) +{ + vect_ptr_msg_def_t messages_definition = new_message_set->get_messages_definition(); + for(std::shared_ptr cmd : messages_definition) + { + cmd->set_parent(new_message_set); + std::vector> signals = cmd->get_signals(); + for(std::shared_ptr sig: signals) + sig->set_parent(cmd); + } + + std::vector> diagnostic_messages = new_message_set->get_diagnostic_messages(); + for(std::shared_ptr dm : diagnostic_messages) + dm->set_parent(new_message_set); +} + #ifdef USE_FEATURE_J1939 std::shared_ptr application_t::get_socket_address_claiming() { @@ -213,4 +215,4 @@ void application_t::set_subscription_address_claiming(std::shared_ptr