native/can: fix CAN init

Native CAN device was not properly ported to periph_can interface.
This commit fixes this by renaming all needed structures and files so
auto_init_can can initialize the native device. FEATURES_PROVIDED is
also updated for native.
This commit is contained in:
Vincent Dupont 2020-09-04 10:41:56 +02:00
parent 98c39d5104
commit b4f29035ce
11 changed files with 38 additions and 92 deletions

View File

@ -51,6 +51,7 @@ config NATIVE_OS_DARWIN
config NATIVE_OS_LINUX config NATIVE_OS_LINUX
bool bool
select HAS_PERIPH_CAN
select HAS_PERIPH_GPIO select HAS_PERIPH_GPIO
select HAS_PERIPH_GPIO_IRQ select HAS_PERIPH_GPIO_IRQ
select HAS_PERIPH_SPI select HAS_PERIPH_SPI

View File

@ -22,4 +22,6 @@ ifeq ($(OS),Linux)
FEATURES_PROVIDED += periph_spi FEATURES_PROVIDED += periph_spi
# Hardware GPIO access is only available on Linux hosts # Hardware GPIO access is only available on Linux hosts
FEATURES_PROVIDED += periph_gpio periph_gpio_irq FEATURES_PROVIDED += periph_gpio periph_gpio_irq
# CAN is only supported on Linux through socketCAN
FEATURES_PROVIDED += periph_can
endif endif

View File

@ -16,8 +16,8 @@
* @author Vincent Dupont <vincent@otakeys.com> * @author Vincent Dupont <vincent@otakeys.com>
*/ */
#ifndef CANDEV_LINUX_PARAMS_H #ifndef CAN_PARAMS_H
#define CANDEV_LINUX_PARAMS_H #define CAN_PARAMS_H
#include "candev_linux.h" #include "candev_linux.h"
#include "can/device.h" #include "can/device.h"
@ -29,7 +29,7 @@ extern "C" {
/** /**
* @brief Default parameters (device names) * @brief Default parameters (device names)
*/ */
static candev_params_t candev_linux_params[] = { static const candev_params_t candev_params[] = {
{ .name = "can0", }, { .name = "can0", },
{ .name = "can1", }, { .name = "can1", },
}; };
@ -38,5 +38,5 @@ static candev_params_t candev_linux_params[] = {
} }
#endif #endif
#endif /* CANDEV_LINUX_PARAMS_H */ #endif /* CAN_PARAMS_H */
/** @} */ /** @} */

View File

@ -42,10 +42,13 @@ extern "C" {
/** /**
* Linux candev configuration * Linux candev configuration
*/ */
typedef struct candev_linux_conf { typedef struct candev_conf {
/** local interface name */ /** local interface name */
char interface_name[CAN_MAX_SIZE_INTERFACE_NAME + 1]; char interface_name[CAN_MAX_SIZE_INTERFACE_NAME + 1];
} candev_linux_conf_t; } can_conf_t;
/** CAN device configuration type can_conf_t is redefined by native CAN */
#define HAVE_CAN_CONF_T
#ifndef CANDEV_LINUX_MAX_FILTERS_RX #ifndef CANDEV_LINUX_MAX_FILTERS_RX
/** /**
@ -74,25 +77,18 @@ typedef struct candev_linux_conf {
typedef struct candev_linux { typedef struct candev_linux {
candev_t candev; /**< candev base structure */ candev_t candev; /**< candev base structure */
int sock; /**< local socket id */ int sock; /**< local socket id */
const candev_linux_conf_t *conf; /**< device configuration */ const can_conf_t *conf; /**< device configuration */
/** filter list */ /** filter list */
struct can_filter filters[CANDEV_LINUX_MAX_FILTERS_RX]; struct can_filter filters[CANDEV_LINUX_MAX_FILTERS_RX];
} candev_linux_t; } can_t;
/** /** CAN device type can_t is redefined by native CAN */
* @brief Device specific initialization function #define HAVE_CAN_T
*
* @param[inout] dev the device to initialize
* @param[in] conf the device configuration
*
* @return 0 on success
*/
int candev_linux_init(candev_linux_t *dev, const candev_linux_conf_t *conf);
/** /**
* @brief Array containing socketCAN device names * @brief Array containing socketCAN device names
*/ */
extern candev_linux_conf_t candev_linux_conf[CAN_DLL_NUMOF]; extern can_conf_t candev_conf[CAN_DLL_NUMOF];
#endif /* defined(__linux__) */ #endif /* defined(__linux__) */

