Merge pull request #231 from Berrysoft/fix/iour-op

fix(driver,iour): wrong impl of WriteVectoredAt

compio-driver/src/iour/op.rs

@@ -174,7 +174,7 @@ impl<T: IoVectoredBuf> OpCode for WriteVectoredAt<T> {
     fn create_entry(self: Pin<&mut Self>) -> OpEntry {
         let this = unsafe { self.get_unchecked_mut() };
         this.slices = unsafe { this.buffer.as_io_slices() };
-        opcode::Write::new(
+        opcode::Writev::new(
             Fd(this.fd),
             this.slices.as_ptr() as _,
             this.slices.len() as _,

compio-fs/tests/file.rs

@@ -1,7 +1,7 @@
 use std::io::prelude::*;
 
 use compio_fs::File;
-use compio_io::{AsyncReadAtExt, AsyncWriteAtExt};
+use compio_io::{AsyncReadAtExt, AsyncWriteAt, AsyncWriteAtExt};
 use tempfile::NamedTempFile;
 
 #[compio_macros::test]
@@ -51,6 +51,21 @@ async fn basic_write() {
     assert_eq!(file, HELLO);
 }
 
+#[compio_macros::test]
+async fn writev() {
+    let tempfile = tempfile();
+
+    let mut file = File::create(tempfile.path()).await.unwrap();
+
+    let (write, _) = file.write_vectored_at([HELLO, HELLO], 0).await.unwrap();
+    assert_eq!(write, HELLO.len() * 2);
+    file.sync_all().await.unwrap();
+
+    let file = std::fs::read(tempfile.path()).unwrap();
+    assert_eq!(&file[..HELLO.len()], HELLO);
+    assert_eq!(&file[HELLO.len()..], HELLO);
+}
+
 #[compio_macros::test]
 async fn cancel_read() {
     let mut tempfile = tempfile();