Add test for SubmitArgs::min_wait_usec

Author: beviu

io-uring-test/src/main.rs

@@ -115,6 +115,7 @@ fn test<S: squeue::EntryMarker, C: cqueue::EntryMarker>(
     tests::timeout::test_timeout_cancel(&mut ring, &test)?;
     tests::timeout::test_timeout_abs(&mut ring, &test)?;
     tests::timeout::test_timeout_submit_args(&mut ring, &test)?;
+    tests::timeout::test_timeout_submit_args_min_wait(&mut ring, &test)?;
 
     // net
     tests::net::test_tcp_write_read(&mut ring, &test)?;

io-uring-test/src/tests/timeout.rs

@@ -381,3 +381,55 @@ pub fn test_timeout_submit_args<S: squeue::EntryMarker, C: cqueue::EntryMarker>(
 
     Ok(())
 }
+
+pub fn test_timeout_submit_args_min_wait<S: squeue::EntryMarker, C: cqueue::EntryMarker>(
+    ring: &mut IoUring<S, C>,
+    test: &Test,
+) -> anyhow::Result<()> {
+    require! {
+        test;
+        ring.params().is_feature_ext_arg();
+        ring.params().is_feature_min_timeout();
+    };
+
+    println!("test timeout_submit_args_min_wait");
+
+    let ts = types::Timespec::new().sec(2);
+    let args = types::SubmitArgs::new()
+        .timespec(&ts)
+        .min_wait_usec(1_000_000);
+
+    // timeout
+
+    let start = Instant::now();
+    match ring.submitter().submit_with_args(2, &args) {
+        Ok(_) => panic!(),
+        Err(ref err) if err.raw_os_error() == Some(libc::ETIME) => (),
+        Err(err) => return Err(err.into()),
+    }
+    assert_eq!(start.elapsed().as_secs(), 2);
+
+    assert!(ring.completion().next().is_none());
+
+    // no timeout
+
+    let nop_e = opcode::Nop::new();
+
+    unsafe {
+        ring.submission()
+            .push(&nop_e.build().user_data(0x1d).into())
+            .expect("queue is full");
+    }
+
+    let start = Instant::now();
+    ring.submitter().submit_with_args(2, &args)?;
+    assert_eq!(start.elapsed().as_secs(), 1);
+
+    let cqes: Vec<cqueue::Entry> = ring.completion().map(Into::into).collect();
+
+    assert_eq!(cqes.len(), 1);
+    assert_eq!(cqes[0].user_data(), 0x1d);
+    assert_eq!(cqes[0].result(), 0);
+
+    Ok(())
+}