Quiet some warns with Todos

Author: pinkforest

io-uring-bearer/src/fixed.rs

@@ -9,6 +9,7 @@ use slab::{Slab, VacantEntry};
 
 #[derive(Clone, Debug)]
 pub(crate) struct FixedFdRegister {
+    #[allow(dead_code)]
     fno2fixed: SelectedHashMap<u32, u32, SelectedHasher<u32>>,
     fixed_ord: Slab<(u32, RegisteredFd)>,
     capacity: u32,

io-uring-bearer/src/slab/buffer.rs

@@ -84,6 +84,7 @@ impl ProvideBuffersRec {
 
 /// Mutable Buffer is taken by something, let's provide it intermediate type.  
 #[derive(Clone, Debug)]
+#[allow(dead_code)]
 pub(crate) struct TakenMutableBuffer {
     pub(crate) buf_idx: usize,
     pub(crate) buf_mut_u8: *mut u8,
@@ -108,6 +109,7 @@ pub(crate) fn take_one_mutable_buffer_raw(
 
 /// Buffer is taken by something for Read-Only, let's provide it intermediate type.  
 #[derive(Clone, Debug)]
+#[allow(dead_code)]
 pub(crate) struct TakenImmutableBuffer {
     pub(crate) buf_idx: usize,
     pub(crate) buf_const_u8: *const u8,

io-uring-bearer/src/slab/send_zc.rs

@@ -20,6 +20,7 @@ pub struct SendZcFixedRec {
     fixed_fd: u32,
     owner: Owner,
     buf_taken: TakenImmutableBuffer,
+    #[allow(dead_code)]
     to_addr: Option<DestTo>,
 }
 
@@ -30,6 +31,7 @@ pub struct SendZcUnsafeRefRec {
     owner: Owner,
     buf_const_u8: *const u8,
     buf_size: u32,
+    #[allow(dead_code)]
     to_addr: Option<DestTo>,
 }
 
@@ -80,20 +82,23 @@ impl SendZcRec {
 
 /// When SendTo is sepcified, send(2) is turned into sendto(2)
 #[derive(Clone, Debug)]
+#[allow(dead_code)]
 pub enum DestTo {
     V4(DestToV4),
     V6(DestToV6),
 }
 
 /// IPv4 SendTo
 #[derive(Clone, Debug)]
+#[allow(dead_code)]
 pub struct DestToV4 {
     pub(crate) sockaddr: libc::sockaddr_in,
     pub(crate) socklen_t: libc::socklen_t,
 }
 
 /// IPv6 SendTo
 #[derive(Clone, Debug)]
+#[allow(dead_code)]
 pub struct DestToV6 {
     pub(crate) sockaddr: libc::sockaddr_in6,
     pub(crate) socklen_t: libc::socklen_t,

io-uring-bearer/src/uring.rs

@@ -111,7 +111,7 @@ impl<C: core::fmt::Debug + Clone + OpCompletion> UringBearer<C> {
     {
         // SAFETY: We Retain the original submission record and don't move it.
         unsafe {
-            self.handle_completions(user, |u, e, rec| {
+            self.handle_completions(user, None, |u, e, rec| {
                 func(u, e, rec);
                 SubmissionRecordStatus::Retain
             })
@@ -130,14 +130,15 @@ impl<C: core::fmt::Debug + Clone + OpCompletion> UringBearer<C> {
     pub unsafe fn handle_completions<F, U>(
         &mut self,
         user: &mut U,
+        #[allow(unused_variables)] limit: Option<u32>,
         func: F,
     ) -> Result<(), UringBearerError>
     where
         F: Fn(&mut U, &io_uring::cqueue::Entry, &Completion<C>) -> SubmissionRecordStatus,
     {
         let iou = &mut self.io_uring;
-        let c_queue = iou.completion();
-        for item in c_queue {
+        let mut c_queue = iou.completion();
+        while let Some(item) = c_queue.next() {
             let key = item.user_data();
             let a_rec_t = self
                 .fd_slab