chore epend on io-uring version ^0.5.8 (#153)

io-uring v0.5.8 handles the overflow of the cqueue so this bump on the
dependancy fixes hangs caused when high frequency submissions fill the
cqueue.

While we're at it, adds a unit test for such a hanging cqueue.

Author: FrankReh

Cargo.toml

@@ -21,8 +21,8 @@ tokio = { version = "1.2", features = ["net", "rt"] }
 scoped-tls = "1.0.0"
 slab = "0.4.2"
 libc = "0.2.80"
-io-uring = { version = "0.5.0", features = [ "unstable" ] }
-socket2 = { version = "0.4.4", features = [ "all"] }
+io-uring = { version = "0.5.8", features = ["unstable"] }
+socket2 = { version = "0.4.4", features = ["all"] }
 bytes = { version = "1.0", optional = true }
 
 [dev-dependencies]

tests/driver.rs

@@ -90,6 +90,38 @@ fn too_many_submissions() {
     });
 }
 
+#[test]
+fn completion_overflow() {
+    use std::process;
+    use std::{thread, time};
+    use tokio::task::JoinSet;
+
+    let spawn_cnt = 50;
+    let squeue_entries = 2;
+    let cqueue_entries = 2 * squeue_entries;
+
+    std::thread::spawn(|| {
+        thread::sleep(time::Duration::from_secs(8)); // 1000 times longer than it takes on a slow machine
+        eprintln!("Timeout reached. The uring completions are hung.");
+        process::exit(1);
+    });
+
+    tokio_uring::builder()
+        .entries(squeue_entries)
+        .uring_builder(tokio_uring::uring_builder().setup_cqsize(cqueue_entries))
+        .start(async move {
+            let mut js = JoinSet::new();
+
+            for _ in 0..spawn_cnt {
+                js.spawn_local(tokio_uring::no_op());
+            }
+
+            while let Some(res) = js.join_next().await {
+                res.unwrap().unwrap();
+            }
+        });
+}
+
 fn tempfile() -> NamedTempFile {
     NamedTempFile::new().unwrap()
 }