zpehyr: Code formatting updates

Run `cargo fmt` in zephyr.

Signed-off-by: David Brown <[email protected]>

Author: d3zd3z

zephyr/src/device/gpio.rs

@@ -35,7 +35,10 @@ mod async_io {
         ZR_GPIO_INT_MODE_DISABLE_ONLY,
     };
 
-    use crate::{printkln, sync::atomic::{AtomicBool, AtomicU32}};
+    use crate::{
+        printkln,
+        sync::atomic::{AtomicBool, AtomicU32},
+    };
 
     use super::{GpioPin, GpioToken};
 

zephyr/src/device/i2c.rs

@@ -43,15 +43,7 @@ impl I2C {
                 flags: raw::ZR_I2C_MSG_READ | raw::ZR_I2C_MSG_STOP,
             },
         ];
-        let res = unsafe {
-            to_result(
-                raw::i2c_transfer(
-                    self.device,
-                    msg.as_mut_ptr(),
-                    2,
-                    0x42,
-                ))
-        };
+        let res = unsafe { to_result(raw::i2c_transfer(self.device, msg.as_mut_ptr(), 2, 0x42)) };
 
         printkln!("res: {} {}", msg[1].len, msg[1].flags);
 

zephyr/src/embassy/executor.rs

@@ -2,9 +2,9 @@
 
 use core::marker::PhantomData;
 
-use embassy_executor::{raw, Spawner};
 use crate::sys::sync::Semaphore;
 use crate::time::Forever;
+use embassy_executor::{raw, Spawner};
 
 /// Zephyr-thread based executor.
 pub struct Executor {

zephyr/src/rtio.rs

@@ -3,8 +3,8 @@
 use core::ffi::c_void;
 
 use crate::error::to_result_void;
-use crate::raw;
 use crate::object::{ObjectInit, ZephyrObject};
+use crate::raw;
 
 /// The underlying structure, holding the rtio, it's semaphores, and pools.
 ///
@@ -27,15 +27,17 @@ pub struct RtioData<const SQE_SZ: usize, const CQE_SZ: usize> {
     /// The CQE items.
     cqe_pool_items: [raw::rtio_cqe; CQE_SZ],
     /// The pool of CQEs.
-    cqe_pool: raw:: rtio_cqe_pool,
+    cqe_pool: raw::rtio_cqe_pool,
 }
 
 /// Init based reference to the the underlying rtio object.
 ///
 /// Note that this declaration will _not_ support userspace currently, as the object will not be
 /// placed in an iterable linker section.  Also, the linker sevction will not work as the
 /// ZephyrObject will have an attached atomic used to ensure proper initialization.
-pub struct RtioObject<const SQE_SZ: usize, const CQE_SZ: usize>(pub(crate) ZephyrObject<RtioData<SQE_SZ, CQE_SZ>>);
+pub struct RtioObject<const SQE_SZ: usize, const CQE_SZ: usize>(
+    pub(crate) ZephyrObject<RtioData<SQE_SZ, CQE_SZ>>,
+);
 
 unsafe impl<const SQE_SZ: usize, const CQE_SZ: usize> Sync for RtioObject<SQE_SZ, CQE_SZ> {}
 
@@ -52,9 +54,7 @@ impl<const SQE_SZ: usize, const CQE_SZ: usize> RtioObject<SQE_SZ, CQE_SZ> {
     pub fn sqe_acquire(&'static self) -> Option<Sqe> {
         let this = unsafe { self.0.get() };
 
-        let ptr = unsafe {
-            raw::rtio_sqe_acquire(&raw mut (*this).rtio)
-        };
+        let ptr = unsafe { raw::rtio_sqe_acquire(&raw mut (*this).rtio) };
 
         if ptr.is_null() {
             None
@@ -67,9 +67,7 @@ impl<const SQE_SZ: usize, const CQE_SZ: usize> RtioObject<SQE_SZ, CQE_SZ> {
     pub fn submit(&'static self, wait: usize) -> crate::Result<()> {
         let this = unsafe { self.0.get() };
 
-        unsafe {
-            to_result_void(raw::rtio_submit(&raw mut (*this).rtio, wait as u32))
-        }
+        unsafe { to_result_void(raw::rtio_submit(&raw mut (*this).rtio, wait as u32)) }
     }
 
     /// Consume a single completion.
@@ -78,9 +76,7 @@ impl<const SQE_SZ: usize, const CQE_SZ: usize> RtioObject<SQE_SZ, CQE_SZ> {
     pub fn cqe_consume(&'static self) -> Option<Cqe> {
         let this = unsafe { self.0.get() };
 
-        let ptr = unsafe {
-            raw::rtio_cqe_consume(&raw mut (*this).rtio)
-        };
+        let ptr = unsafe { raw::rtio_cqe_consume(&raw mut (*this).rtio) };
 
         if ptr.is_null() {
             None
@@ -93,7 +89,9 @@ impl<const SQE_SZ: usize, const CQE_SZ: usize> RtioObject<SQE_SZ, CQE_SZ> {
     }
 }
 
-impl<const SQE_SZ: usize, const CQE_SZ: usize> ObjectInit<RtioData<SQE_SZ, CQE_SZ>> for ZephyrObject<RtioData<SQE_SZ, CQE_SZ>> {
+impl<const SQE_SZ: usize, const CQE_SZ: usize> ObjectInit<RtioData<SQE_SZ, CQE_SZ>>
+    for ZephyrObject<RtioData<SQE_SZ, CQE_SZ>>
+{
     fn init(item: *mut RtioData<SQE_SZ, CQE_SZ>) {
         #[cfg(CONFIG_RTIO_SUBMIT_SEM)]
         unsafe {
@@ -149,7 +147,12 @@ pub struct Sqe {
 
 impl Sqe {
     /// Configure this SQE as a callback.
-    pub fn prep_callback(&mut self, callback: raw::rtio_callback_t, arg0: *mut c_void, userdata: *mut c_void) {
+    pub fn prep_callback(
+        &mut self,
+        callback: raw::rtio_callback_t,
+        arg0: *mut c_void,
+        userdata: *mut c_void,
+    ) {
         unsafe {
             raw::rtio_sqe_prep_callback(self.item, callback, arg0, userdata);
         }
@@ -179,9 +182,7 @@ pub struct Cqe {
 impl Cqe {
     /// Retrieve the result of this operation.
     pub fn result(&self) -> i32 {
-        unsafe {
-            (*self.item).result
-        }
+        unsafe { (*self.item).result }
     }
 }
 

zephyr/src/work.rs

@@ -554,7 +554,8 @@ impl<T: SimpleAction + Send> Work<T> {
 
         // SAFETY: The Pin ensures this will not move.  Our implementation of drop ensures that the
         // work item is no longer queued when the data is dropped.
-        let result = SubmitResult::to_result(unsafe { k_work_submit_to_queue(queue.item.get(), work) });
+        let result =
+            SubmitResult::to_result(unsafe { k_work_submit_to_queue(queue.item.get(), work) });
 
         Self::check_drop(work, &result);
 
@@ -609,7 +610,6 @@ impl<T: SimpleAction + Send> Work<T> {
                 drop(this);
             }
         }
-
     }
 
     /// Access the inner action.