mirror of https://github.com/ArduPilot/ardupilot
247 lines
7.7 KiB
C++
247 lines
7.7 KiB
C++
/*
|
|
* The MIT License (MIT)
|
|
*
|
|
* Copyright (c) 2014 Pavel Kirienko
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy of
|
|
* this software and associated documentation files (the "Software"), to deal in
|
|
* the Software without restriction, including without limitation the rights to
|
|
* use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
|
|
* the Software, and to permit persons to whom the Software is furnished to do so,
|
|
* subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in all
|
|
* copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
|
|
* FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
|
|
* COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
|
|
* IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|
*/
|
|
|
|
/*
|
|
* This file is free software: you can redistribute it and/or modify it
|
|
* under the terms of the GNU General Public License as published by the
|
|
* Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This file is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
* See the GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along
|
|
* with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* Code by Siddharth Bharat Purohit
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include "AP_HAL_ChibiOS.h"
|
|
#include "EventSource.h"
|
|
|
|
#if HAL_NUM_CAN_IFACES
|
|
|
|
#ifndef HAL_CAN_RX_QUEUE_SIZE
|
|
#define HAL_CAN_RX_QUEUE_SIZE 128
|
|
#endif
|
|
|
|
static_assert(HAL_CAN_RX_QUEUE_SIZE <= 254, "Invalid CAN Rx queue size");
|
|
|
|
/**
|
|
* Single CAN iface.
|
|
*/
|
|
class ChibiOS::CANIface : public AP_HAL::CANIface
|
|
{
|
|
static constexpr unsigned long IDE = (0x40000000U); // Identifier Extension
|
|
static constexpr unsigned long STID_MASK = (0x1FFC0000U); // Standard Identifier Mask
|
|
static constexpr unsigned long EXID_MASK = (0x1FFFFFFFU); // Extended Identifier Mask
|
|
static constexpr unsigned long RTR = (0x20000000U); // Remote Transmission Request
|
|
static constexpr unsigned long DLC_MASK = (0x000F0000U); // Data Length Code
|
|
|
|
/**
|
|
* CANx register sets
|
|
*/
|
|
typedef FDCAN_GlobalTypeDef CanType;
|
|
|
|
struct CriticalSectionLocker {
|
|
CriticalSectionLocker()
|
|
{
|
|
chSysSuspend();
|
|
}
|
|
~CriticalSectionLocker()
|
|
{
|
|
chSysEnable();
|
|
}
|
|
};
|
|
|
|
struct MessageRAM {
|
|
uint32_t StandardFilterSA;
|
|
uint32_t ExtendedFilterSA;
|
|
uint32_t RxFIFO0SA;
|
|
uint32_t RxFIFO1SA;
|
|
uint32_t TxFIFOQSA;
|
|
uint32_t EndAddress;
|
|
} MessageRam_;
|
|
|
|
struct Timings {
|
|
uint16_t prescaler;
|
|
uint8_t sjw;
|
|
uint8_t bs1;
|
|
uint8_t bs2;
|
|
|
|
Timings()
|
|
: prescaler(0)
|
|
, sjw(0)
|
|
, bs1(0)
|
|
, bs2(0)
|
|
{ }
|
|
};
|
|
|
|
enum { NumTxMailboxes = 32 };
|
|
|
|
static uint32_t FDCANMessageRAMOffset_;
|
|
|
|
CanType* can_;
|
|
|
|
CanRxItem rx_buffer[HAL_CAN_RX_QUEUE_SIZE];
|
|
ByteBuffer rx_bytebuffer_;
|
|
ObjectBuffer<CanRxItem> rx_queue_;
|
|
CanTxItem pending_tx_[NumTxMailboxes];
|
|
uint8_t peak_tx_mailbox_index_;
|
|
bool irq_init_;
|
|
bool initialised_;
|
|
bool had_activity_;
|
|
AP_HAL::EventHandle* event_handle_;
|
|
#if !defined(HAL_BUILD_AP_PERIPH) && !defined(HAL_BOOTLOADER_BUILD)
|
|
static ChibiOS::EventSource evt_src_;
|
|
#endif
|
|
const uint8_t self_index_;
|
|
|
|
bool computeTimings(uint32_t target_bitrate, Timings& out_timings);
|
|
|
|
void setupMessageRam(void);
|
|
|
|
bool readRxFIFO(uint8_t fifo_index);
|
|
|
|
void discardTimedOutTxMailboxes(uint64_t current_time);
|
|
|
|
bool canAcceptNewTxFrame() const;
|
|
|
|
bool isRxBufferEmpty() const;
|
|
|
|
bool recover_from_busoff();
|
|
|
|
void pollErrorFlags();
|
|
|
|
void checkAvailable(bool& read, bool& write,
|
|
const AP_HAL::CANFrame* pending_tx) const;
|
|
|
|
// Reset the error states like Bus Off Error
|
|
void clearErrors();
|
|
|
|
static uint32_t FDCAN2MessageRAMOffset_;
|
|
static bool clock_init_;
|
|
|
|
bool _detected_bus_off;
|
|
|
|
struct {
|
|
uint32_t tx_requests;
|
|
uint32_t tx_rejected;
|
|
uint32_t tx_success;
|
|
uint32_t tx_timedout;
|
|
uint32_t tx_abort;
|
|
uint32_t rx_received;
|
|
uint32_t rx_overflow;
|
|
uint32_t rx_errors;
|
|
uint32_t num_busoff_err;
|
|
uint32_t num_events;
|
|
} stats;
|
|
|
|
public:
|
|
/******************************************
|
|
* Common CAN methods *
|
|
* ****************************************/
|
|
CANIface(uint8_t index);
|
|
|
|
// Initialise CAN Peripheral
|
|
bool init(const uint32_t bitrate, const OperatingMode mode) override;
|
|
|
|
// Put frame into Tx FIFO returns negative on error, 0 on buffer full,
|
|
// 1 on successfully pushing a frame into FIFO
|
|
int16_t send(const AP_HAL::CANFrame& frame, uint64_t tx_deadline,
|
|
CanIOFlags flags) override;
|
|
|
|
// Receive frame from Rx Buffer, returns negative on error, 0 on nothing available,
|
|
// 1 on successfully poping a frame
|
|
int16_t receive(AP_HAL::CANFrame& out_frame, uint64_t& out_timestamp_us,
|
|
CanIOFlags& out_flags) override;
|
|
|
|
// Set Filters to ignore frames not to be handled by us
|
|
bool configureFilters(const CanFilterConfig* filter_configs,
|
|
uint16_t num_configs) override;
|
|
|
|
// returns true if busoff state was detected and not handled yet
|
|
bool is_busoff() const override
|
|
{
|
|
return _detected_bus_off;
|
|
}
|
|
|
|
// Clear the Rx buffer
|
|
void clear_rx() override;
|
|
|
|
// Get number of Filter configurations
|
|
uint16_t getNumFilters() const override;
|
|
|
|
// Get total number of Errors discovered
|
|
uint32_t getErrorCount() const override;
|
|
|
|
// returns true if init was successfully called
|
|
bool is_initialized() const override
|
|
{
|
|
return initialised_;
|
|
}
|
|
|
|
/******************************************
|
|
* Select Method *
|
|
* ****************************************/
|
|
// wait until selected event is available, false when timed out waiting else true
|
|
bool select(bool &read, bool &write,
|
|
const AP_HAL::CANFrame* const pending_tx,
|
|
uint64_t blocking_deadline) override;
|
|
|
|
#if !defined(HAL_BUILD_AP_PERIPH) && !defined(HAL_BOOTLOADER_BUILD)
|
|
// setup event handle for waiting on events
|
|
bool set_event_handle(AP_HAL::EventHandle* handle) override;
|
|
|
|
// fetch stats text and return the size of the same,
|
|
// results available via @SYS/can0_stats.txt or @SYS/can1_stats.txt
|
|
uint32_t get_stats(char* data, uint32_t max_size) override;
|
|
#endif
|
|
/************************************
|
|
* Methods used inside interrupt *
|
|
************************************/
|
|
void handleTxCompleteInterrupt(uint64_t timestamp_us);
|
|
void handleRxInterrupt(uint8_t fifo_index);
|
|
void handleBusOffInterrupt();
|
|
|
|
// handle if any error occured, and do the needful such as,
|
|
// droping the frame, and counting errors
|
|
void pollErrorFlagsFromISR(void);
|
|
|
|
// CAN Peripheral register structure
|
|
static constexpr CanType* const Can[HAL_NUM_CAN_IFACES] = {
|
|
reinterpret_cast<CanType*>(FDCAN1_BASE)
|
|
#if HAL_NUM_CAN_IFACES > 1
|
|
,
|
|
reinterpret_cast<CanType*>(FDCAN2_BASE)
|
|
#endif
|
|
};
|
|
};
|
|
|
|
|
|
#endif //HAL_NUM_CAN_IFACES
|