From 862a59747245529ae2b6039a00b639e747069aae Mon Sep 17 00:00:00 2001 From: Romain Forlot Date: Wed, 31 May 2017 12:08:13 +0200 Subject: Clearer call to method Change-Id: Ibf37a46989ac8d84a56aa43873fdb8bb0e601304 Signed-off-by: Romain Forlot --- CAN-binder/low-can-binding/can/can-bus.cpp | 8 ++++---- CAN-binder/low-can-binding/can/can-bus.hpp | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) (limited to 'CAN-binder') diff --git a/CAN-binder/low-can-binding/can/can-bus.cpp b/CAN-binder/low-can-binding/can/can-bus.cpp index d83ef5d..4113107 100644 --- a/CAN-binder/low-can-binding/can/can-bus.cpp +++ b/CAN-binder/low-can-binding/can/can-bus.cpp @@ -82,8 +82,8 @@ int can_bus_t::process_can_signals(const can_message_t& can_message) openxc_SimpleMessage s_message = build_SimpleMessage(sig->get_sig_name(), decoded_message); vehicle_message = build_VehicleMessage(s_message, can_message.get_timestamp()); - push_new_vehicle_message(std::make_pair(can_message.get_sub_id(), vehicle_message)); std::lock_guard decoded_can_message_lock(decoded_can_message_mutex_); + push_new_vehicle_message(subscription_id, vehicle_message); } processed_signals++; } @@ -116,7 +116,7 @@ int can_bus_t::process_diagnostic_signals(diagnostic_manager_t& manager, const c (s.find(can_message.get_sub_id()) != s.end() && afb_event_is_valid(s[can_message.get_sub_id()].second))) { std::lock_guard decoded_can_message_lock(decoded_can_message_mutex_); - push_new_vehicle_message(std::make_pair(can_message.get_sub_id(), vehicle_message)); + push_new_vehicle_message(can_message.get_sub_id(), vehicle_message); processed_signals++; } } @@ -277,9 +277,9 @@ std::pair can_bus_t::next_vehicle_message() /// @brief Push a openxc_VehicleMessage into the queue /// /// @param[in] v_msg - const reference openxc_VehicleMessage object to push into the queue -void can_bus_t::push_new_vehicle_message(const std::pair& v_msg) +void can_bus_t::push_new_vehicle_message(int subscription_id, const openxc_VehicleMessage& v_msg) { - vehicle_message_q_.push(v_msg); + vehicle_message_q_.push(std::make_pair(subscription_id, v_msg)); } /// @brief Return the shared pointer on the can_bus_dev_t initialized diff --git a/CAN-binder/low-can-binding/can/can-bus.hpp b/CAN-binder/low-can-binding/can/can-bus.hpp index 934b45d..1d064b2 100644 --- a/CAN-binder/low-can-binding/can/can-bus.hpp +++ b/CAN-binder/low-can-binding/can/can-bus.hpp @@ -88,5 +88,5 @@ public: std::condition_variable& get_new_can_message_cv(); std::pair next_vehicle_message(); - void push_new_vehicle_message(const std::pair& v_msg); + void push_new_vehicle_message(int subscription_id, const openxc_VehicleMessage& v_msg); }; -- cgit 1.2.3-korg