From 9519e9d5b875b45fbf6f32267b728b1d11377276 Mon Sep 17 00:00:00 2001 From: Loïc Collignon Date: Wed, 8 Mar 2017 14:47:38 +0100 Subject: separation of can_bus_t and can_bus_dev_t and use of the new socket class. MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Change-Id: I5f292ab18737fa48259f357d660fed27fb8fb4be Signed-off-by: Loïc Collignon --- src/can/can-bus-dev.hpp | 60 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 src/can/can-bus-dev.hpp (limited to 'src/can/can-bus-dev.hpp') diff --git a/src/can/can-bus-dev.hpp b/src/can/can-bus-dev.hpp new file mode 100644 index 0000000..83a1b30 --- /dev/null +++ b/src/can/can-bus-dev.hpp @@ -0,0 +1,60 @@ +/* + * Copyright (C) 2015, 2016, 2017 "IoT.bzh" + * Author "Romain Forlot" + * Author "Loïc Collignon" + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * 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 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#pragma once + +#include +#include +#include + +#include "../utils/socket.hpp" + +class can_bus_t; +class can_message_t; + +/// @brief Object representing a can device. Handle opening, closing and reading on the +/// socket. This is the low level object to be use by can_bus_t. +class can_bus_dev_t +{ +private: + std::string device_name_; + utils::socket_t can_socket_; + + int32_t id_; /// < an identifier used through binding that refer to that device + + bool is_fdmode_on_; /// < boolean telling if whether or not the can socket use fdmode. + struct sockaddr_can txAddress_; /// < internal member using to bind to the socket + + std::thread th_reading_; /// < Thread handling read the socket can device filling can_message_q_ queue of can_bus_t + bool is_running_; /// < boolean telling whether or not reading is running or not + void can_reader(can_bus_t& can_bus); + +public: + can_bus_dev_t(const std::string& dev_name); + + int open(); + int close(); + + void start_reading(can_bus_t& can_bus); + + void stop_reading(); + + std::pair read(); + + int send_can_message(can_message_t& can_msg); +}; -- cgit 1.2.3-korg