diff options
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_icmp.rs | 4 | ||||
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_icmp_ping.rs | 4 | ||||
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_multisocket.rs | 8 | ||||
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_tcp_client.rs | 4 | ||||
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_tcp_server.rs | 4 | ||||
| -rw-r--r-- | examples/rp235x/src/bin/ethernet_w5500_udp.rs | 4 | ||||
| -rw-r--r-- | examples/stm32h5/src/bin/adc_dma.rs | 4 | ||||
| -rw-r--r-- | examples/stm32h755cm4/src/bin/intercore.rs | 2 | ||||
| -rw-r--r-- | examples/stm32wb/src/bin/gatt_server.rs | 2 |
9 files changed, 18 insertions, 18 deletions
diff --git a/examples/rp235x/src/bin/ethernet_w5500_icmp.rs b/examples/rp235x/src/bin/ethernet_w5500_icmp.rs index f1abd311c..f012c9589 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_icmp.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_icmp.rs | |||
| @@ -61,7 +61,7 @@ async fn main(spawner: Spawner) { | |||
| 61 | ) | 61 | ) |
| 62 | .await | 62 | .await |
| 63 | .unwrap(); | 63 | .unwrap(); |
| 64 | unwrap!(spawner.spawn(ethernet_task(runner))); | 64 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 65 | 65 | ||
| 66 | // Generate random seed | 66 | // Generate random seed |
| 67 | let seed = rng.next_u64(); | 67 | let seed = rng.next_u64(); |
| @@ -76,7 +76,7 @@ async fn main(spawner: Spawner) { | |||
| 76 | ); | 76 | ); |
| 77 | 77 | ||
| 78 | // Launch network task | 78 | // Launch network task |
| 79 | unwrap!(spawner.spawn(net_task(runner))); | 79 | spawner.spawn(unwrap!(net_task(runner))); |
| 80 | 80 | ||
| 81 | info!("Waiting for DHCP..."); | 81 | info!("Waiting for DHCP..."); |
| 82 | let cfg = wait_for_config(stack).await; | 82 | let cfg = wait_for_config(stack).await; |
diff --git a/examples/rp235x/src/bin/ethernet_w5500_icmp_ping.rs b/examples/rp235x/src/bin/ethernet_w5500_icmp_ping.rs index 1f799a6b0..309d3e4f7 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_icmp_ping.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_icmp_ping.rs | |||
| @@ -63,7 +63,7 @@ async fn main(spawner: Spawner) { | |||
| 63 | ) | 63 | ) |
| 64 | .await | 64 | .await |
| 65 | .unwrap(); | 65 | .unwrap(); |
| 66 | unwrap!(spawner.spawn(ethernet_task(runner))); | 66 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 67 | 67 | ||
| 68 | // Generate random seed | 68 | // Generate random seed |
| 69 | let seed = rng.next_u64(); | 69 | let seed = rng.next_u64(); |
| @@ -78,7 +78,7 @@ async fn main(spawner: Spawner) { | |||
| 78 | ); | 78 | ); |
| 79 | 79 | ||
| 80 | // Launch network task | 80 | // Launch network task |
| 81 | unwrap!(spawner.spawn(net_task(runner))); | 81 | spawner.spawn(unwrap!(net_task(runner))); |
| 82 | 82 | ||
| 83 | info!("Waiting for DHCP..."); | 83 | info!("Waiting for DHCP..."); |
| 84 | let cfg = wait_for_config(stack).await; | 84 | let cfg = wait_for_config(stack).await; |
diff --git a/examples/rp235x/src/bin/ethernet_w5500_multisocket.rs b/examples/rp235x/src/bin/ethernet_w5500_multisocket.rs index fd8bc5c7a..7cfc00776 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_multisocket.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_multisocket.rs | |||
| @@ -64,7 +64,7 @@ async fn main(spawner: Spawner) { | |||
| 64 | ) | 64 | ) |
| 65 | .await | 65 | .await |
| 66 | .unwrap(); | 66 | .unwrap(); |
| 67 | unwrap!(spawner.spawn(ethernet_task(runner))); | 67 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 68 | 68 | ||
| 69 | // Generate random seed | 69 | // Generate random seed |
| 70 | let seed = rng.next_u64(); | 70 | let seed = rng.next_u64(); |
| @@ -79,7 +79,7 @@ async fn main(spawner: Spawner) { | |||
| 79 | ); | 79 | ); |
| 80 | 80 | ||
| 81 | // Launch network task | 81 | // Launch network task |
| 82 | unwrap!(spawner.spawn(net_task(runner))); | 82 | spawner.spawn(unwrap!(net_task(runner))); |
| 83 | 83 | ||
| 84 | info!("Waiting for DHCP..."); | 84 | info!("Waiting for DHCP..."); |
| 85 | let cfg = wait_for_config(stack).await; | 85 | let cfg = wait_for_config(stack).await; |
| @@ -87,8 +87,8 @@ async fn main(spawner: Spawner) { | |||
| 87 | info!("IP address: {:?}", local_addr); | 87 | info!("IP address: {:?}", local_addr); |
| 88 | 88 | ||
| 89 | // Create two sockets listening to the same port, to handle simultaneous connections | 89 | // Create two sockets listening to the same port, to handle simultaneous connections |
| 90 | unwrap!(spawner.spawn(listen_task(stack, 0, 1234))); | 90 | spawner.spawn(unwrap!(listen_task(stack, 0, 1234))); |
| 91 | unwrap!(spawner.spawn(listen_task(stack, 1, 1234))); | 91 | spawner.spawn(unwrap!(listen_task(stack, 1, 1234))); |
| 92 | } | 92 | } |
| 93 | 93 | ||
| 94 | #[embassy_executor::task(pool_size = 2)] | 94 | #[embassy_executor::task(pool_size = 2)] |
diff --git a/examples/rp235x/src/bin/ethernet_w5500_tcp_client.rs b/examples/rp235x/src/bin/ethernet_w5500_tcp_client.rs index b726b9cc6..254aada9a 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_tcp_client.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_tcp_client.rs | |||
| @@ -67,7 +67,7 @@ async fn main(spawner: Spawner) { | |||
| 67 | ) | 67 | ) |
| 68 | .await | 68 | .await |
| 69 | .unwrap(); | 69 | .unwrap(); |
| 70 | unwrap!(spawner.spawn(ethernet_task(runner))); | 70 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 71 | 71 | ||
| 72 | // Generate random seed | 72 | // Generate random seed |
| 73 | let seed = rng.next_u64(); | 73 | let seed = rng.next_u64(); |
| @@ -82,7 +82,7 @@ async fn main(spawner: Spawner) { | |||
| 82 | ); | 82 | ); |
| 83 | 83 | ||
| 84 | // Launch network task | 84 | // Launch network task |
| 85 | unwrap!(spawner.spawn(net_task(runner))); | 85 | spawner.spawn(unwrap!(net_task(runner))); |
| 86 | 86 | ||
| 87 | info!("Waiting for DHCP..."); | 87 | info!("Waiting for DHCP..."); |
| 88 | let cfg = wait_for_config(stack).await; | 88 | let cfg = wait_for_config(stack).await; |
diff --git a/examples/rp235x/src/bin/ethernet_w5500_tcp_server.rs b/examples/rp235x/src/bin/ethernet_w5500_tcp_server.rs index 32b3880f6..ba812f4fd 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_tcp_server.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_tcp_server.rs | |||
| @@ -66,7 +66,7 @@ async fn main(spawner: Spawner) { | |||
| 66 | ) | 66 | ) |
| 67 | .await | 67 | .await |
| 68 | .unwrap(); | 68 | .unwrap(); |
| 69 | unwrap!(spawner.spawn(ethernet_task(runner))); | 69 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 70 | 70 | ||
| 71 | // Generate random seed | 71 | // Generate random seed |
| 72 | let seed = rng.next_u64(); | 72 | let seed = rng.next_u64(); |
| @@ -81,7 +81,7 @@ async fn main(spawner: Spawner) { | |||
| 81 | ); | 81 | ); |
| 82 | 82 | ||
| 83 | // Launch network task | 83 | // Launch network task |
| 84 | unwrap!(spawner.spawn(net_task(runner))); | 84 | spawner.spawn(unwrap!(net_task(runner))); |
| 85 | 85 | ||
| 86 | info!("Waiting for DHCP..."); | 86 | info!("Waiting for DHCP..."); |
| 87 | let cfg = wait_for_config(stack).await; | 87 | let cfg = wait_for_config(stack).await; |
diff --git a/examples/rp235x/src/bin/ethernet_w5500_udp.rs b/examples/rp235x/src/bin/ethernet_w5500_udp.rs index cd0824df1..ae74ad518 100644 --- a/examples/rp235x/src/bin/ethernet_w5500_udp.rs +++ b/examples/rp235x/src/bin/ethernet_w5500_udp.rs | |||
| @@ -64,7 +64,7 @@ async fn main(spawner: Spawner) { | |||
| 64 | ) | 64 | ) |
| 65 | .await | 65 | .await |
| 66 | .unwrap(); | 66 | .unwrap(); |
| 67 | unwrap!(spawner.spawn(ethernet_task(runner))); | 67 | spawner.spawn(unwrap!(ethernet_task(runner))); |
| 68 | 68 | ||
| 69 | // Generate random seed | 69 | // Generate random seed |
| 70 | let seed = rng.next_u64(); | 70 | let seed = rng.next_u64(); |
| @@ -79,7 +79,7 @@ async fn main(spawner: Spawner) { | |||
| 79 | ); | 79 | ); |
| 80 | 80 | ||
| 81 | // Launch network task | 81 | // Launch network task |
| 82 | unwrap!(spawner.spawn(net_task(runner))); | 82 | spawner.spawn(unwrap!(net_task(runner))); |
| 83 | 83 | ||
| 84 | info!("Waiting for DHCP..."); | 84 | info!("Waiting for DHCP..."); |
| 85 | let cfg = wait_for_config(stack).await; | 85 | let cfg = wait_for_config(stack).await; |
diff --git a/examples/stm32h5/src/bin/adc_dma.rs b/examples/stm32h5/src/bin/adc_dma.rs index 20073e22f..fb9fcbc5c 100644 --- a/examples/stm32h5/src/bin/adc_dma.rs +++ b/examples/stm32h5/src/bin/adc_dma.rs | |||
| @@ -42,8 +42,8 @@ async fn main(spawner: Spawner) { | |||
| 42 | } | 42 | } |
| 43 | let p = embassy_stm32::init(config); | 43 | let p = embassy_stm32::init(config); |
| 44 | 44 | ||
| 45 | spawner.must_spawn(adc1_task(p.ADC1, p.GPDMA1_CH0, p.PA0, p.PA2)); | 45 | spawner.spawn(unwrap!(adc1_task(p.ADC1, p.GPDMA1_CH0, p.PA0, p.PA2))); |
| 46 | spawner.must_spawn(adc2_task(p.ADC2, p.GPDMA1_CH1, p.PA1, p.PA3)); | 46 | spawner.spawn(unwrap!(adc2_task(p.ADC2, p.GPDMA1_CH1, p.PA1, p.PA3))); |
| 47 | } | 47 | } |
| 48 | 48 | ||
| 49 | #[embassy_executor::task] | 49 | #[embassy_executor::task] |
diff --git a/examples/stm32h755cm4/src/bin/intercore.rs b/examples/stm32h755cm4/src/bin/intercore.rs index d5e3e7648..f584e31e9 100644 --- a/examples/stm32h755cm4/src/bin/intercore.rs +++ b/examples/stm32h755cm4/src/bin/intercore.rs | |||
| @@ -128,7 +128,7 @@ async fn main(spawner: Spawner) -> ! { | |||
| 128 | let red_led = Output::new(p.PB14, Level::Low, Speed::Low); // LD3 (heartbeat) | 128 | let red_led = Output::new(p.PB14, Level::Low, Speed::Low); // LD3 (heartbeat) |
| 129 | 129 | ||
| 130 | // Start heartbeat task | 130 | // Start heartbeat task |
| 131 | unwrap!(spawner.spawn(blink_heartbeat(red_led))); | 131 | spawner.spawn(unwrap!(blink_heartbeat(red_led))); |
| 132 | 132 | ||
| 133 | // Track previous values to detect changes | 133 | // Track previous values to detect changes |
| 134 | let mut prev_green = false; | 134 | let mut prev_green = false; |
diff --git a/examples/stm32wb/src/bin/gatt_server.rs b/examples/stm32wb/src/bin/gatt_server.rs index 9864fa026..5d927bc00 100644 --- a/examples/stm32wb/src/bin/gatt_server.rs +++ b/examples/stm32wb/src/bin/gatt_server.rs | |||
| @@ -71,7 +71,7 @@ async fn main(spawner: Spawner) { | |||
| 71 | let config = Config::default(); | 71 | let config = Config::default(); |
| 72 | let mut mbox = TlMbox::init(p.IPCC, Irqs, config); | 72 | let mut mbox = TlMbox::init(p.IPCC, Irqs, config); |
| 73 | 73 | ||
| 74 | spawner.spawn(run_mm_queue(mbox.mm_subsystem)).unwrap(); | 74 | spawner.spawn(run_mm_queue(mbox.mm_subsystem).unwrap()); |
| 75 | let sys_event = mbox.sys_subsystem.read().await; | 75 | let sys_event = mbox.sys_subsystem.read().await; |
| 76 | info!("sys event: {}", sys_event.payload()); | 76 | info!("sys event: {}", sys_event.payload()); |
| 77 | 77 | ||