View File

@ -156,6 +156,10 @@ typedef enum {
#endif #endif
/** @} */ /** @} */
#ifdef MODULE_PERIPH_CAN
#include "candev_linux.h"
#endif
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif

View File

@ -53,7 +53,7 @@ static int _remove_filter(candev_t *candev, const struct can_filter *filter);
static int _power_up(candev_t *candev); static int _power_up(candev_t *candev);
static int _power_down(candev_t *candev); static int _power_down(candev_t *candev);
static int _set_bittiming(candev_linux_t *dev, struct can_bittiming *bittiming); static int _set_bittiming(can_t *dev, struct can_bittiming *bittiming);
static const candev_driver_t candev_linux_driver = { static const candev_driver_t candev_linux_driver = {
.send = _send, .send = _send,
@ -69,7 +69,7 @@ static const candev_driver_t candev_linux_driver = {
static candev_event_t _can_error_to_can_evt(struct can_frame can_frame_err); static candev_event_t _can_error_to_can_evt(struct can_frame can_frame_err);
static void _callback_can_sigio(int sock, void *arg); static void _callback_can_sigio(int sock, void *arg);
candev_linux_conf_t candev_linux_conf[CAN_DLL_NUMOF] = { can_conf_t candev_conf[CAN_DLL_NUMOF] = {
#if CAN_DLL_NUMOF >= 1 #if CAN_DLL_NUMOF >= 1
{ {
.interface_name = "vcan0", .interface_name = "vcan0",
@ -82,9 +82,9 @@ candev_linux_conf_t candev_linux_conf[CAN_DLL_NUMOF] = {
#endif #endif
}; };
int candev_linux_init(candev_linux_t *dev, const candev_linux_conf_t *conf) int can_init(can_t *dev, const can_conf_t *conf)
{ {
memset(dev, 0, sizeof(candev_linux_t)); memset(dev, 0, sizeof(can_t));
dev->candev.driver = &candev_linux_driver; dev->candev.driver = &candev_linux_driver;
dev->conf = conf; dev->conf = conf;
dev->candev.bittiming.bitrate = CANDEV_LINUX_DEFAULT_BITRATE; dev->candev.bittiming.bitrate = CANDEV_LINUX_DEFAULT_BITRATE;
@ -129,7 +129,7 @@ static candev_event_t _can_error_to_can_evt(struct can_frame can_frame_err)
static void _callback_can_sigio(int sockfd, void *arg) static void _callback_can_sigio(int sockfd, void *arg)
{ {
(void) sockfd; (void) sockfd;
candev_linux_t *dev = (candev_linux_t *) arg; can_t *dev = (can_t *) arg;
if (dev->candev.event_callback) { if (dev->candev.event_callback) {
dev->candev.event_callback(&dev->candev, CANDEV_EVENT_ISR, NULL); dev->candev.event_callback(&dev->candev, CANDEV_EVENT_ISR, NULL);
@ -149,7 +149,7 @@ static int _init(candev_t *candev)
int ret; int ret;
DEBUG("Will start linux CAN init\n"); DEBUG("Will start linux CAN init\n");
candev_linux_t *dev = (candev_linux_t *)candev; can_t *dev = (can_t *)candev;
if ((strlen(dev->conf->interface_name) == 0) if ((strlen(dev->conf->interface_name) == 0)
|| (strlen(dev->conf->interface_name) > CAN_MAX_SIZE_INTERFACE_NAME)) { || (strlen(dev->conf->interface_name) > CAN_MAX_SIZE_INTERFACE_NAME)) {
@ -212,7 +212,7 @@ static int _init(candev_t *candev)
static int _send(candev_t *candev, const struct can_frame *frame) static int _send(candev_t *candev, const struct can_frame *frame)
{ {
int nbytes; int nbytes;
candev_linux_t *dev = (candev_linux_t *)candev; can_t *dev = (can_t *)candev;
nbytes = real_write(dev->sock, frame, sizeof(struct can_frame)); nbytes = real_write(dev->sock, frame, sizeof(struct can_frame));
@ -232,7 +232,7 @@ static void _isr(candev_t *candev)
{ {
int nbytes; int nbytes;
struct can_frame rcv_frame; struct can_frame rcv_frame;
candev_linux_t *dev = (candev_linux_t *)candev; can_t *dev = (can_t *)candev;
if (dev == NULL) { if (dev == NULL) {
return; return;
@ -272,7 +272,7 @@ static void _isr(candev_t *candev)
} }
static int _set_bittiming(candev_linux_t *dev, struct can_bittiming *bittiming) static int _set_bittiming(can_t *dev, struct can_bittiming *bittiming)
{ {
int res; int res;
@ -300,7 +300,7 @@ static int _set_bittiming(candev_linux_t *dev, struct can_bittiming *bittiming)
static int _set(candev_t *candev, canopt_t opt, void *value, size_t value_len) static int _set(candev_t *candev, canopt_t opt, void *value, size_t value_len)
{ {
candev_linux_t *dev = (candev_linux_t *) candev; can_t *dev = (can_t *) candev;
int res = 0; int res = 0;
switch (opt) { switch (opt) {
@ -349,7 +349,7 @@ static int _set(candev_t *candev, canopt_t opt, void *value, size_t value_len)
static int _get(candev_t *candev, canopt_t opt, void *value, size_t max_len) static int _get(candev_t *candev, canopt_t opt, void *value, size_t max_len)
{ {
candev_linux_t *dev = (candev_linux_t *) candev; can_t *dev = (can_t *) candev;
int res = 0; int res = 0;
switch (opt) { switch (opt) {
@ -456,7 +456,7 @@ static int _get(candev_t *candev, canopt_t opt, void *value, size_t max_len)
static int _set_filter(candev_t *candev, const struct can_filter *filter) static int _set_filter(candev_t *candev, const struct can_filter *filter)
{ {
candev_linux_t *dev = (candev_linux_t *)candev; can_t *dev = (can_t *)candev;
if (filter == NULL) { if (filter == NULL) {
DEBUG("candev_native: _set_filter: error filter NULL\n"); DEBUG("candev_native: _set_filter: error filter NULL\n");
@ -500,7 +500,7 @@ static int _set_filter(candev_t *candev, const struct can_filter *filter)
static int _remove_filter(candev_t *candev, const struct can_filter *filter) static int _remove_filter(candev_t *candev, const struct can_filter *filter)
{ {
candev_linux_t *dev = (candev_linux_t *)candev; can_t *dev = (can_t *)candev;
if (filter == NULL) { if (filter == NULL) {
DEBUG("candev_native: _remove_filter: error filter NULL\n"); DEBUG("candev_native: _remove_filter: error filter NULL\n");

View File

@ -515,7 +515,7 @@ __attribute__((constructor)) static void startup(int argc, char **argv, char **e
usage_exit(EXIT_FAILURE); usage_exit(EXIT_FAILURE);
} }
optarg++; optarg++;
strncpy(candev_linux_conf[i].interface_name, optarg, strncpy(candev_conf[i].interface_name, optarg,
CAN_MAX_SIZE_INTERFACE_NAME); CAN_MAX_SIZE_INTERFACE_NAME);
} }
break; break;

View File

@ -1,53 +0,0 @@
/*
* Copyright (C) 2016 OTA keys S.A.
*
* This file is subject to the terms and conditions of the GNU Lesser
* General Public License v2.1. See the file LICENSE in the top level
* directory for more details.
*/
/**
* @ingroup sys_auto_init
* @{
* @file
* @brief initializes native can device
*
* @author Vincent Dupont <vincent@otakeys.com>
* @}
*/
#include "can/device.h"
#include "candev_linux_params.h"
#define CANDEV_LINUX_NUMOF ARRAY_SIZE(candev_linux_params)
#ifndef CANDEV_LINUX_STACKSIZE
#define CANDEV_LINUX_STACKSIZE (THREAD_STACKSIZE_DEFAULT + THREAD_EXTRA_STACKSIZE_PRINTF)
#endif
#ifndef CANDEV_LINUX_BASE_PRIORITY
#define CANDEV_LINUX_BASE_PRIORITY (THREAD_PRIORITY_MAIN - CANDEV_LINUX_NUMOF - 2)
#endif
static candev_dev_t candev_dev_linux[CANDEV_LINUX_NUMOF];
static char _can_linux_stacks[CANDEV_LINUX_NUMOF][CANDEV_LINUX_STACKSIZE];
static candev_linux_t candev_linux[CANDEV_LINUX_NUMOF];
void auto_init_can_native(void) {
for (size_t i = 0; i < CANDEV_LINUX_NUMOF; i++) {
candev_linux_init(&candev_linux[i], &candev_linux_conf[i]);
candev_dev_linux[i].dev = (candev_t *)&candev_linux[i];
candev_dev_linux[i].name = candev_linux_params[i].name;
#ifdef MODULE_CAN_TRX
candev_dev_linux[i].trx = candev_linux_params[i].trx;
#endif
#ifdef MODULE_CAN_PM
candev_dev_linux[i].rx_inactivity_timeout = candev_linux_params[i].rx_inactivity_timeout;
candev_dev_linux[i].tx_wakeup_timeout = candev_linux_params[i].tx_wakeup_timeout;
#endif
can_device_init(_can_linux_stacks[i], CANDEV_LINUX_STACKSIZE, CANDEV_LINUX_BASE_PRIORITY + i,
candev_linux_params[i].name, &candev_dev_linux[i]);
}
}

View File

@ -16,6 +16,7 @@
* @} * @}
*/ */
#include "periph/can.h"
#include "can/device.h" #include "can/device.h"
#include "can_params.h" #include "can_params.h"

View File

@ -49,11 +49,6 @@ void auto_init_candev(void)
isotp_init(isotp_stack, ISOTP_STACK_SIZE, ISOTP_PRIORITY, "isotp"); isotp_init(isotp_stack, ISOTP_STACK_SIZE, ISOTP_PRIORITY, "isotp");
#endif #endif
#ifdef MODULE_CAN_LINUX
extern void auto_init_can_native(void);
auto_init_can_native();
#endif
#ifdef MODULE_PERIPH_CAN #ifdef MODULE_PERIPH_CAN
extern void auto_init_periph_can(void); extern void auto_init_periph_can(void);
auto_init_periph_can(); auto_init_periph_can();

View File

@ -34,7 +34,7 @@
#include <candev_linux.h> #include <candev_linux.h>
static candev_linux_t linux_dev; static can_t linux_dev;
#else #else
/* add other candev drivers here */ /* add other candev drivers here */
@ -194,7 +194,7 @@ int main(void)
isrpipe_init(&rxbuf, (uint8_t *)rx_ringbuf, sizeof(rx_ringbuf)); isrpipe_init(&rxbuf, (uint8_t *)rx_ringbuf, sizeof(rx_ringbuf));
#if IS_USED(MODULE_CAN_LINUX) #if IS_USED(MODULE_CAN_LINUX)
puts("Initializing Linux Can device"); puts("Initializing Linux Can device");
candev_linux_init( &linux_dev, &(candev_linux_conf[0])); /* vcan0 */ can_init( &linux_dev, &(candev_conf[0])); /* vcan0 */
candev = (candev_t *)&linux_dev; candev = (candev_t *)&linux_dev;
#else #else
/* add initialization for other candev drivers here */ /* add initialization for other candev drivers here */