feat(driver): use RawFd instead of HANDLE

Author: Berrysoft

compio-driver/src/iocp/cp/global.rs

@@ -61,7 +61,7 @@ fn iocp_start() -> io::Result<()> {
                 syscall!(
                     BOOL,
                     PostQueuedCompletionStatus(
-                        overlapped.driver,
+                        overlapped.driver as _,
                         entry.dwNumberOfBytesTransferred,
                         entry.lpCompletionKey,
                         entry.lpOverlapped,

compio-driver/src/iocp/cp/mod.rs

@@ -9,7 +9,7 @@ use compio_log::*;
 use windows_sys::Win32::{
     Foundation::{
         RtlNtStatusToDosError, ERROR_BAD_COMMAND, ERROR_HANDLE_EOF, ERROR_IO_INCOMPLETE,
-        ERROR_NO_DATA, FACILITY_NTWIN32, HANDLE, INVALID_HANDLE_VALUE, NTSTATUS, STATUS_PENDING,
+        ERROR_NO_DATA, FACILITY_NTWIN32, INVALID_HANDLE_VALUE, NTSTATUS, STATUS_PENDING,
         STATUS_SUCCESS,
     },
     Storage::FileSystem::SetFileCompletionNotificationModes,
@@ -120,7 +120,7 @@ impl CompletionPort {
     pub fn poll(
         &self,
         timeout: Option<Duration>,
-        current_driver: Option<HANDLE>,
+        current_driver: Option<RawFd>,
     ) -> io::Result<impl Iterator<Item = Entry>> {
         Ok(self.poll_raw(timeout)?.map(move |entry| {
             // Any thin pointer is OK because we don't use the type of opcode.
@@ -132,7 +132,7 @@ impl CompletionPort {
                     syscall!(
                         BOOL,
                         PostQueuedCompletionStatus(
-                            overlapped.driver,
+                            overlapped.driver as _,
                             entry.dwNumberOfBytesTransferred,
                             entry.lpCompletionKey,
                             entry.lpOverlapped,

compio-driver/src/iocp/cp/multi.rs

@@ -28,7 +28,7 @@ impl Port {
     }
 
     pub fn poll(&self, timeout: Option<Duration>) -> io::Result<impl Iterator<Item = Entry> + '_> {
-        let current_id = self.as_raw_handle() as _;
+        let current_id = self.as_raw_handle();
         self.port.poll(timeout, Some(current_id))
     }
 }

compio-driver/src/iocp/mod.rs

@@ -17,7 +17,7 @@ use compio_buf::BufResult;
 use compio_log::{instrument, trace};
 use slab::Slab;
 use windows_sys::Win32::{
-    Foundation::{ERROR_BUSY, ERROR_OPERATION_ABORTED, HANDLE},
+    Foundation::{ERROR_BUSY, ERROR_OPERATION_ABORTED},
     Networking::WinSock::{WSACleanup, WSAStartup, WSADATA},
     System::IO::OVERLAPPED,
 };
@@ -294,7 +294,7 @@ pub struct Overlapped<T: ?Sized> {
     /// The base [`OVERLAPPED`].
     pub base: OVERLAPPED,
     /// The unique ID of created driver.
-    pub driver: HANDLE,
+    pub driver: RawFd,
     /// The registered user defined data.
     pub user_data: usize,
     /// The opcode.
@@ -303,7 +303,7 @@ pub struct Overlapped<T: ?Sized> {
 }
 
 impl<T> Overlapped<T> {
-    pub(crate) fn new(driver: HANDLE, user_data: usize, op: T) -> Self {
+    pub(crate) fn new(driver: RawFd, user_data: usize, op: T) -> Self {
         Self {
             base: unsafe { std::mem::zeroed() },
             driver,
@@ -326,7 +326,7 @@ pub(crate) struct RawOp {
 }
 
 impl RawOp {
-    pub(crate) fn new(driver: HANDLE, user_data: usize, op: impl OpCode + 'static) -> Self {
+    pub(crate) fn new(driver: RawFd, user_data: usize, op: impl OpCode + 'static) -> Self {
         let op = Overlapped::new(driver, user_data, op);
         let op = Box::new(op) as Box<Overlapped<dyn OpCode>>;
         Self {