X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=CAN-binder%2Flow-can-binding%2Fdiagnostic%2Factive-diagnostic-request.cpp;h=35a6c562899a4b2a855aa8dc72368d0bcccaf145;hb=ab4d52b65359c571267c71244578321580520c20;hp=7ddf1d5184348e5e7cbb7b49efc4c9de5de5cd04;hpb=0242c26c2f5dc96387bca7efb118364c800f4ee7;p=apps%2Fagl-service-can-low-level.git

diff --git a/CAN-binder/low-can-binding/diagnostic/active-diagnostic-request.cpp b/CAN-binder/low-can-binding/diagnostic/active-diagnostic-request.cpp
index 7ddf1d51..35a6c562 100644
--- a/CAN-binder/low-can-binding/diagnostic/active-diagnostic-request.cpp
+++ b/CAN-binder/low-can-binding/diagnostic/active-diagnostic-request.cpp
@@ -20,7 +20,7 @@
 
 #include "active-diagnostic-request.hpp"
 
-#include "../configuration.hpp"
+#include "../binding/configuration.hpp"
 
 #define ERROR_PID 0xFF
 
@@ -43,36 +43,55 @@ active_diagnostic_request_t& active_diagnostic_request_t::operator=(const active
 		callback_ = adr.callback_;
 		recurring_ = adr.recurring_; 
 		wait_for_multiple_responses_ = adr.wait_for_multiple_responses_;
-		in_flight_ = adr.in_flight_;
 		frequency_clock_ = adr.frequency_clock_;
 		timeout_clock_ = adr.timeout_clock_;
+		socket_ = adr.socket_;
 	}
 	
 	return *this;
 }
 
 active_diagnostic_request_t::active_diagnostic_request_t()
-	: bus_{nullptr}, id_{0}, handle_{nullptr}, name_{""},
-	  decoder_{nullptr}, callback_{nullptr}, recurring_{false}, wait_for_multiple_responses_{false},
-	  in_flight_{false}, frequency_clock_{frequency_clock_t()}, timeout_clock_{frequency_clock_t()}
+	: bus_{nullptr},
+	  id_{0},
+	  handle_{nullptr},
+	  name_{""},
+	  decoder_{nullptr},
+	  callback_{nullptr},
+	  recurring_{false},
+	  wait_for_multiple_responses_{false},
+	  frequency_clock_{frequency_clock_t()},
+	  timeout_clock_{frequency_clock_t()}
 {}
 
 active_diagnostic_request_t::active_diagnostic_request_t(const std::string& bus, DiagnosticRequest* request,
-		const std::string& name, bool wait_for_multiple_responses, const DiagnosticResponseDecoder decoder,
-		const DiagnosticResponseCallback callback, float frequencyHz)
-	: bus_{bus}, id_{request->arbitration_id}, handle_{nullptr}, name_{name},
-	  decoder_{decoder}, callback_{callback}, recurring_{frequencyHz ? true : false}, wait_for_multiple_responses_{wait_for_multiple_responses},
-	  in_flight_{false}, frequency_clock_{frequency_clock_t(frequencyHz)}, timeout_clock_{frequency_clock_t(10)}
+		const std::string& name,
+		bool wait_for_multiple_responses,
+		const DiagnosticResponseDecoder decoder,
+		const DiagnosticResponseCallback callback,
+		float frequencyHz)
+	: bus_{bus},
+	  id_{request->arbitration_id},
+	  handle_{nullptr},
+	  name_{name},
+	  decoder_{decoder},
+	  callback_{callback},
+	  recurring_{frequencyHz ? true : false},
+	  wait_for_multiple_responses_{wait_for_multiple_responses},
+	  frequency_clock_{frequency_clock_t(frequencyHz)},
+	  timeout_clock_{frequency_clock_t(10)}
 {}
 
-uint32_t active_diagnostic_request_t::get_id() const
+active_diagnostic_request_t::~active_diagnostic_request_t()
 {
-	return id_;
+	socket_.close();
+	delete handle_;
+	handle_ = nullptr;
 }
 
-const std::shared_ptr<can_bus_dev_t> active_diagnostic_request_t::get_can_bus_dev() const
+uint32_t active_diagnostic_request_t::get_id() const
 {
-	return can_bus_t::get_can_device(bus_);
+	return id_;
 }
 
 uint16_t active_diagnostic_request_t::get_pid() const
@@ -112,11 +131,6 @@ bool active_diagnostic_request_t::get_recurring() const
 	return recurring_;
 }
 
-bool active_diagnostic_request_t::get_in_flight() const
-{
-	return in_flight_;
-}
-
 frequency_clock_t& active_diagnostic_request_t::get_frequency_clock()
 {
 	return frequency_clock_;
@@ -127,14 +141,14 @@ frequency_clock_t& active_diagnostic_request_t::get_timeout_clock()
 	return timeout_clock_;
 }
 
-void active_diagnostic_request_t::set_handle(DiagnosticShims& shims, DiagnosticRequest* request)
+utils::socketcan_bcm_t& active_diagnostic_request_t::get_socket()
 {
-	handle_ = new DiagnosticRequestHandle(generate_diagnostic_request(&shims, request, nullptr));
+	return socket_;
 }
 
-void active_diagnostic_request_t::set_in_flight(bool val)
+void active_diagnostic_request_t::set_handle(DiagnosticShims& shims, DiagnosticRequest* request)
 {
-	in_flight_ = val;
+	handle_ = new DiagnosticRequestHandle(generate_diagnostic_request(&shims, request, nullptr));
 }
 
 ///
@@ -153,26 +167,6 @@ bool active_diagnostic_request_t::is_diagnostic_signal(const std::string& name)
 	return false;
 }
 
-/// @brief Check is the request should be sent or not
-///
-/// @return true if the request is not running or recurring nor completed,
-/// or it's recurring, its clock elapsed
-/// so it's time to send another one.
-bool active_diagnostic_request_t::should_send()
-{
-	return !in_flight_ && ( (!recurring_ && !request_completed()) ||
-			(recurring_ && frequency_clock_.elapsed(true)) );
-}
-
-/// @brief check if the timeout clock has elapsed
-///
-/// @return true if elapsed, so it is a timeout, else false.
-bool active_diagnostic_request_t::timed_out()
-{
-	// don't use staggered start with the timeout clock
-	return timeout_clock_.elapsed(false);
-}
-
 /// @brief Returns true if a sufficient response has been received for a
 /// diagnostic request.
 ///
@@ -182,13 +176,5 @@ bool active_diagnostic_request_t::timed_out()
 bool active_diagnostic_request_t::response_received() const
 {
 	return !wait_for_multiple_responses_ &&
-				handle_->completed;
-}
-
-/// @brief Returns true if the request has timed out waiting for a response,
-/// or a sufficient number of responses has been received.
-bool active_diagnostic_request_t::request_completed()
-{
-	return response_received() || 
-		(timed_out() && diagnostic_request_sent(handle_));
+				handle_->completed && handle_->success;
 }