cargo fmt

3 files changed, 56 insertions, 43 deletions

diff --git a/embassy-nrf/src/pdm.rs b/embassy-nrf/src/pdm.rs
index f2675bb7a..48668c7f4 100644
--- a/embassy-nrf/src/pdm.rs
+++ b/embassy-nrf/src/pdm.rs
@@ -8,17 +8,17 @@ use core::task::Poll;
 
 use embassy_hal_common::drop::OnDrop;
 use embassy_hal_common::{into_ref, PeripheralRef};
-use futures::future::poll_fn;
 use fixed::types::I7F1;
+use futures::future::poll_fn;
 
 use crate::chip::EASY_DMA_SIZE;
 use crate::gpio::sealed::Pin;
 use crate::gpio::{AnyPin, Pin as GpioPin};
 use crate::interrupt::typelevel::Interrupt;
-use crate::{interrupt, Peripheral};
 use crate::pac::pdm::mode::{EDGE_A, OPERATION_A};
 pub use crate::pac::pdm::pdmclkctrl::FREQ_A as Frequency;
 pub use crate::pac::pdm::ratio::RATIO_A as Ratio;
+use crate::{interrupt, Peripheral};
 
 /// Interrupt handler.
 pub struct InterruptHandler<T: Instance> {
@@ -133,8 +133,14 @@ impl<'d, T: Instance> Pdm<'d, T> {
     }
 
     fn _set_gain(r: &crate::pac::pdm::RegisterBlock, gain_left: I7F1, gain_right: I7F1) {
-        let gain_left = gain_left.saturating_add(I7F1::from_bits(40)).saturating_to_num::<u8>().clamp(0, 0x50);
-        let gain_right = gain_right.saturating_add(I7F1::from_bits(40)).saturating_to_num::<u8>().clamp(0, 0x50);
+        let gain_left = gain_left
+            .saturating_add(I7F1::from_bits(40))
+            .saturating_to_num::<u8>()
+            .clamp(0, 0x50);
+        let gain_right = gain_right
+            .saturating_add(I7F1::from_bits(40))
+            .saturating_to_num::<u8>()
+            .clamp(0, 0x50);
 
         r.gainl.write(|w| unsafe { w.gainl().bits(gain_left) });
         r.gainr.write(|w| unsafe { w.gainr().bits(gain_right) });
@@ -258,7 +264,8 @@ impl<'d, T: Instance> Pdm<'d, T> {
         &mut self,
         bufs: &mut [[i16; N]; 2],
         mut sampler: S,
-    ) -> Result<(), Error> where
+    ) -> Result<(), Error>
+    where
         S: FnMut(&[i16; N]) -> SamplerState,
     {
         let r = T::regs();
@@ -267,7 +274,9 @@ impl<'d, T: Instance> Pdm<'d, T> {
             return Err(Error::AlreadyRunning);
         }
 
-        r.sample.ptr.write(|w| unsafe { w.sampleptr().bits(bufs[0].as_mut_ptr() as u32) });
+        r.sample
+            .ptr
+            .write(|w| unsafe { w.sampleptr().bits(bufs[0].as_mut_ptr() as u32) });
         r.sample.maxcnt.write(|w| unsafe { w.buffsize().bits(N as _) });
 
         // Reset and enable the events
@@ -285,7 +294,7 @@ impl<'d, T: Instance> Pdm<'d, T> {
         // wouldn't happen anyway.
         compiler_fence(Ordering::SeqCst);
 
-        r.tasks_start.write(|w| { w.tasks_start().set_bit() });
+        r.tasks_start.write(|w| w.tasks_start().set_bit());
 
         let mut current_buffer = 0;
 
@@ -309,7 +318,8 @@ impl<'d, T: Instance> Pdm<'d, T> {
                 r.events_end.reset();
                 r.intenset.write(|w| w.end().set());
 
-                if !done { // Discard the last buffer after the user requested a stop.
+                if !done {
+                    // Discard the last buffer after the user requested a stop.
                     if sampler(&bufs[current_buffer]) == SamplerState::Sampled {
                         let next_buffer = 1 - current_buffer;
                         current_buffer = next_buffer;
diff --git a/examples/nrf52840/src/bin/pdm.rs b/examples/nrf52840/src/bin/pdm.rs
index 47fe67733..444b9137f 100644
--- a/examples/nrf52840/src/bin/pdm.rs
+++ b/examples/nrf52840/src/bin/pdm.rs
@@ -41,9 +41,11 @@ async fn main(_p: Spawner) {
                 buf.iter().min().unwrap(),
                 buf.iter().max().unwrap(),
                 mean,
-                (
-                    buf.iter().map(|v| i32::from(*v - mean).pow(2)).fold(0i32, |a,b| a.saturating_add(b))
-                / buf.len() as i32).sqrt() as i16,
+                (buf.iter()
+                    .map(|v| i32::from(*v - mean).pow(2))
+                    .fold(0i32, |a, b| a.saturating_add(b))
+                    / buf.len() as i32)
+                    .sqrt() as i16,
             );
 
             info!("samples: {:?}", &buf);
diff --git a/examples/nrf52840/src/bin/pdm_continuous.rs b/examples/nrf52840/src/bin/pdm_continuous.rs
index 9eaf30717..7d8531475 100644
--- a/examples/nrf52840/src/bin/pdm_continuous.rs
+++ b/examples/nrf52840/src/bin/pdm_continuous.rs
@@ -2,14 +2,15 @@
 #![no_main]
 #![feature(type_alias_impl_trait)]
 
-use defmt::info;
 use core::cmp::Ordering;
+
+use defmt::info;
 use embassy_executor::Spawner;
+use embassy_nrf::pdm::{self, Config, Frequency, OperationMode, Pdm, Ratio, SamplerState};
 use embassy_nrf::{bind_interrupts, peripherals};
-use embassy_nrf::pdm::{self, Config, OperationMode, Pdm, SamplerState, Frequency, Ratio};
 use fixed::types::I7F1;
-use num_integer::Roots;
 use microfft::real::rfft_1024;
+use num_integer::Roots;
 use {defmt_rtt as _, panic_probe as _};
 
 // Demonstrates both continuous sampling and scanning multiple channels driven by a PPI linked timer
@@ -31,34 +32,34 @@ async fn main(_p: Spawner) {
 
     let mut bufs = [[0; 1024]; 2];
 
-    pdm
-        .run_task_sampler(
-            &mut bufs,
-            move |buf| {
-                // NOTE: It is important that the time spent within this callback
-                // does not exceed the time taken to acquire the 1500 samples we
-                // have in this example, which would be 10us + 2us per
-                // sample * 1500 = 18ms. You need to measure the time taken here
-                // and set the sample buffer size accordingly. Exceeding this
-                // time can lead to the peripheral re-writing the other buffer.
-                let mean = (buf.iter().map(|v| i32::from(*v)).sum::<i32>() / buf.len() as i32) as i16;
-                let (peak_freq_index, peak_mag) = fft_peak_freq(&buf);
-                let peak_freq = peak_freq_index * 16000 / buf.len();
-                info!(
-                    "{} samples, min {=i16}, max {=i16}, mean {=i16}, AC RMS {=i16}, peak {} @ {} Hz",
-                    buf.len(),
-                    buf.iter().min().unwrap(),
-                    buf.iter().max().unwrap(),
-                    mean,
-                    (
-                        buf.iter().map(|v| i32::from(*v - mean).pow(2)).fold(0i32, |a,b| a.saturating_add(b))
-                    / buf.len() as i32).sqrt() as i16,
-                    peak_mag, peak_freq,
-                );
-                SamplerState::Sampled
-            },
-        )
-        .await.unwrap();
+    pdm.run_task_sampler(&mut bufs, move |buf| {
+        // NOTE: It is important that the time spent within this callback
+        // does not exceed the time taken to acquire the 1500 samples we
+        // have in this example, which would be 10us + 2us per
+        // sample * 1500 = 18ms. You need to measure the time taken here
+        // and set the sample buffer size accordingly. Exceeding this
+        // time can lead to the peripheral re-writing the other buffer.
+        let mean = (buf.iter().map(|v| i32::from(*v)).sum::<i32>() / buf.len() as i32) as i16;
+        let (peak_freq_index, peak_mag) = fft_peak_freq(&buf);
+        let peak_freq = peak_freq_index * 16000 / buf.len();
+        info!(
+            "{} samples, min {=i16}, max {=i16}, mean {=i16}, AC RMS {=i16}, peak {} @ {} Hz",
+            buf.len(),
+            buf.iter().min().unwrap(),
+            buf.iter().max().unwrap(),
+            mean,
+            (buf.iter()
+                .map(|v| i32::from(*v - mean).pow(2))
+                .fold(0i32, |a, b| a.saturating_add(b))
+                / buf.len() as i32)
+                .sqrt() as i16,
+            peak_mag,
+            peak_freq,
+        );
+        SamplerState::Sampled
+    })
+    .await
+    .unwrap();
 }
 
 fn fft_peak_freq(input: &[i16; 1024]) -> (usize, u32) {
@@ -75,6 +76,6 @@ fn fft_peak_freq(input: &[i16; 1024]) -> (usize, u32) {
         .map(|c| c.norm_sqr())
         .enumerate()
         .max_by(|(_, a), (_, b)| a.partial_cmp(b).unwrap_or(Ordering::Equal))
-        .map(|(i, v)| (i, ((v*32768.0) as u32).sqrt()))
+        .map(|(i, v)| (i, ((v * 32768.0) as u32).sqrt()))
         .unwrap()
 }