Use mio to replace Epoll

Epoll is linux-specific. So we use mio, which is a cross-platform
event notification, to replace Epoll.

Signed-off-by: Wenyu Huang <huangwenyuu@outlook.com>

Author: uran0sH

vhost-user-backend/Cargo.toml

@@ -13,8 +13,11 @@ xen = ["vm-memory/xen", "vhost/xen"]
 postcopy = ["vhost/postcopy", "userfaultfd"]
 
 [dependencies]
+bitflags = "2.9.1"
+dashmap = "6.1.0"
 libc = "0.2.39"
 log = "0.4.17"
+mio = { version = "1.0.4", features = ["os-poll", "os-ext"] }
 userfaultfd = { version = "0.8.1", optional = true }
 vhost = { path = "../vhost", version = "0.14.0", features = ["vhost-user-backend"] }
 virtio-bindings = { workspace = true }

vhost-user-backend/src/backend.rs

@@ -23,17 +23,19 @@ use std::io::Result;
 use std::ops::Deref;
 use std::sync::{Arc, Mutex, RwLock};
 
+use mio::event::Event;
 use vhost::vhost_user::message::{
     VhostTransferStateDirection, VhostTransferStatePhase, VhostUserProtocolFeatures,
     VhostUserSharedMsg,
 };
 use vhost::vhost_user::Backend;
 use vm_memory::bitmap::Bitmap;
-use vmm_sys_util::epoll::EventSet;
 use vmm_sys_util::eventfd::EventFd;
 
 use vhost::vhost_user::GpuBackend;
 
+use crate::event_loop::VringEventSet;
+
 use super::vring::VringT;
 use super::GM;
 
@@ -144,7 +146,7 @@ pub trait VhostUserBackend: Send + Sync {
     fn handle_event(
         &self,
         device_event: u16,
-        evset: EventSet,
+        evset: VringEventSet,
         vrings: &[Self::Vring],
         thread_id: usize,
     ) -> Result<()>;
@@ -287,7 +289,7 @@ pub trait VhostUserBackendMut: Send + Sync {
     fn handle_event(
         &mut self,
         device_event: u16,
-        evset: EventSet,
+        evset: VringEventSet,
         vrings: &[Self::Vring],
         thread_id: usize,
     ) -> Result<()>;
@@ -389,7 +391,7 @@ impl<T: VhostUserBackend> VhostUserBackend for Arc<T> {
     fn handle_event(
         &self,
         device_event: u16,
-        evset: EventSet,
+        evset: VringEventSet,
         vrings: &[Self::Vring],
         thread_id: usize,
     ) -> Result<()> {
@@ -478,7 +480,7 @@ impl<T: VhostUserBackendMut> VhostUserBackend for Mutex<T> {
     fn handle_event(
         &self,
         device_event: u16,
-        evset: EventSet,
+        evset: VringEventSet,
         vrings: &[Self::Vring],
         thread_id: usize,
     ) -> Result<()> {
@@ -570,7 +572,7 @@ impl<T: VhostUserBackendMut> VhostUserBackend for RwLock<T> {
     fn handle_event(
         &self,
         device_event: u16,
-        evset: EventSet,
+        evset: VringEventSet,
         vrings: &[Self::Vring],
         thread_id: usize,
     ) -> Result<()> {
@@ -600,6 +602,7 @@ pub mod tests {
     use super::*;
     use crate::VringRwLock;
     use libc::EFD_NONBLOCK;
+    use mio::Interest;
     use std::sync::Mutex;
     use uuid::Uuid;
     use vm_memory::{GuestAddress, GuestMemoryAtomic, GuestMemoryMmap};
@@ -707,7 +710,7 @@ pub mod tests {
         fn handle_event(
             &mut self,
             _device_event: u16,
-            _evset: EventSet,
+            _evset: VringEventSet,
             _vrings: &[VringRwLock],
             _thread_id: usize,
         ) -> Result<()> {
@@ -793,7 +796,7 @@ pub mod tests {
 
         let vring = VringRwLock::new(mem, 0x1000).unwrap();
         backend
-            .handle_event(0x1, EventSet::IN, &[vring], 0)
+            .handle_event(0x1, (&Interest::READABLE).into(), &[vring], 0)
             .unwrap();
 
         backend.reset_device();