Change hpp include file directive

Change-Id: I1df7ab41b19a2c065d8ed477115e21e0ded8659f
Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>

diff --git a/src/can-signals.hpp b/src/can-signals.hpp
index f34c743..91a6932 100644 (file)
--- a/src/can-signals.hpp
+++ b/src/can-signals.hpp
@@ -17,7 +17,7 @@
 
 #pragma once
 
-#include "can-utils.h"
+#include "can-utils.hpp"
 #include <string>
 
 /** Public: Return the currently active CAN configuration. */

diff --git a/src/can_event_push.cpp b/src/can_event_push.cpp
index a59aba7..3964f97 100644 (file)
--- a/src/can_event_push.cpp
+++ b/src/can_event_push.cpp
@@ -26,10 +26,10 @@
 #include "openxc.pb.h"
 #include "json-c/json.h"
 
-void can_event_push(can_bus_t *can_bus)
+void can_event_push(can_bus_t& can_bus)
 {
-       openxc_VehicleMessage *v_message;
-       openxc_SimpleMessage *s_message;
+       openxc_VehicleMessage v_message;
+       openxc_SimpleMessage s_message;
        iterator it_event;
 
        while(true)
@@ -37,20 +37,21 @@ void can_event_push(can_bus_t *can_bus)
                if(v_message = can_bus->next_vehicle_message())
                {
                        s_message = get_simple_message(v_msg);
-                       it_event = event_map.find(s_msg->name);
-                       afb_event_push(it_event->second, jsonify_simple(s_msg));
+                       const auto& it_event = subscribed_signals.find(s_msg.name);
+                       if(! it_event->end() && afb_event_is_valid(it_event->second))
+                               afb_event_push(it_event->second, jsonify_simple(s_msg));
                }
        }
 }
 
-void jsonify_DynamicField(openxc_DynamicField *field, json_object *value)
+void jsonify_DynamicField(const openxc_DynamicField& field, const json_object& value)
 {
-       if(field->has_numeric_value)
-               json_object_object_add(value, "value", json_object_new_double(field->numeric_value));
-       else if(field->has_boolean_value)
-               json_object_object_add(value, "value", json_object_new_boolean(field->boolean_value));
-       else if(field->has_string_value)
-               json_object_object_add(value, "value", json_object_new_string(field->string_value));
+       if(field.has_numeric_value)
+               json_object_object_add(value, "value", json_object_new_double(field.numeric_value));
+       else if(field.has_boolean_value)
+               json_object_object_add(value, "value", json_object_new_boolean(field.boolean_value));
+       else if(field.has_string_value)
+               json_object_object_add(value, "value", json_object_new_string(field.string_value));
 
        return value;
 }
@@ -58,24 +59,21 @@ void jsonify_DynamicField(openxc_DynamicField *field, json_object *value)
 /* Extract the simple message value from an openxc_VehicleMessage
  * and return it, or null if there isn't.
  */
-openxc_SimpleMessage* get_simple_message(openxc_VehicleMessage *v_msg)
+openxc_SimpleMessage get_simple_message(const openxc_VehicleMessage& v_msg)
 {
-       if(v_msg->has_simple_message)
-               return v_msg->simple_message;
-       
-       return nullptr;
+       return v_msg.has_simple_message ? v_msg.simple_message : {0};
 }
 
-json_object* jsonify_simple(openxc_SimpleMessage *s_msg)
+json_object jsonify_simple(const openxc_SimpleMessage& s_msg)
 {
        json_object *json;
-       json = json_object_new_object();
-
-       if(!s_msg->has_name)
-               return nullptr;
-
-       json_object_object_add(json, "name", json_object_new_string(s_msg->name));
-       jsonify_DynamicField(&s_msg->value, json);
+       json = nullptr;
 
+       if(s_msg->has_name)
+       {
+         json = json_object_new_object();
+       json_object_object_add(json, "name", json_object_new_string(s_msg->name));
+       jsonify_DynamicField(&s_msg->value, json);
+  }
        return json;
 }
\ No newline at end of file

diff --git a/src/obd2.hpp b/src/obd2.hpp
index 166773c..72b41eb 100644 (file)
--- a/src/obd2.hpp
+++ b/src/obd2.hpp
@@ -15,6 +15,7 @@
  * limitations under the License.
  */
 
