fix test close file

Author: hxzhao527

monoio/tests/fs_file.rs

@@ -1,6 +1,9 @@
 use std::{
     io::prelude::*,
-    os::unix::io::{AsRawFd, FromRawFd, RawFd},
+    os::unix::{
+        fs::MetadataExt,
+        io::{AsRawFd, FromRawFd, RawFd},
+    },
 };
 
 use monoio::fs::File;
@@ -21,6 +24,7 @@ async fn read_hello(file: &File) {
 async fn basic_read() {
     let mut tempfile = tempfile();
     tempfile.write_all(HELLO).unwrap();
+    tempfile.as_file_mut().sync_data().unwrap();
 
     let file = File::open(tempfile.path()).await.unwrap();
     read_hello(&file).await;
@@ -30,6 +34,7 @@ async fn basic_read() {
 async fn basic_read_exact() {
     let mut tempfile = tempfile();
     tempfile.write_all(HELLO).unwrap();
+    tempfile.as_file_mut().sync_data().unwrap();
 
     let file = File::open(tempfile.path()).await.unwrap();
     let buf = Vec::with_capacity(HELLO.len());
@@ -48,6 +53,7 @@ async fn basic_write() {
 
     let file = File::create(tempfile.path()).await.unwrap();
     file.write_at(HELLO, 0).await.0.unwrap();
+    file.sync_all().await.unwrap();
 
     let file = std::fs::read(tempfile.path()).unwrap();
     assert_eq!(file, HELLO);
@@ -59,6 +65,7 @@ async fn basic_write_all() {
 
     let file = File::create(tempfile.path()).await.unwrap();
     file.write_all_at(HELLO, 0).await.0.unwrap();
+    file.sync_all().await.unwrap();
 
     let file = std::fs::read(tempfile.path()).unwrap();
     assert_eq!(file, HELLO);
@@ -68,6 +75,7 @@ async fn basic_write_all() {
 async fn cancel_read() {
     let mut tempfile = tempfile();
     tempfile.write_all(HELLO).unwrap();
+    tempfile.as_file_mut().sync_data().unwrap();
 
     let file = File::open(tempfile.path()).await.unwrap();
 
@@ -81,13 +89,14 @@ async fn cancel_read() {
 async fn explicit_close() {
     let mut tempfile = tempfile();
     tempfile.write_all(HELLO).unwrap();
+    tempfile.as_file_mut().sync_data().unwrap();
 
     let file = File::open(tempfile.path()).await.unwrap();
     let fd = file.as_raw_fd();
 
     file.close().await.unwrap();
 
-    assert_invalid_fd(fd);
+    assert_invalid_fd(fd, tempfile.as_file().metadata().unwrap());
 }
 
 #[monoio::test_all]
@@ -97,6 +106,7 @@ async fn drop_open() {
     // Do something else
     let file_w = File::create(tempfile.path()).await.unwrap();
     file_w.write_at(HELLO, 0).await.0.unwrap();
+    file_w.sync_all().await.unwrap();
 
     let file = std::fs::read(tempfile.path()).unwrap();
     assert_eq!(file, HELLO);
@@ -118,7 +128,7 @@ fn drop_off_runtime() {
     let fd = file.as_raw_fd();
     drop(file);
 
-    assert_invalid_fd(fd);
+    assert_invalid_fd(fd, tempfile.as_file().metadata().unwrap());
 }
 
 #[monoio::test_all]
@@ -151,11 +161,26 @@ async fn poll_once(future: impl std::future::Future) {
     .await;
 }
 
-fn assert_invalid_fd(fd: RawFd) {
+fn assert_invalid_fd(fd: RawFd, base: std::fs::Metadata) {
     use std::fs::File;
 
-    let mut f = unsafe { File::from_raw_fd(fd) };
-    let mut buf = vec![];
-
-    assert!(f.read_to_end(&mut buf).is_err());
+    let f = unsafe { File::from_raw_fd(fd) };
+    let meta = f.metadata();
+    // The fd maybe used by others, so we can't close it now.
+    std::mem::forget(f);
+
+    if let Ok(meta) = meta {
+        if !meta.is_file() {
+            return;
+        }
+
+        #[cfg(unix)]
+        {
+            let inode = meta.ino();
+            let actual = base.ino();
+            if inode == actual {
+                panic!();
+            }
+        }
+    }
 }