Dreaded_X/pico_p1
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

UART adjustments

Browse Source
This commit is contained in:
Dreaded_X 2023-09-08 00:11:56 +02:00
parent 3b6acbd65e
commit 77eba3071d
Signed by: Dreaded_X
GPG Key ID: FA5F485356B0D2D4
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/main.rs
View File

@ -25,9 +25,9 @@ use embassy_rp::{
clocks::RoscRng, clocks::RoscRng,
flash::{Flash, WRITE_SIZE}, flash::{Flash, WRITE_SIZE},
gpio::{Level, Output}, gpio::{Level, Output},
peripherals::{DMA_CH0, PIN_23, PIN_25, PIO0, UART0}, peripherals::{DMA_CH1, PIN_23, PIN_25, PIO0, UART0},
pio::{self, Pio}, pio::{self, Pio},
uart::{self, BufferedUartRx, Parity}, uart::{self, Async, Parity, UartRx},
}; };
use embassy_sync::{ use embassy_sync::{
blocking_mutex::{raw::NoopRawMutex, Mutex}, blocking_mutex::{raw::NoopRawMutex, Mutex},
@ -58,7 +58,7 @@ use defmt::{debug, error, info, warn, Debug2Format};
use {defmt_rtt as _, panic_probe as _}; use {defmt_rtt as _, panic_probe as _};
bind_interrupts!(struct Irqs { bind_interrupts!(struct Irqs {
UART0_IRQ => uart::BufferedInterruptHandler<UART0>; UART0_IRQ => uart::InterruptHandler<UART0>;
PIO0_IRQ_0 => pio::InterruptHandler<PIO0>; PIO0_IRQ_0 => pio::InterruptHandler<PIO0>;
}); });
@ -102,7 +102,7 @@ async fn wifi_task(
runner: cyw43::Runner< runner: cyw43::Runner<
'static, 'static,
Output<'static, PIN_23>, Output<'static, PIN_23>,
PioSpi<'static, PIN_25, PIO0, 0, DMA_CH0>, PioSpi<'static, PIN_25, PIO0, 0, DMA_CH1>,
>, >,
) -> ! { ) -> ! {
runner.run().await runner.run().await
@ -113,14 +113,14 @@ async fn net_task(stack: &'static Stack<cyw43::NetDriver<'static>>) -> ! {
stack.run().await stack.run().await
} }
async fn get_readout(rx: &mut BufferedUartRx<'static, UART0>) -> Readout { async fn get_readout(rx: &mut UartRx<'static, UART0, Async>) -> Readout {
let mut buffer: Vec<u8, 2048> = Vec::new(); let mut buffer: Vec<u8, 2048> = Vec::new();
buffer.push(b'/').unwrap(); buffer.push(b'/').unwrap();
let mut byte = [0; 1]; let mut byte = [0; 1];
debug!("Waiting for next telegram..."); debug!("Waiting for next telegram...");
loop { loop {
rx.read_exact(&mut byte).await.unwrap(); rx.read(&mut byte).await.unwrap();
if byte[0] == b'/' { if byte[0] == b'/' {
break; break;
@ -137,7 +137,7 @@ async fn get_readout(rx: &mut BufferedUartRx<'static, UART0>) -> Readout {
debug!("Start of CRC detected"); debug!("Start of CRC detected");
let mut crc = [0; 4]; let mut crc = [0; 4];
rx.read_exact(&mut crc).await.unwrap(); rx.read(&mut crc).await.unwrap();
buffer.extend_from_slice(&crc).unwrap(); buffer.extend_from_slice(&crc).unwrap();
@ -155,7 +155,7 @@ async fn get_readout(rx: &mut BufferedUartRx<'static, UART0>) -> Readout {
#[embassy_executor::task] #[embassy_executor::task]
async fn uart_rx_task( async fn uart_rx_task(
mut rx: BufferedUartRx<'static, UART0>, mut rx: UartRx<'static, UART0, Async>,
sender: Sender<'static, NoopRawMutex, dsmr5::state::State, 1>, sender: Sender<'static, NoopRawMutex, dsmr5::state::State, 1>,
) { ) {
info!("Wating for serial data"); info!("Wating for serial data");
@ -213,8 +213,7 @@ async fn main(spawner: Spawner) {
config.parity = Parity::ParityNone; config.parity = Parity::ParityNone;
// config.invert_rx = true; // config.invert_rx = true;
let buf = make_static!([0u8; 2048]); let rx = UartRx::new(p.UART0, p.PIN_17, Irqs, p.DMA_CH0, config);
let rx = BufferedUartRx::new_with_rts(p.UART0, Irqs, p.PIN_1, p.PIN_3, buf, config);
spawner.spawn(uart_rx_task(rx, channel.sender())).unwrap(); spawner.spawn(uart_rx_task(rx, channel.sender())).unwrap();
@ -229,7 +228,7 @@ async fn main(spawner: Spawner) {
cs, cs,
p.PIN_24, p.PIN_24,
p.PIN_29, p.PIN_29,
p.DMA_CH0, p.DMA_CH1,
); );
let (fw, clm) = unsafe { get_firmware() }; let (fw, clm) = unsafe { get_firmware() };