Get decoding diagnostic request from decoding thread of can_bus_t

Decoding divided in 2 subfunctions dedicated to decode either
pure CAN messages or diagnostic (obd2) message. About now,
a diagnostic request has a name then it will be pushed
on the event_queue as a SimpleMessage. Without name full
details of diagnostic response will be pushed as diagnostic
response. This behavior follows the one from OpenXC.

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

4 files changed, 101 insertions, 31 deletions

diff --git a/src/can/can-bus-dev.cpp b/src/can/can-bus-dev.cpp
index 5c8673c..a574b42 100644
--- a/src/can/can-bus-dev.cpp
+++ b/src/can/can-bus-dev.cpp
@@ -42,6 +42,11 @@ std::string can_bus_dev_t::get_device_name() const
 	return device_name_;
 }
 
+uint32_t can_bus_dev_t::get_address() const
+{
+	return address_;
+}
+
 /// @brief Open the can socket and returning it
 /// @return -1 if something wrong.
 int can_bus_dev_t::open()
diff --git a/src/can/can-bus-dev.hpp b/src/can/can-bus-dev.hpp
index c0ef8da..63e6163 100644
--- a/src/can/can-bus-dev.hpp
+++ b/src/can/can-bus-dev.hpp
@@ -49,6 +49,7 @@ public:
 	can_bus_dev_t(const std::string& dev_name, int32_t address);
 
 	std::string get_device_name() const;
+	uint32_t get_address() const;
 
 	int open();
 	int close();
diff --git a/src/can/can-bus.cpp b/src/can/can-bus.cpp
index 79fcd3f..dfecea9 100644
--- a/src/can/can-bus.cpp
+++ b/src/can/can-bus.cpp
@@ -51,6 +51,87 @@ can_bus_t::can_bus_t(int conf_file)
 }
 
 
