diff options
author | chemicstry <chemicstry@gmail.com> | 2022-02-09 02:02:23 +0200 |
---|---|---|
committer | chemicstry <chemicstry@gmail.com> | 2022-02-09 02:02:23 +0200 |
commit | 1f81a69347e0983f9a040125ed1532ca635e9d79 (patch) | |
tree | ccf6defc27e579e2d9c96353d342e27a5778c77c /examples/stm32f4/src/bin | |
parent | db0d798b4896e97bf40e42cb54344e7a3f77a5c8 (diff) | |
download | embassy-1f81a69347e0983f9a040125ed1532ca635e9d79.zip |
Merge USB FS and HS peripherals. Add ULPI.
Diffstat (limited to 'examples/stm32f4/src/bin')
-rw-r--r-- | examples/stm32f4/src/bin/usb_uart.rs | 4 | ||||
-rw-r--r-- | examples/stm32f4/src/bin/usb_uart_ulpi.rs | 114 |
2 files changed, 116 insertions, 2 deletions
diff --git a/examples/stm32f4/src/bin/usb_uart.rs b/examples/stm32f4/src/bin/usb_uart.rs index 7167a28b..63059d51 100644 --- a/examples/stm32f4/src/bin/usb_uart.rs +++ b/examples/stm32f4/src/bin/usb_uart.rs @@ -13,7 +13,7 @@ use panic_probe as _; // print out panic messages use embassy::executor::Spawner; use embassy::io::{AsyncBufReadExt, AsyncWriteExt}; -use embassy_stm32::usb_otg_fs::{State, Usb, UsbBus, UsbOtgFs, UsbSerial}; +use embassy_stm32::usb_otg::{State, Usb, UsbBus, UsbOtg, UsbSerial}; use embassy_stm32::{interrupt, time::Hertz, Config, Peripherals}; use usb_device::device::{UsbDeviceBuilder, UsbVidPid}; @@ -32,7 +32,7 @@ async fn main(_spawner: Spawner, p: Peripherals) { // we send back input + cr + lf let mut tx_buffer = [0u8; 66]; - let peri = UsbOtgFs::new(p.USB_OTG_FS, p.PA12, p.PA11); + let peri = UsbOtg::new_fs(p.USB_OTG_FS, p.PA12, p.PA11); let usb_bus = UsbBus::new(peri, unsafe { &mut EP_MEMORY }); let serial = UsbSerial::new(&usb_bus, &mut rx_buffer, &mut tx_buffer); diff --git a/examples/stm32f4/src/bin/usb_uart_ulpi.rs b/examples/stm32f4/src/bin/usb_uart_ulpi.rs new file mode 100644 index 00000000..2cdc8e68 --- /dev/null +++ b/examples/stm32f4/src/bin/usb_uart_ulpi.rs @@ -0,0 +1,114 @@ +#![no_std] +#![no_main] +#![feature(type_alias_impl_trait)] + +#[path = "../example_common.rs"] +mod example_common; + +use defmt::{info, unwrap}; +use defmt_rtt as _; // global logger +use embassy::interrupt::InterruptExt; +use futures::pin_mut; +use panic_probe as _; // print out panic messages + +use embassy::executor::Spawner; +use embassy::io::{AsyncBufReadExt, AsyncWriteExt}; +use embassy_stm32::usb_otg::{State, Usb, UsbBus, UsbOtg, UsbSerial}; +use embassy_stm32::{interrupt, time::Hertz, Config, Peripherals}; +use usb_device::device::{UsbDeviceBuilder, UsbVidPid}; + +static mut EP_MEMORY: [u32; 2048] = [0; 2048]; + +// USB requires at least 48 MHz clock +fn config() -> Config { + let mut config = Config::default(); + config.rcc.sys_ck = Some(Hertz(48_000_000)); + config +} + +#[embassy::main(config = "config()")] +async fn main(_spawner: Spawner, p: Peripherals) { + let mut rx_buffer = [0u8; 64]; + // we send back input + cr + lf + let mut tx_buffer = [0u8; 66]; + + // USB with external high-speed PHY + let peri = UsbOtg::new_ulpi( + p.USB_OTG_HS, + p.PA5, + p.PC2, + p.PC3, + p.PC0, + p.PA3, + p.PB0, + p.PB1, + p.PB10, + p.PB11, + p.PB12, + p.PB13, + p.PB5, + ); + let usb_bus = UsbBus::new(peri, unsafe { &mut EP_MEMORY }); + + let serial = UsbSerial::new(&usb_bus, &mut rx_buffer, &mut tx_buffer); + + let device = UsbDeviceBuilder::new(&usb_bus, UsbVidPid(0x16c0, 0x27dd)) + .manufacturer("Fake company") + .product("Serial port") + .serial_number("TEST") + .device_class(0x02) + .build(); + + let irq = interrupt::take!(OTG_FS); + irq.set_priority(interrupt::Priority::P3); + + let mut state = State::new(); + let usb = unsafe { Usb::new(&mut state, device, serial, irq) }; + pin_mut!(usb); + + let (mut reader, mut writer) = usb.as_ref().take_serial_0(); + + info!("usb initialized!"); + + unwrap!( + writer + .write_all(b"\r\nInput returned upper cased on CR+LF\r\n") + .await + ); + + let mut buf = [0u8; 64]; + loop { + let mut n = 0; + + async { + loop { + let char = unwrap!(reader.read_byte().await); + + if char == b'\r' || char == b'\n' { + break; + } + + buf[n] = char; + n += 1; + + // stop if we're out of room + if n == buf.len() { + break; + } + } + } + .await; + + if n > 0 { + for char in buf[..n].iter_mut() { + // upper case + if 0x61 <= *char && *char <= 0x7a { + *char &= !0x20; + } + } + unwrap!(writer.write_all(&buf[..n]).await); + unwrap!(writer.write_all(b"\r\n").await); + unwrap!(writer.flush().await); + } + } +} |