Fix and run queue fuzz tests

fuzz/Cargo.toml

@@ -153,4 +153,25 @@ name = "queues_fixed_bulk"
 path = "fuzz_targets/queues/fixed_bulk.rs"
 test = false
 doc = false
-bench = false
+bench = false
+
+[[bin]]
+name = "queues_fixed_enqueue_dequeue"
+path = "fuzz_targets/queues/fixed_enqueue_dequeue.rs"
+test = false
+doc = false
+bench = false
+
+[[bin]]
+name = "queues_static_bulk"
+path = "fuzz_targets/queues/static_bulk.rs"
+test = false
+doc = false
+bench = false
+
+[[bin]]
+name = "queues_static_enqueue_dequeue"
+path = "fuzz_targets/queues/static_enqueue_dequeue.rs"
+test = false
+doc = false
+bench = false

ufotofu_queues/fuzz/fuzz_targets/fixed_enqueue_dequeue.rs → fuzz/fuzz_targets/queues/fixed_enqueue_dequeue.rs

@@ -1,6 +1,7 @@
 #![no_main]
 use std::collections::VecDeque;
 
+use libfuzzer_sys::arbitrary;
 use arbitrary::Arbitrary;
 use libfuzzer_sys::fuzz_target;
 

ufotofu_queues/fuzz/fuzz_targets/static_bulk.rs → fuzz/fuzz_targets/queues/static_bulk.rs

@@ -1,5 +1,6 @@
 #![no_main]
 
+use libfuzzer_sys::arbitrary;
 use arbitrary::Arbitrary;
 use libfuzzer_sys::fuzz_target;
 

ufotofu_queues/fuzz/fuzz_targets/static_enqueue_dequeue.rs → fuzz/fuzz_targets/queues/static_enqueue_dequeue.rs

@@ -1,6 +1,7 @@
 #![no_main]
 use std::collections::VecDeque;
 
+use libfuzzer_sys::arbitrary;
 use arbitrary::Arbitrary;
 use libfuzzer_sys::fuzz_target;
 

ufotofu_queues/src/fixed.rs

@@ -72,7 +72,7 @@ impl<T> Fixed<T> {
     }
 
     /// Return a slice containing the next items that should be read.
-    fn readable_slice(&mut self) -> &[MaybeUninit<T>] {
+    fn readable_slice(&mut self) -> &[T] {
         if self.is_data_contiguous() {
             &self.data[self.read..self.write_to()]
         } else {
@@ -81,7 +81,7 @@ impl<T> Fixed<T> {
     }
 
     /// Return a slice containing the next slots that should be written to.
-    fn writeable_slice(&mut self) -> &mut [MaybeUninit<T>] {
+    fn writeable_slice(&mut self) -> &mut [T] {
         let capacity = self.capacity();
         let write_to = self.write_to();
         if self.is_data_contiguous() {
@@ -217,7 +217,7 @@ impl<T: Copy> Queue for Fixed<T> {
     /// exposed to contain initialized memory after this call, even if the memory it exposed was
     /// originally uninitialized. Violating the invariants will cause the queue to read undefined
     /// memory, which triggers undefined behavior.
-    unsafe fn consider_enqueued(&mut self, amount: usize) {
+    fn consider_enqueued(&mut self, amount: usize) {
         self.amount += amount;
     }
 
@@ -233,7 +233,7 @@ impl<T: Copy> Queue for Fixed<T> {
             self.read = (self.read + 1) % self.capacity();
             self.amount -= 1;
 
-            Some(unsafe { self.data[previous_read].assume_init() })
+            Some(self.data[previous_read])
         }
     }
 
@@ -244,7 +244,7 @@ impl<T: Copy> Queue for Fixed<T> {
         if self.amount == 0 {
             None
         } else {
-            Some(unsafe { crate::slice_assume_init_ref(self.readable_slice()) })
+            Some(self.readable_slice())
         }
     }