+int can_bus_t::process_can_signals(can_message_t& can_message)
+{
+	int processed_signals = 0;
+	std::vector <can_signal_t*> signals;
+	openxc_DynamicField search_key, decoded_message;
+	openxc_VehicleMessage vehicle_message;
+
+	/* First we have to found which can_signal_t it is */
+	search_key = build_DynamicField((double)can_message.get_id());
+	signals.clear();
+	configuration_t::instance().find_can_signals(search_key, signals);
+
+	/* Decoding the message ! Don't kill the messenger ! */
+	for(auto& sig : signals)
+	{
+		std::lock_guard<std::mutex> subscribed_signals_lock(get_subscribed_signals_mutex());
+		std::map<std::string, struct afb_event>& s = get_subscribed_signals();
+
+		/* DEBUG message to make easier debugger STL containers...
+		DEBUG(binder_interface, "Operator[] key char: %s, event valid? %d", sig.generic_name, afb_event_is_valid(s[sig.generic_name]));
+		DEBUG(binder_interface, "Operator[] key string: %s, event valid? %d", sig.generic_name, afb_event_is_valid(s[std::string(sig.generic_name)]));
+		DEBUG(binder_interface, "Nb elt matched char: %d", (int)s.count(sig.generic_name));
+		DEBUG(binder_interface, "Nb elt matched string: %d", (int)s.count(std::string(sig.generic_name)));*/
+		if( s.find(sig->get_name()) != s.end() && afb_event_is_valid(s[sig->get_name()]))
+		{
+			decoded_message = decoder_t::translateSignal(*sig, can_message, configuration_t::instance().get_can_signals());
+
+			openxc_SimpleMessage s_message = build_SimpleMessage(sig->get_generic_name(), decoded_message);
+			vehicle_message = build_VehicleMessage(s_message);
+
+			std::lock_guard<std::mutex> decoded_can_message_lock(decoded_can_message_mutex_);
+			push_new_vehicle_message(vehicle_message);
+			new_decoded_can_message_.notify_one();
+			processed_signals++;
+		}
+	}
+
+	DEBUG(binder_interface, "process_can_signals: %d/%d CAN signals processed.", processed_signals, (int)signals.size());
+	return processed_signals;
+}
+
+int can_bus_t::process_diagnostic_signals(active_diagnostic_request_t* entry, const can_message_t& can_message)
+{
+	int processed_signals = 0;
+	openxc_VehicleMessage vehicle_message;
+
+	diagnostic_manager_t& manager = configuration_t::instance().get_diagnostic_manager();
+	
+	std::lock_guard<std::mutex> subscribed_signals_lock(get_subscribed_signals_mutex());
+	std::map<std::string, struct afb_event>& s = get_subscribed_signals();
+
+	if( s.find(entry->get_name()) != s.end() && afb_event_is_valid(s[entry->get_name()]))
+	{
+		if(manager.get_can_bus_dev() == entry->get_can_bus_dev() && entry->get_in_flight())
+		{
+			DiagnosticResponse response = diagnostic_receive_can_frame(
+					// TODO: openXC todo task: eek, is bus address and array index this tightly coupled?
+					&manager.get_shims(),
+					entry->get_handle(), can_message.get_id(), can_message.get_data(), can_message.get_length());
+			if(response.completed && entry->get_handle()->completed)
+			{
+				if(entry->get_handle()->success)
+				{
+					vehicle_message = manager.relay_diagnostic_response(entry, response);
+					std::lock_guard<std::mutex> decoded_can_message_lock(decoded_can_message_mutex_);
+					push_new_vehicle_message(vehicle_message);
+					new_decoded_can_message_.notify_one();
+					processed_signals++;
+				}
+				else
+					DEBUG(binder_interface, "Fatal error sending or receiving diagnostic request");
+			}
+			else if(!response.completed && response.multi_frame)
+				// Reset the timeout clock while completing the multi-frame receive
+				entry->get_timeout_clock().tick();
+		}
+	}
+
+	return processed_signals;
+}
+
 /**
 * @brief thread to decoding raw CAN messages.
 *
@@ -59,13 +140,15 @@ can_bus_t::can_bus_t(int conf_file)
 *  subscription has been made. Can message will be decoded using translateSignal that will pass it to the
 *  corresponding decoding function if there is one assigned for that signal. If not, it will be the default
 *  noopDecoder function that will operate on it.
+*
+*  Depending on the nature of message, if id match a diagnostic request corresponding id for a response 
+*  then decoding a diagnostic message else use classic CAN signals decoding functions.
+*
+*  TODO: make diagnostic messages parsing optionnal.
 */
 void can_bus_t::can_decode_message()
 {
 	can_message_t can_message;
-	std::vector <can_signal_t*> signals;
-	openxc_VehicleMessage vehicle_message;
-	openxc_DynamicField search_key, decoded_message;
 
 	while(is_decoding_)
 	{
@@ -73,34 +156,11 @@ void can_bus_t::can_decode_message()
 		new_can_message_cv_.wait(can_message_lock);
 		can_message = next_can_message();
 
-		/* First we have to found which can_signal_t it is */
-		search_key = build_DynamicField((double)can_message.get_id());
-		signals.clear();
-		configuration_t::instance().find_can_signals(search_key, signals);
-
-		/* Decoding the message ! Don't kill the messenger ! */
-		for(auto& sig : signals)
-		{
-			std::lock_guard<std::mutex> subscribed_signals_lock(get_subscribed_signals_mutex());
-			std::map<std::string, struct afb_event>& s = get_subscribed_signals();
-
-			/* DEBUG message to make easier debugger STL containers...
-			DEBUG(binder_interface, "Operator[] key char: %s, event valid? %d", sig.generic_name, afb_event_is_valid(s[sig.generic_name]));
-			DEBUG(binder_interface, "Operator[] key string: %s, event valid? %d", sig.generic_name, afb_event_is_valid(s[std::string(sig.generic_name)]));
-			DEBUG(binder_interface, "Nb elt matched char: %d", (int)s.count(sig.generic_name));
-			DEBUG(binder_interface, "Nb elt matched string: %d", (int)s.count(std::string(sig.generic_name)));*/
-			if( s.find(sig->get_name()) != s.end() && afb_event_is_valid(s[sig->get_name()]))
-			{
-				decoded_message = decoder_t::translateSignal(*sig, can_message, configuration_t::instance().get_can_signals());
-
-				openxc_SimpleMessage s_message = build_SimpleMessage(sig->get_generic_name(), decoded_message);
-				vehicle_message = build_VehicleMessage_with_SimpleMessage(openxc_DynamicField_Type::openxc_DynamicField_Type_NUM, s_message);
-
-				std::lock_guard<std::mutex> decoded_can_message_lock(decoded_can_message_mutex_);
-				push_new_vehicle_message(vehicle_message);
-				new_decoded_can_message_.notify_one();
-			}
-		}
+		active_diagnostic_request_t* adr = configuration_t::instance().get_diagnostic_manager().is_diagnostic_response(can_message);
+		if(adr != nullptr)
+			process_diagnostic_signals(adr, can_message);
+		else
+			process_can_signals(can_message);
 	}
 }
 
diff --git a/src/can/can-bus.hpp b/src/can/can-bus.hpp
index a001d1e..b4f1a3e 100644
--- a/src/can/can-bus.hpp
+++ b/src/can/can-bus.hpp
@@ -29,6 +29,7 @@
 #include "can-signals.hpp"
 #include "can-message.hpp"
 #include "can-bus-dev.hpp"
+#include "../obd2/active-diagnostic-request.hpp"
 
 #include "../low-can-binding.hpp"
 
@@ -79,6 +80,9 @@ public:
 	void start_threads();
 	void stop_threads();
 
+	int process_can_signals(can_message_t& can_message);
+	int process_diagnostic_signals(active_diagnostic_request_t* adr, const can_message_t& can_message);
+
 	can_message_t next_can_message();
 	void push_new_can_message(const can_message_t& can_msg);
 	std::mutex& get_can_message_mutex();