+#include <vector>
 #include "uds/uds.h"
 
 enum UNIT {
@@ -67,27 +68,6 @@ typedef struct _Obd2Pid {
        struct afb_event event;
 } Obd2Pid;
 
-/*
-       { pid: 0x4, name: "engine.load", frequency: 5 },
-       { pid: 0x5, name: "engine.coolant.temperature", frequency: 1 },
-       { pid: 0xa, name: "fuel.pressure", frequency: 1 },
-       { pid: 0xb, name: "intake.manifold.pressure", frequency: 1 },
-       { pid: 0xc, name: "engine.speed", frequency: 5 },
-       { pid: 0xd, name: "vehicle.speed", frequency: 5 },
-       { pid: 0xf, name: "intake.air.temperature", frequency: 1 },
-       { pid: 0x10, name: "mass.airflow", frequency: 5 },
-       { pid: 0x11, name: "throttle.position", frequency: 5 },
-       { pid: 0x1f, name: "running.time", frequency: 1 },
-       { pid: 0x27, name: "fuel.level", frequency: 1 },
-       { pid: 0x33, name: "barometric.pressure", frequency: 1 },
-       { pid: 0x4c, name: "commanded.throttle.position", frequency: 1 },
-       { pid: 0x52, name: "ethanol.fuel.percentage", frequency: 1 },
-       { pid: 0x5a, name: "accelerator.pedal.position", frequency: 5 },
-       { pid: 0x5c, name: "engine.oil.temperature", frequency: 1 },
-       { pid: 0x63, name: "engine.torque", frequency: 1 },
-};
- */
-
 /* Public: Check if a request is an OBD-II PID request.
  *
  * Returns true if the request is a mode 1     request and it has a 1 byte PID.
@@ -110,57 +90,58 @@ float handleObd2Pid(const DiagnosticResponse* response, float parsedPayload);
 class obd2_handler_c {
        private:
 
-               public:
-               /*
-               * Pre-defined OBD-II PIDs to query for if supported by the vehicle.
-               */
-               const Obd2Pid OBD2_PIDS[] = {
-                       { pid: 0x04, name: "obd2.engine.load", min:0, max: 100, unit: POURCENT, frequency: 5, supported: false },
-                       { pid: 0x05, name: "obd2.engine.coolant.temperature", min: -40, max: 215, unit: DEGREES_CELSIUS, frequency: 1, supported: false },
-                       { pid: 0x0a, name: "obd2.fuel.pressure", min: 0, max: 765, unit: KPA, frequency: 1, supported: false },
-                       { pid: 0x0b, name: "obd2.intake.manifold.pressure", min: 0, max: 255, unit: KPA, frequency: 1, supported: false },
-                       { pid: 0x0c, name: "obd2.engine.speed", min: 0, max: 16383, unit: RPM, frequency: 5, supported: false },
-                       { pid: 0x0d, name: "obd2.vehicle.speed", min: 0, max: 255, unit: KM_H, frequency: 5, supported: false },
-                       { pid: 0x0f, name: "obd2.intake.air.temperature", min: -40, max:215, unit: DEGREES_CELSIUS, frequency: 1, supported: false },
-                       { pid: 0x10, name: "obd2.mass.airflow", min: 0, max: 655, unit: GRAMS_SEC, frequency: 5, supported: false },
-                       { pid: 0x11, name: "obd2.throttle.position", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false },
-                       { pid: 0x1f, name: "obd2.running.time", min: 0, max: 65535, unit: SECONDS, frequency: 1, supported: false },
-                       { pid: 0x2d, name: "obd2.EGR.error", min: -100, max: 99, unit: POURCENT, frequency: 0, supported: false },
-                       { pid: 0x2f, name: "obd2.fuel.level", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false },
-                       { pid: 0x33, name: "obd2.barometric.pressure", min: 0, max: 255, unit: KPA, frequency: 1, supported: false },
-                       { pid: 0x4c, name: "obd2.commanded.throttle.position", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false },
-                       { pid: 0x52, name: "obd2.ethanol.fuel.percentage", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false },
-                       { pid: 0x5a, name: "obd2.accelerator.pedal.position", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false },
-                       { pid: 0x5b, name: "obd2.hybrid.battery-pack.remaining.life", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false },
-                       { pid: 0x5c, name: "obd2.engine.oil.temperature",min: -40, max: 210, unit: DEGREES_CELSIUS, frequency: 1, supported: false },
-                       { pid: 0x63, name: "obd2.engine.torque", min: 0, max: 65535, unit: NM, frequency: 1, supported: false },
-               };
-
-                       
-                       /* Public: Check if a request is an OBD-II PID request.
-                        *
-                        * Returns true if the request is a mode 1  request and it has a 1 byte PID.
-                        */
-                       void find_obd2_pid(const char *name, std::Vector<Obd2Pid> *pids);
+       public:
+       /*
+       * Pre-defined OBD-II PIDs to query for if supported by the vehicle.
+       */
+       const Obd2Pid OBD2_PIDS[] = {
+               { pid: 0x04, name: "obd2.engine.load", min:0, max: 100, unit: POURCENT, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x05, name: "obd2.engine.coolant.temperature", min: -40, max: 215, unit: DEGREES_CELSIUS, frequency: 1, supported: false, event: nullptr},
+               { pid: 0x0a, name: "obd2.fuel.pressure", min: 0, max: 765, unit: KPA, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x0b, name: "obd2.intake.manifold.pressure", min: 0, max: 255, unit: KPA, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x0c, name: "obd2.engine.speed", min: 0, max: 16383, unit: RPM, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x0d, name: "obd2.vehicle.speed", min: 0, max: 255, unit: KM_H, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x0f, name: "obd2.intake.air.temperature", min: -40, max:215, unit: DEGREES_CELSIUS, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x10, name: "obd2.mass.airflow", min: 0, max: 655, unit: GRAMS_SEC, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x11, name: "obd2.throttle.position", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x1f, name: "obd2.running.time", min: 0, max: 65535, unit: SECONDS, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x2d, name: "obd2.EGR.error", min: -100, max: 99, unit: POURCENT, frequency: 0, supported: false, event: nullptr },
+               { pid: 0x2f, name: "obd2.fuel.level", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x33, name: "obd2.barometric.pressure", min: 0, max: 255, unit: KPA, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x4c, name: "obd2.commanded.throttle.position", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x52, name: "obd2.ethanol.fuel.percentage", min: 0, max: 100, unit: POURCENT, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x5a, name: "obd2.accelerator.pedal.position", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x5b, name: "obd2.hybrid.battery-pack.remaining.life", min: 0, max: 100, unit: POURCENT, frequency: 5, supported: false, event: nullptr },
+               { pid: 0x5c, name: "obd2.engine.oil.temperature",min: -40, max: 210, unit: DEGREES_CELSIUS, frequency: 1, supported: false, event: nullptr },
+               { pid: 0x63, name: "obd2.engine.torque", min: 0, max: 65535, unit: NM, frequency: 1, supported: false, event: nullptr }
+       };
+               
+               /**
+                * @brief:
+                *
+                * Returns
+                */
+               void find_obd2_pid(const char *name, std::vector<Obd2Pid> *pids);
 
-                       /* Public: Check if a request is an OBD-II PID request.
-                        *
-                        * Returns true if the request is a mode 1  request and it has a 1 byte PID.
-                        */
-                       bool is_obd2_request(DiagnosticRequest *request);
+               /**
+                * @brief Check if a request is an OBD-II PID request.
+                *
+                * @return true if the request is a mode 1  request and it has a 1 byte PID.
+                */
+               bool is_obd2_request(DiagnosticRequest *request);
 
-                       /*
-                        * Public: Check if requested signal name is an obd2 pid
-                        * 
-                        * Returns true if name began with ob2.* else false.
-                        */
-                       bool is_obd2_signal(const char *name);
+               /**
+               * @brief Check if requested signal name is an obd2 pid
+               * 
+               * @return true if name began with ob2.* else false.
+               */
+               bool is_obd2_signal(const char *name);
 
-                       /*
-                        * Public: pass response to UDS-C library function 
-                        * diagnostic_decode_obd2_pid()
-                        *
-                        * Return: float number representing the requested value.
-                        */
-                       bool decode_obd2_response(DiagnosticResponse* responce);
+               /*
+               * @brief pass response to UDS-C library function 
+               * diagnostic_decode_obd2_pid()
+               *
+               * @return float number representing the requested value.
+               */
+               bool decode_obd2_response(DiagnosticResponse* responce);
 }
\ No newline at end of file