Add test, fmt

Author: jamesmunns

src/queue.rs

@@ -106,3 +106,31 @@ impl<S: Storage, C: Coord, N: Notifier> crate::queue::ArcBBQueue<S, C, N> {
         }
     }
 }
+
+#[cfg(test)]
+mod test {
+    use crate::traits::{
+        coordination::cas::AtomicCoord, notifier::blocking::Blocking, storage::Inline,
+    };
+
+    use super::*;
+
+    type Queue = BBQueue<Inline<4096>, AtomicCoord, Blocking>;
+    static QUEUE: Queue = BBQueue::new();
+    static PRODUCER: FramedProducer<&'static Queue, u16> = QUEUE.framed_producer();
+    static CONSUMER: FramedConsumer<&'static Queue, u16> = QUEUE.framed_consumer();
+
+    #[test]
+    fn handles() {
+        let mut wgr = PRODUCER.grant(16).unwrap();
+        wgr.iter_mut().for_each(|w| *w = 123);
+        wgr.commit(16);
+
+        let rgr = CONSUMER.read().unwrap();
+        assert_eq!(rgr.len(), 16);
+        for b in rgr.iter() {
+            assert_eq!(*b, 123);
+        }
+        rgr.release();
+    }
+}

src/traits/bbqhdl.rs

@@ -17,7 +17,13 @@
 
 use core::{marker::PhantomData, ops::Deref};
 
-use crate::{prod_cons::{framed::{FramedConsumer, FramedProducer, LenHeader}, stream::{StreamConsumer, StreamProducer}}, queue::BBQueue};
+use crate::{
+    prod_cons::{
+        framed::{FramedConsumer, FramedProducer, LenHeader},
+        stream::{StreamConsumer, StreamProducer},
+    },
+    queue::BBQueue,
+};
 
 use super::{coordination::Coord, notifier::Notifier, storage::Storage};
 

src/traits/coordination/cas.rs

@@ -65,7 +65,11 @@ unsafe impl Coord for AtomicCoord {
         self.last.store(0, Ordering::Release);
     }
 
-    fn grant_max_remaining(&self, capacity: usize, mut sz: usize) -> Result<(usize, usize), WriteGrantError> {
+    fn grant_max_remaining(
+        &self,
+        capacity: usize,
+        mut sz: usize,
+    ) -> Result<(usize, usize), WriteGrantError> {
         if self.write_in_progress.swap(true, Ordering::AcqRel) {
             return Err(WriteGrantError::GrantInProgress);
         }

src/traits/coordination/cs.rs

@@ -71,7 +71,11 @@ unsafe impl Coord for CsCoord {
         self.last.store(0, Ordering::Release);
     }
 
-    fn grant_max_remaining(&self, capacity: usize, mut sz: usize) -> Result<(usize, usize), WriteGrantError> {
+    fn grant_max_remaining(
+        &self,
+        capacity: usize,
+        mut sz: usize,
+    ) -> Result<(usize, usize), WriteGrantError> {
         critical_section::with(|_cs| {
             if self.write_in_progress.load(Ordering::Relaxed) {
                 return Err(WriteGrantError::GrantInProgress);

src/traits/coordination/mod.rs

@@ -54,7 +54,11 @@ pub unsafe trait Coord {
 
     // Write Grants
 
-    fn grant_max_remaining(&self, capacity: usize, sz: usize) -> Result<(usize, usize), WriteGrantError>;
+    fn grant_max_remaining(
+        &self,
+        capacity: usize,
+        sz: usize,
+    ) -> Result<(usize, usize), WriteGrantError>;
     fn grant_exact(&self, capacity: usize, sz: usize) -> Result<usize, WriteGrantError>;
     fn commit_inner(&self, capacity: usize, grant_len: usize, used: usize);