itsscb/embassy
1
0
Fork 0
mirror of https://github.com/embassy-rs/embassy.git synced 2025-10-02 14:44:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Switch to SendDynamicSender for FDCAN.

Browse Source
This commit is contained in:
Corey Schuhen 2025-05-29 20:47:33 +10:00
parent 9b8d6d6f22
commit eba9ddc805
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
embassy-stm32/src/can/common.rs
View File

@ -1,29 +1,29 @@
use embassy_sync::channel::{DynamicReceiver, DynamicSender}; use embassy_sync::channel::{SendDynamicReceiver, SendDynamicSender};
use super::enums::*; use super::enums::*;
use super::frame::*; use super::frame::*;
pub(crate) struct ClassicBufferedRxInner { pub(crate) struct ClassicBufferedRxInner {
pub rx_sender: DynamicSender<'static, Result<Envelope, BusError>>, pub rx_sender: SendDynamicSender<'static, Result<Envelope, BusError>>,
} }
pub(crate) struct ClassicBufferedTxInner { pub(crate) struct ClassicBufferedTxInner {
pub tx_receiver: DynamicReceiver<'static, Frame>, pub tx_receiver: SendDynamicReceiver<'static, Frame>,
} }
#[cfg(any(can_fdcan_v1, can_fdcan_h7))] #[cfg(any(can_fdcan_v1, can_fdcan_h7))]
pub(crate) struct FdBufferedRxInner { pub(crate) struct FdBufferedRxInner {
pub rx_sender: DynamicSender<'static, Result<FdEnvelope, BusError>>, pub rx_sender: SendDynamicSender<'static, Result<FdEnvelope, BusError>>,
} }
#[cfg(any(can_fdcan_v1, can_fdcan_h7))] #[cfg(any(can_fdcan_v1, can_fdcan_h7))]
pub(crate) struct FdBufferedTxInner { pub(crate) struct FdBufferedTxInner {
pub tx_receiver: DynamicReceiver<'static, FdFrame>, pub tx_receiver: SendDynamicReceiver<'static, FdFrame>,
} }
/// Sender that can be used for sending CAN frames. /// Sender that can be used for sending CAN frames.
pub struct BufferedSender<'ch, FRAME> { pub struct BufferedSender<'ch, FRAME> {
pub(crate) tx_buf: embassy_sync::channel::DynamicSender<'ch, FRAME>, pub(crate) tx_buf: embassy_sync::channel::SendDynamicSender<'ch, FRAME>,
pub(crate) waker: fn(), pub(crate) waker: fn(),
pub(crate) internal_operation: fn(InternalOperation), pub(crate) internal_operation: fn(InternalOperation),
} }
@ -70,7 +70,7 @@ pub type BufferedCanSender = BufferedSender<'static, Frame>;
/// Receiver that can be used for receiving CAN frames. Note, each CAN frame will only be received by one receiver. /// Receiver that can be used for receiving CAN frames. Note, each CAN frame will only be received by one receiver.
pub struct BufferedReceiver<'ch, ENVELOPE> { pub struct BufferedReceiver<'ch, ENVELOPE> {
pub(crate) rx_buf: embassy_sync::channel::DynamicReceiver<'ch, Result<ENVELOPE, BusError>>, pub(crate) rx_buf: embassy_sync::channel::SendDynamicReceiver<'ch, Result<ENVELOPE, BusError>>,
pub(crate) internal_operation: fn(InternalOperation), pub(crate) internal_operation: fn(InternalOperation),
} }