3#include "ch32_usbcan_shared.hpp"
9#if defined(CAN1) && !defined(CAN2)
10static void can1_rx0_thunk()
14 can->ProcessRxInterrupt();
18static void can1_tx_thunk()
22 can->ProcessTxInterrupt();
27static inline uint8_t ch32_can_mode_macro(
const CAN::Mode& m)
31 return CAN_Mode_Silent_LoopBack;
35 return CAN_Mode_LoopBack;
39 return CAN_Mode_Silent;
41 return CAN_Mode_Normal;
44static inline void ch32_can_enable_nvic(ch32_can_id_t
id, uint8_t fifo)
52 NVIC_EnableIRQ(USB_HP_CAN1_TX_IRQn);
58 NVIC_EnableIRQ(CAN2_TX_IRQn);
73 NVIC_EnableIRQ(USB_LP_CAN1_RX0_IRQn);
79 NVIC_EnableIRQ(CAN2_RX0_IRQn);
92 NVIC_EnableIRQ(CAN1_RX1_IRQn);
98 NVIC_EnableIRQ(CAN2_RX1_IRQn);
113 NVIC_EnableIRQ(CAN1_SCE_IRQn);
119 NVIC_EnableIRQ(CAN2_SCE_IRQn);
129 :
CAN(), instance_(CH32_CAN_GetInstanceID(id)), id_(id), tx_pool_(pool_size)
131 if constexpr (LibXR::CH32UsbCanShared::usb_can_share_enabled())
133#if defined(CAN1) && !defined(CAN2)
134 const bool USB_ALREADY_INITED =
135 LibXR::CH32UsbCanShared::usb_inited.load(std::memory_order_acquire);
138 ASSERT(USB_ALREADY_INITED ==
false);
146 fifo_ = CAN_FilterFIFO0;
151 fifo_ = CAN_FilterFIFO1;
155 fifo_ = CAN_FilterFIFO0;
158 ASSERT(id_ < CH32_CAN_NUMBER);
159 ASSERT(instance_ !=
nullptr);
165 RCC_APB1PeriphClockCmd(CH32_CAN_RCC_PERIPH_MAP[id_], ENABLE);
169 (void)CAN_OperatingModeRequest(instance_, CAN_OperatingMode_Initialization);
174 CAN_SlaveStartBank(CH32_CAN_DEFAULT_SLAVE_START_BANK);
182 if (instance_ ==
nullptr)
189 CAN_FilterInitTypeDef f = {};
190 f.CAN_FilterIdHigh = 0u;
191 f.CAN_FilterIdLow = 0u;
192 f.CAN_FilterMaskIdHigh = 0u;
193 f.CAN_FilterMaskIdLow = 0u;
194 f.CAN_FilterFIFOAssignment = fifo_;
195 f.CAN_FilterNumber = filter_bank_;
196 f.CAN_FilterMode = CAN_FilterMode_IdMask;
197 f.CAN_FilterScale = CAN_FilterScale_32bit;
198 f.CAN_FilterActivation = ENABLE;
206 ch32_can_enable_nvic(id_, fifo_);
208 if constexpr (LibXR::CH32UsbCanShared::usb_can_share_enabled())
210#if defined(CAN1) && !defined(CAN2)
211 LibXR::CH32UsbCanShared::register_can1_rx0(&can1_rx0_thunk);
212 LibXR::CH32UsbCanShared::register_can1_tx(&can1_tx_thunk);
213 LibXR::CH32UsbCanShared::can1_inited.store(
true, std::memory_order_release);
220void CH32CAN::DisableIRQs()
259 CAN_ITConfig(instance_, it, DISABLE);
263void CH32CAN::EnableIRQs()
304 if ((it & CAN_IT_TME) != 0u)
306 CAN_ClearITPendingBit(instance_, CAN_IT_TME);
311 if (fifo_ == 0u && ((it & CAN_IT_FMP0) != 0u))
313 CAN_ClearITPendingBit(instance_, CAN_IT_FMP0);
317 if (fifo_ == 1u && ((it & CAN_IT_FMP1) != 0u))
319 CAN_ClearITPendingBit(instance_, CAN_IT_FMP1);
323 CAN_ITConfig(instance_, it, ENABLE);
330 auto keep = [&](uint32_t& field, uint32_t cached) ->
bool
344 ok &= keep(dst.
brp, cache.
brp);
348 ok &= keep(dst.
sjw, cache.
sjw);
354 if (instance_ ==
nullptr)
364 explicit IrqGuard(
CH32CAN* s) : self(s) { self->DisableIRQs(); }
365 ~IrqGuard() { self->EnableIRQs(); }
369 bool entered_init =
false;
385 if (bt.
brp < 1u || bt.
brp > 1024u)
393 if (BS1 < 1u || BS1 > 16u)
415 if (CAN_OperatingModeRequest(instance_, CAN_OperatingMode_Initialization) ==
416 CAN_ModeStatus_Failed)
424 CAN_InitTypeDef init;
425 std::memset(&init, 0,
sizeof(init));
426 CAN_StructInit(&init);
428 init.CAN_Prescaler =
static_cast<uint16_t
>(bt.
brp);
429 init.CAN_Mode = ch32_can_mode_macro(cfg.
mode);
431 init.CAN_SJW =
static_cast<uint8_t
>(bt.
sjw - 1u);
432 init.CAN_BS1 =
static_cast<uint8_t
>(BS1 - 1u);
433 init.CAN_BS2 =
static_cast<uint8_t
>(bt.
phase_seg2 - 1u);
441 init.CAN_TTCM = DISABLE;
442 init.CAN_ABOM = ENABLE;
443 init.CAN_AWUM = DISABLE;
444 init.CAN_RFLM = DISABLE;
445 init.CAN_TXFP = ENABLE;
447 if (CAN_Init(instance_, &init) != CAN_InitStatus_Success)
453 if (CAN_OperatingModeRequest(instance_, CAN_OperatingMode_Normal) ==
454 CAN_ModeStatus_Failed)
471 (void)CAN_OperatingModeRequest(instance_, CAN_OperatingMode_Normal);
479 RCC_ClocksTypeDef clocks{};
480 RCC_GetClocksFreq(&clocks);
481 return clocks.PCLK1_Frequency;
484inline void CH32CAN::BuildTxMsg(
const ClassicPack& p, CanTxMsg& m)
490 m.DLC = (p.dlc <= 8u) ?
static_cast<uint8_t
>(p.dlc) : 8u;
491 m.IDE = IS_EXT ? CAN_ID_EXT : CAN_ID_STD;
492 m.RTR = IS_RTR ? CAN_RTR_REMOTE : CAN_RTR_DATA;
494 m.StdId = IS_EXT ? 0u : (p.id & 0x7FFu);
495 m.ExtId = IS_EXT ? (p.id & 0x1FFFFFFFu) : 0u;
497 std::memcpy(m.Data, p.data, 8);
500void CH32CAN::TxService()
502 if (instance_ ==
nullptr)
507 tx_pend_.store(1u, std::memory_order_release);
509 uint32_t expected = 0u;
510 if (!tx_lock_.compare_exchange_strong(expected, 1u, std::memory_order_acquire,
511 std::memory_order_relaxed))
518 tx_pend_.store(0u, std::memory_order_release);
528 BuildTxMsg(p, tx_msg_);
530 uint8_t mb = CAN_Transmit(instance_, &tx_msg_);
531 if (mb == CAN_TxStatus_NoMailBox)
533 (void)tx_pool_.
Put(p);
538 tx_lock_.store(0u, std::memory_order_release);
540 if (tx_pend_.load(std::memory_order_acquire) == 0u)
546 if (!tx_lock_.compare_exchange_strong(expected, 1u, std::memory_order_acquire,
547 std::memory_order_relaxed))
573 if (instance_ ==
nullptr)
578 if (CAN_GetITStatus(instance_, CAN_IT_TME) != RESET)
580 CAN_ClearITPendingBit(instance_, CAN_IT_TME);
590 if (instance_ ==
nullptr)
597 while (CAN_MessagePending(instance_, fifo_) != 0u)
599 CAN_Receive(instance_, fifo_, &
rx_msg_);
613 if (
rx_msg_.RTR == CAN_RTR_REMOTE)
619 std::memcpy(p.data,
rx_msg_.Data, 8);
629 if (CAN_GetITStatus(instance_, CAN_IT_FMP0) != RESET)
631 CAN_ClearITPendingBit(instance_, CAN_IT_FMP0);
638 if (CAN_GetITStatus(instance_, CAN_IT_FMP1) != RESET)
640 CAN_ClearITPendingBit(instance_, CAN_IT_FMP1);
648 if (instance_ ==
nullptr)
655 const bool BOF = (CAN_GetFlagStatus(instance_, CAN_FLAG_BOF) != RESET);
656 const bool EPV = (CAN_GetFlagStatus(instance_, CAN_FLAG_EPV) != RESET);
657 const bool EWG = (CAN_GetFlagStatus(instance_, CAN_FLAG_EWG) != RESET);
658 const uint8_t LEC = CAN_GetLastErrorCode(instance_);
661 if (CAN_GetITStatus(instance_, CAN_IT_LEC) != RESET)
663 CAN_ClearITPendingBit(instance_, CAN_IT_LEC);
667 if (CAN_GetITStatus(instance_, CAN_IT_ERR) != RESET)
669 CAN_ClearITPendingBit(instance_, CAN_IT_ERR);
673 if (CAN_GetITStatus(instance_, CAN_IT_BOF) != RESET)
675 CAN_ClearITPendingBit(instance_, CAN_IT_BOF);
679 if (CAN_GetITStatus(instance_, CAN_IT_EPV) != RESET)
681 CAN_ClearITPendingBit(instance_, CAN_IT_EPV);
685 if (CAN_GetITStatus(instance_, CAN_IT_EWG) != RESET)
687 CAN_ClearITPendingBit(instance_, CAN_IT_EWG);
699 eid = CAN::ErrorID::CAN_ERROR_ID_BUS_OFF;
703 eid = CAN::ErrorID::CAN_ERROR_ID_ERROR_PASSIVE;
707 eid = CAN::ErrorID::CAN_ERROR_ID_ERROR_WARNING;
713 case CAN_ErrorCode_StuffErr:
714 eid = CAN::ErrorID::CAN_ERROR_ID_STUFF;
716 case CAN_ErrorCode_FormErr:
717 eid = CAN::ErrorID::CAN_ERROR_ID_FORM;
719 case CAN_ErrorCode_ACKErr:
720 eid = CAN::ErrorID::CAN_ERROR_ID_ACK;
722 case CAN_ErrorCode_BitRecessiveErr:
723 eid = CAN::ErrorID::CAN_ERROR_ID_BIT1;
725 case CAN_ErrorCode_BitDominantErr:
726 eid = CAN::ErrorID::CAN_ERROR_ID_BIT0;
728 case CAN_ErrorCode_CRCErr:
729 eid = CAN::ErrorID::CAN_ERROR_ID_CRC;
732 eid = CAN::ErrorID::CAN_ERROR_ID_OTHER;
737 p.id =
static_cast<uint32_t
>(eid);
743 if (instance_ ==
nullptr)
751 state.
bus_off = (CAN_GetFlagStatus(instance_, CAN_FLAG_BOF) != RESET);
752 state.
error_passive = (CAN_GetFlagStatus(instance_, CAN_FLAG_EPV) != RESET);
753 state.
error_warning = (CAN_GetFlagStatus(instance_, CAN_FLAG_EWG) != RESET);
760extern "C" void CAN1_TX_IRQHandler(
void) __attribute__((interrupt(
"WCH-Interrupt-fast")));
762extern "C" void CAN1_TX_IRQHandler(
void)
766 can->ProcessTxInterrupt();
771extern "C" void CAN1_RX1_IRQHandler(
void)
772 __attribute__((interrupt(
"WCH-Interrupt-fast")));
774extern "C" void CAN1_RX1_IRQHandler(
void)
778 can->ProcessRxInterrupt();
783extern "C" void CAN1_SCE_IRQHandler(
void)
784 __attribute__((interrupt(
"WCH-Interrupt-fast")));
786extern "C" void CAN1_SCE_IRQHandler(
void)
790 can->ProcessErrorInterrupt();
797extern "C" void CAN2_TX_IRQHandler(
void) __attribute__((interrupt(
"WCH-Interrupt-fast")));
799extern "C" void CAN2_TX_IRQHandler(
void)
803 can->ProcessTxInterrupt();
808extern "C" void CAN2_RX0_IRQHandler(
void)
809 __attribute__((interrupt(
"WCH-Interrupt-fast")));
811extern "C" void CAN2_RX0_IRQHandler(
void)
815 can->ProcessRxInterrupt();
820extern "C" void CAN2_RX1_IRQHandler(
void)
821 __attribute__((interrupt(
"WCH-Interrupt-fast")));
823extern "C" void CAN2_RX1_IRQHandler(
void)
827 can->ProcessRxInterrupt();
832extern "C" void CAN2_SCE_IRQHandler(
void)
833 __attribute__((interrupt(
"WCH-Interrupt-fast")));
835extern "C" void CAN2_SCE_IRQHandler(
void)
839 can->ProcessErrorInterrupt();
CAN 通信抽象类,定义经典 CAN 帧与订阅接口。 Abstract class for CAN communication with classic CAN frames and subscript...
@ EXTENDED
扩展数据帧(29-bit ID)。Extended data frame (29-bit ID).
@ REMOTE_EXTENDED
扩展远程帧。Extended remote frame.
@ STANDARD
标准数据帧(11-bit ID)。Standard data frame (11-bit ID).
@ REMOTE_STANDARD
标准远程帧。Standard remote frame.
@ ERROR
错误帧(虚拟事件)。Error frame (virtual event).
void OnMessage(const ClassicPack &pack, bool in_isr)
分发接收到的经典 CAN 帧。 Dispatch a received classic CAN frame.
ErrorID
ClassicPack::type == Type::ERROR 时使用的虚拟 ID。 Virtual IDs used when ClassicPack::type == Type::ERROR.
CH32 CAN 驱动实现 / CH32 CAN driver implementation.
ErrorCode SetConfig(const CAN::Configuration &cfg) override
设置 CAN 配置 / Set CAN configuration
void ProcessTxInterrupt()
处理发送中断 / Handle TX interrupt
void ProcessErrorInterrupt()
处理错误中断 / Handle error interrupt
CAN::Configuration cfg_cache_
缓存配置(用于保留原值语义) / Cached configuration for keep-previous semantics
ErrorCode AddMessage(const ClassicPack &pack) override
发送消息入队 / Enqueue TX message
void ProcessRxInterrupt()
处理接收中断 / Handle RX interrupt
ErrorCode Init()
初始化过滤器和中断路由 / Initialize filters and IRQ routing
ErrorCode GetErrorState(CAN::ErrorState &state) const override
获取总线错误状态 / Get bus error state
uint32_t GetClockFreq() const override
获取 CAN 时钟频率 / Get CAN clock frequency
static CH32CAN * map[CH32_CAN_NUMBER]
中断分发表 / IRQ dispatch map
CH32CAN(ch32_can_id_t id, uint32_t pool_size)
构造 CAN 驱动对象 / Construct CAN driver object
CanRxMsg rx_msg_
中断上下文收发缓冲 / RX/TX buffers in IRQ context
ErrorCode Put(const Data &data)
向池中放入一个元素 / Put an element into the pool
ErrorCode Get(Data &data)
从池中取出一个元素 / Retrieve an element from the pool
@ FAILED
操作失败 | Operation failed
@ OK
操作成功 | Operation successful
@ ARG_ERR
参数错误 | Argument error
CAN 位时序配置。Bit timing configuration for CAN.
uint32_t brp
预分频。Baud rate prescaler.
uint32_t sjw
同步跳宽。Synchronization jump width.
uint32_t phase_seg2
相位段 2。Phase segment 2.
uint32_t prop_seg
传播段。Propagation segment.
uint32_t phase_seg1
相位段 1。Phase segment 1.
经典 CAN 帧数据结构。Classic CAN frame structure.
uint8_t dlc
有效数据长度(0~8)。Data length code (0–8).
CAN 配置参数。CAN configuration parameters.
BitTiming bit_timing
位时序配置。Bit timing configuration.
Mode mode
工作模式。Operating mode.
CAN 当前错误状态快照(来自硬件计数器/状态机)。 Snapshot of current CAN controller error state (from HW counters/state).
bool bus_off
是否处于 BUS-OFF。True if controller is bus-off.
bool error_passive
是否处于 Error Passive。True if error-passive.
uint8_t tx_error_counter
发送错误计数 TEC。Transmit error counter (TEC).
bool error_warning
是否处于 Error Warning。True if error-warning.
uint8_t rx_error_counter
接收错误计数 REC。Receive error counter (REC).
CAN 工作模式。CAN operating mode.
bool loopback
回环模式。Loopback mode.
bool one_shot
单次发送模式。One-shot transmission.
bool listen_only
只听(静默)模式。Listen-only (silent) mode.