Close diagnostic manager socket if there isn't any requests
[apps/low-level-can-service.git] / CAN-binder / low-can-binding / diagnostic / diagnostic-manager.cpp
index a52bd8f..31a3d23 100644 (file)
@@ -33,7 +33,7 @@
 #define MICRO 1000000
 
 diagnostic_manager_t::diagnostic_manager_t()
-       : initialized_{false}
+       : initialized_{false}, event_source_{nullptr}
 {}
 
 /// @brief Diagnostic manager isn't initialized at launch but after
@@ -49,6 +49,7 @@ bool diagnostic_manager_t::initialize()
        bus_ = configuration_t::instance().get_diagnostic_bus();
 
        init_diagnostic_shims();
+       event_source_ = nullptr;
        reset();
 
        initialized_ = true;
@@ -56,16 +57,6 @@ bool diagnostic_manager_t::initialize()
        return initialized_;
 }
 
-void diagnostic_manager_t::read_socket()
-{
-       can_message_t msg;
-       can_bus_t& cbm = configuration_t::instance().get_can_bus_manager();
-       socket_ >> msg;
-       std::lock_guard<std::mutex> can_message_lock(cbm.get_can_message_mutex());
-       { cbm.push_new_can_message(msg); }
-       cbm.get_new_can_message_cv().notify_one();
-}
-
 utils::socketcan_bcm_t& diagnostic_manager_t::get_socket()
 {
        return socket_;
@@ -95,7 +86,7 @@ int diagnostic_manager_t::add_rx_filter(uint32_t can_id)
 {
        // Make sure that socket has been opened.
        if(! socket_)
-               socket_.open(bus_);
+               socket_.open(get_bus_device_name());
 
        struct utils::simple_bcm_msg bcm_msg;
        memset(&bcm_msg.msg_head, 0, sizeof(bcm_msg.msg_head));
@@ -108,7 +99,7 @@ int diagnostic_manager_t::add_rx_filter(uint32_t can_id)
        bcm_msg.msg_head.ival2.tv_usec = freq.tv_usec;
 
        // If it isn't an OBD2 CAN ID then just add a simple RX_SETUP job
-       if(can_id != OBD2_FUNCTIONAL_RESPONSE_START
+       if(can_id != OBD2_FUNCTIONAL_BROADCAST_ID
        {
                bcm_msg.msg_head.can_id  = can_id;
 
@@ -151,7 +142,7 @@ bool diagnostic_manager_t::shims_send(const uint32_t arbitration_id, const uint8
        // Make sure that socket has been opened.
        if(! tx_socket)
                tx_socket.open(
-                       dm.get_can_bus());
+                       dm.get_bus_device_name());
 
        struct utils::simple_bcm_msg bcm_msg;
        struct can_frame cfd;
@@ -167,6 +158,7 @@ bool diagnostic_manager_t::shims_send(const uint32_t arbitration_id, const uint8
        bcm_msg.msg_head.ival2.tv_sec = freq.tv_sec;
        bcm_msg.msg_head.ival2.tv_usec = freq.tv_usec;
        bcm_msg.msg_head.nframes = 1;
+       cfd.can_dlc = size;
        ::memcpy(cfd.data, data, size);
 
        bcm_msg.frames = cfd;
@@ -193,13 +185,24 @@ void diagnostic_manager_t::shims_logger(const char* format, ...)
        vsnprintf(buffer, 256, format, args);
 
        DEBUG(binder_interface, "%s: %s", __FUNCTION__, buffer);
+       va_end(args);
 }
 
 /// @brief The type signature for a... OpenXC TODO: not used yet.
 void diagnostic_manager_t::shims_timer()
 {}
 
-std::shared_ptr<can_bus_dev_t> diagnostic_manager_t::get_can_bus_dev()
+const std::string diagnostic_manager_t::get_bus_name() const
+{
+       return bus_;
+}
+
+const std::string diagnostic_manager_t::get_bus_device_name() const
+{
+       return configuration_t::instance().get_can_bus_manager()
+               .get_can_device_name(bus_);
+}
+
 active_diagnostic_request_t* diagnostic_manager_t::get_last_recurring_requests() const
 {
        return recurring_requests_.back();
@@ -211,6 +214,16 @@ DiagnosticShims& diagnostic_manager_t::get_shims()
        return shims_;
 }
 
+bool diagnostic_manager_t::socket_close()
+{
+       if(non_recurring_requests_.empty() && recurring_requests_.empty())
+       {
+               socket_.close();
+               return true;
+       }
+       return false;
+}
+
 /// @brief Search for a specific active diagnostic request in the provided requests list
 /// and erase it from the vector. This is useful at unsubscription to clean up the list otherwize
 /// all received CAN messages will be passed to DiagnosticRequestHandle of all active diagnostic request
@@ -228,23 +241,9 @@ void diagnostic_manager_t::find_and_erase(active_diagnostic_request_t* entry, st
 // @brief TODO: implement cancel_request if needed... Don't know.
 void diagnostic_manager_t::cancel_request(active_diagnostic_request_t* entry)
 {
-
-       /* TODO: implement acceptance filters.
-       if(entry.arbitration_id_ == OBD2_FUNCTIONAL_BROADCAST_ID) {
-               for(uint32_t filter = OBD2_FUNCTIONAL_RESPONSE_START;
-                               filter < OBD2_FUNCTIONAL_RESPONSE_START +
-                                       OBD2_FUNCTIONAL_RESPONSE_COUNT;
-                               filter++) {
-                       removeAcceptanceFilter(entry.bus_, filter,
-                                       CanMessageFormat::STANDARD, getCanBuses(),
-                                       getCanBusCount());
-               }
-       } else {
-               removeAcceptanceFilter(entry.bus_,
-                               entry.arbitration_id_ +
-                                       DIAGNOSTIC_RESPONSE_ARBITRATION_ID_OFFSET,
-                               CanMessageFormat::STANDARD, getCanBuses(), getCanBusCount());
-       }*/
+       entry->get_socket().close();
+       delete entry;
+       entry = nullptr;
 }
 
 /// @brief Cleanup a specific request if it isn't running and get complete. As it is almost
@@ -255,25 +254,24 @@ void diagnostic_manager_t::cancel_request(active_diagnostic_request_t* entry)
 /// @param[in] force - Force the cleaning or not ?
 void diagnostic_manager_t::cleanup_request(active_diagnostic_request_t* entry, bool force)
 {
-       if((force || (entry != nullptr && entry->get_in_flight() && entry->request_completed())))
+       if((force || (entry != nullptr && entry->response_received())))
        {
-               entry->set_in_flight(false);
-
                char request_string[128] = {0};
                diagnostic_request_to_string(&entry->get_handle()->request,
                        request_string, sizeof(request_string));
                if(force && entry->get_recurring())
                {
-                       find_and_erase(entry, recurring_requests_);
                        cancel_request(entry);
+                       find_and_erase(entry, recurring_requests_);
                        DEBUG(binder_interface, "%s: Cancelling completed, recurring request: %s", __FUNCTION__, request_string);
                }
-               else
+               else if (!entry->get_recurring())
                {
                        DEBUG(binder_interface, "%s: Cancelling completed, non-recurring request: %s", __FUNCTION__, request_string);
-                       find_and_erase(entry, non_recurring_requests_);
                        cancel_request(entry);
+                       find_and_erase(entry, non_recurring_requests_);
                }
+               socket_close();
        }
 }
 
@@ -284,12 +282,17 @@ void diagnostic_manager_t::cleanup_request(active_diagnostic_request_t* entry, b
 void diagnostic_manager_t::cleanup_active_requests(bool force)
 {
        for(auto& entry : non_recurring_requests_)
+       {
                if (entry != nullptr)
                        cleanup_request(entry, force);
+       }
 
        for(auto& entry : recurring_requests_)
+        {
                if (entry != nullptr)
                        cleanup_request(entry, force);
+        }
+
 }
 
 /// @brief Will return the active_diagnostic_request_t pointer for theDiagnosticRequest or nullptr if
@@ -304,10 +307,7 @@ active_diagnostic_request_t* diagnostic_manager_t::find_recurring_request(const
                if(entry != nullptr)
                {
                        if(diagnostic_request_equals(&entry->get_handle()->request, request))
-                       {
-                               return entry;
-                               break;
-                       }
+                               {return entry;}
                }
        }
        return nullptr;
@@ -339,7 +339,7 @@ active_diagnostic_request_t* diagnostic_manager_t::find_recurring_request(const
 /// @return true if the request was added successfully. Returns false if there
 /// wasn't a free active request entry, if the frequency was too high or if the
 /// CAN acceptance filters could not be configured,
-active_diagnostic_request_t* diagnostic_manager_t::add_request(DiagnosticRequest* request, const std::string name,
+active_diagnostic_request_t* diagnostic_manager_t::add_request(DiagnosticRequest* request, const std::string& name,
        bool wait_for_multiple_responses, const DiagnosticResponseDecoder decoder,
        const DiagnosticResponseCallback callback)
 {
@@ -452,15 +452,28 @@ active_diagnostic_request_t* diagnostic_manager_t::add_recurring_request(Diagnos
                {
                        // TODO: implement Acceptance Filter
                        //if(updateRequiredAcceptanceFilters(bus, request)) {
-                       active_diagnostic_request_t* entry = new active_diagnostic_request_t(bus_, request, name,
+                       entry = new active_diagnostic_request_t(bus_, request, name,
                                        wait_for_multiple_responses, decoder, callback, frequencyHz);
                        recurring_requests_.push_back(entry);
 
                        entry->set_handle(shims_, request);
                        if(add_rx_filter(OBD2_FUNCTIONAL_BROADCAST_ID) < 0)
-                       { recurring_requests_.pop_back(); }
+                               { recurring_requests_.pop_back(); }
                        else
-                       { start_diagnostic_request(&shims_, entry->get_handle()); }
+                               {
+                                       start_diagnostic_request(&shims_, entry->get_handle()); 
+                                       if(event_source_ == nullptr && sd_event_add_io(afb_daemon_get_event_loop(binder_interface->daemon), 
+                                               &event_source_,
+                                               socket_.socket(),
+                                               EPOLLIN,
+                                               read_message,
+                                               nullptr) < 0)
+                                       {
+                                               cleanup_request(entry, true);
+                                               WARNING(binder_interface, "%s: signal: %s isn't supported. Canceling operation.", __FUNCTION__, entry->get_name().c_str());
+                                               return entry;
+                                       }
+                               }
                }
                else
                {
@@ -469,45 +482,10 @@ active_diagnostic_request_t* diagnostic_manager_t::add_recurring_request(Diagnos
                }
        }
        else
-       { DEBUG(binder_interface, "%s: Can't add request, one already exists with same key", __FUNCTION__);}
+               { DEBUG(binder_interface, "%s: Can't add request, one already exists with same key", __FUNCTION__);}
        return entry;
 }
 
-/// @brief Returns true if there are two active requests running for the same arbitration ID.
-bool diagnostic_manager_t::conflicting(active_diagnostic_request_t* request, active_diagnostic_request_t* candidate) const
-{
-       return (candidate->get_in_flight() && candidate != request &&
-                       candidate->get_can_bus_dev() == request->get_can_bus_dev() &&
-                       candidate->get_id() == request->get_id());
-}
-
-
-/// @brief Returns true if there are no other active requests to the same arbitration ID
-/// and if there aren't more than 8 requests in flight at the same time.
-bool diagnostic_manager_t::clear_to_send(active_diagnostic_request_t* request) const
-{
-       int total_in_flight = 0;
-       for ( auto entry : non_recurring_requests_)
-       {
-               if(conflicting(request, entry))
-                       return false;
-               if(entry->get_in_flight())
-                       total_in_flight++;
-       }
-
-       for ( auto entry : recurring_requests_)
-       {
-               if(conflicting(request, entry))
-                       return false;
-               if(entry->get_in_flight())
-                       total_in_flight++;
-       }
-
-       if(total_in_flight > MAX_SIMULTANEOUS_IN_FLIGHT_REQUESTS)
-               return false;
-       return true;
-}
-
 /// @brief Will decode the diagnostic response and build the final openxc_VehicleMessage to return.
 ///
 /// @param[in] adr - A pointer to an active diagnostic request holding a valid diagnostic handle
@@ -523,7 +501,7 @@ openxc_VehicleMessage diagnostic_manager_t::relay_diagnostic_response(active_dia
                value = adr->get_decoder()(&response, value);
        }
 
-       if((response.success && strnlen(adr->get_name().c_str(), adr->get_name().size())) > 0)
+       if((response.success && adr->get_name().size()) > 0)
        {
                // If name, include 'value' instead of payload, and leave of response
                // details.
@@ -555,7 +533,7 @@ openxc_VehicleMessage diagnostic_manager_t::relay_diagnostic_response(active_dia
        }
 
        // Reset the completed flag handle to make sure that it will be reprocessed the next time.
-       adr->get_handle()->completed = false;
+       adr->get_handle()->success = false;
        return message;
 }
 
@@ -578,7 +556,8 @@ openxc_VehicleMessage diagnostic_manager_t::relay_diagnostic_handle(active_diagn
        else if(!response.completed && response.multi_frame)
        {
                // Reset the timeout clock while completing the multi-frame receive
-               entry->get_timeout_clock().tick();
+               entry->get_timeout_clock().tick(
+                       entry->get_timeout_clock().get_time_function()());
        }
 
        return build_VehicleMessage();