-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #5 from dstric-aqueduct/master
add USB serial example
- Loading branch information
Showing
6 changed files
with
209 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| #![no_std] | ||
| #![no_main] | ||
| #![feature(type_alias_impl_trait)] | ||
|
|
||
| use defmt::info; | ||
| use defmt_rtt as _; | ||
| use embassy_executor::{main, task, Spawner}; | ||
| use embassy_time::Timer; | ||
| use embassy_usb::class::cdc_acm::{CdcAcmClass, State}; | ||
| use embassy_usb::driver::EndpointError; | ||
| use embassy_usb::Builder; | ||
| use futures::future::join; | ||
| use panic_probe as _; | ||
| use portenta_h7_async::led; | ||
|
|
||
| use embassy_stm32::usb_otg::{Driver, Instance}; | ||
|
|
||
| #[main] | ||
| async fn main(spawner: Spawner) { | ||
| info!("Init"); | ||
|
|
||
| let portenta_h7_async::Board { | ||
| led_blue, | ||
| mut led_red, | ||
| usb, | ||
| .. | ||
| } = portenta_h7_async::Board::take(); | ||
|
|
||
| // Create embassy-usb Config | ||
| let mut config = embassy_usb::Config::new(0xc0de, 0xcafe); | ||
| config.manufacturer = Some("Embassy"); | ||
| config.product = Some("USB-serial example"); | ||
| config.serial_number = Some("12345678"); | ||
| config.max_packet_size_0 = 64; | ||
|
|
||
| // Required for windows compatibility. | ||
| // https://developer.nordicsemi.com/nRF_Connect_SDK/doc/1.9.1/kconfig/CONFIG_CDC_ACM_IAD.html#help | ||
| config.device_class = 0xEF; | ||
| config.device_sub_class = 0x02; | ||
| config.device_protocol = 0x01; | ||
| config.composite_with_iads = true; | ||
|
|
||
| // Create embassy-usb DeviceBuilder using the driver and config. | ||
| // It needs some buffers for building the descriptors. | ||
| let mut device_descriptor = [0; 256]; | ||
| let mut config_descriptor = [0; 256]; | ||
| let mut bos_descriptor = [0; 256]; | ||
| let mut control_buf = [0; 64]; | ||
|
|
||
| let mut state = State::new(); | ||
|
|
||
| let mut builder = Builder::new( | ||
| usb, | ||
| config, | ||
| &mut device_descriptor, | ||
| &mut config_descriptor, | ||
| &mut bos_descriptor, | ||
| &mut [], // no msos descriptors | ||
| &mut control_buf, | ||
| ); | ||
|
|
||
| // Create classes on the builder. | ||
| let mut class = CdcAcmClass::new(&mut builder, &mut state, 512); | ||
|
|
||
| // Build the builder. | ||
| let mut usb = builder.build(); | ||
|
|
||
| // Run the USB device. | ||
| let usb_fut = usb.run(); | ||
|
|
||
| // Do stuff with the class! | ||
| let echo_fut = async { | ||
| loop { | ||
| class.wait_connection().await; | ||
| info!("Connected"); | ||
| let _ = echo(&mut class, &mut led_red).await; | ||
| info!("Disconnected"); | ||
| } | ||
| }; | ||
|
|
||
| spawner.spawn(blink_led_blue(led_blue)).unwrap(); | ||
|
|
||
| // Run everything concurrently. | ||
| // If we had made everything `'static` above instead, we could do this using separate tasks instead. | ||
| join(usb_fut, echo_fut).await; | ||
| } | ||
|
|
||
| struct Disconnected {} | ||
|
|
||
| impl From<EndpointError> for Disconnected { | ||
| fn from(val: EndpointError) -> Self { | ||
| match val { | ||
| EndpointError::BufferOverflow => panic!("Buffer overflow"), | ||
| EndpointError::Disabled => Disconnected {}, | ||
| } | ||
| } | ||
| } | ||
|
|
||
| async fn echo<'d, T: Instance + 'd>( | ||
| class: &mut CdcAcmClass<'d, Driver<'d, T>>, | ||
| led_red: &mut led::user::Red, | ||
| ) -> Result<(), Disconnected> { | ||
| let mut buf = [0; 512]; | ||
| loop { | ||
| let n = class.read_packet(&mut buf).await?; | ||
| let data = &buf[..n]; | ||
| info!("data: {:x}", data); | ||
| led_red.toggle(); | ||
| class.write_packet(data).await?; | ||
| } | ||
| } | ||
|
|
||
| #[task] | ||
| async fn blink_led_blue(mut led: led::user::Blue) { | ||
| loop { | ||
| led.toggle(); | ||
| Timer::after_millis(1_000).await; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters