From f06b6358accc3ba106c535ed0cbc70a6da60dac5 Mon Sep 17 00:00:00 2001 From: Romain Forlot Date: Fri, 10 Mar 2017 02:06:57 +0100 Subject: Adding requests to diagnostic manager implemented. Needed overload of operator and constructor set for active_diagnostic_message_t class. Without we can't make the basic operation needed by the manager. Get rid of original raw pointer on "entry" which avoid some tests. It miss the acceptance filters implementations for now. Change-Id: I1ca61ff843c13255af6d9a60ce72a8b8bc9d1c18 Signed-off-by: Romain Forlot --- src/diagnostic/diagnostic-manager.hpp | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) (limited to 'src/diagnostic/diagnostic-manager.hpp') diff --git a/src/diagnostic/diagnostic-manager.hpp b/src/diagnostic/diagnostic-manager.hpp index 2b804a47..e4221dec 100644 --- a/src/diagnostic/diagnostic-manager.hpp +++ b/src/diagnostic/diagnostic-manager.hpp @@ -32,6 +32,7 @@ */ #define MAX_SHIM_COUNT can_bus_t.get_can_devices().size() + /** * @brief The core structure for running the diagnostics module on the VI. * @@ -49,7 +50,7 @@ private: * library (uds-c) into the VI's CAN peripheral.*/ can_bus_dev_t* bus_; /*!< bus_ - A pointer to the CAN bus that should be used for all standard OBD-II requests, if the bus is not * explicitly spcified in the request. If NULL, all requests require an explicit bus.*/ - std::queue recurring_requests_; /*!< recurringRequests - A queue of active, recurring diagnostic requests. When + std::vector recurring_requests_; /*!< recurringRequests - A queue of active, recurring diagnostic requests. When * a response is received for a recurring request or it times out, it is * popped from the queue and pushed onto the back. */ std::vector non_recurring_requests_; /*!< nonrecurringRequests - A list of active one-time diagnostic requests. When a @@ -69,9 +70,20 @@ public: void init_diagnostic_shims(); can_bus_dev_t* get_can_bus_dev(); + active_diagnostic_request_t& get_free_entry(); + + void find_and_erase(active_diagnostic_request_t& entry, std::vector& requests_list); + void cancel_request(active_diagnostic_request_t& entry); + void cleanup_request(active_diagnostic_request_t& entry, bool force); + void cleanup_active_requests(bool force); + bool lookup_recurring_request(const DiagnosticRequest* request); + + + bool validate_optional_request_attributes(float frequencyHz); + void reset(); void checkSupportedPids(const active_diagnostic_request_t& request, - const DiagnosticResponse& response, float parsedPayload); + const DiagnosticResponse& response, float parsedPayload); bool add_request(DiagnosticRequest* request, const std::string name, bool waitForMultipleResponses, const DiagnosticResponseDecoder decoder, @@ -80,6 +92,4 @@ public: bool add_recurring_request(DiagnosticRequest* request, const char* name, bool waitForMultipleResponses, const DiagnosticResponseDecoder decoder, const DiagnosticResponseCallback callback, float frequencyHz); - - void reset(); }; -- cgit 1.2.3-korg