From 2fc26a117842428f4148621361c53082ac93722f Mon Sep 17 00:00:00 2001 From: Romain Forlot Date: Mon, 13 Feb 2017 23:26:58 +0000 Subject: New threads management, only one argument needed. Now CanBus_c object is the main core part to handle queues and to follow CAN bus reading process. Change-Id: I33cdfadb06362da4330a572caa1c1cf61d3ab3fd Signed-off-by: Romain Forlot --- can_decoder.cpp | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) (limited to 'can_decoder.cpp') diff --git a/can_decoder.cpp b/can_decoder.cpp index 74694c9..5de6eda 100644 --- a/can_decoder.cpp +++ b/can_decoder.cpp @@ -7,7 +7,7 @@ * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, @@ -25,16 +25,16 @@ #include "can-utils.h" #include "openxc.pb.h" -void decode_can_message(afb_binding_interface *interface, std::queue & can_message_q, std::queue & VehicleMessage_q) +void decode_can_message(CanBus_c *can_bus) { - canfd_frame canfd_frame; + CanMessage_c can_message; - while(true) - { - if(! canfd_frame_queue.empty()) - { - canfd_frame = canfd_frame_queue.front(); - canfd_frame_queue.pop(); - } - } + while(true) + { + if(! can_bus->can_message_q.empty()) + { + can_message = can_bus->can_message_q.front(); + can_bus->can_message_q.pop(); + } + } } -- cgit