diff --git a/virtio-devices/src/net.rs b/virtio-devices/src/net.rs index 981ae8e30..3f3abd9f5 100644 --- a/virtio-devices/src/net.rs +++ b/virtio-devices/src/net.rs @@ -101,11 +101,7 @@ impl NetEpollHandler { Ok(()) } - fn handle_tx_event(&mut self) -> result::Result<(), DeviceError> { - let queue_evt = &self.queue_evt_pair[1]; - if let Err(e) = queue_evt.read() { - error!("Failed to get tx queue event: {:?}", e); - } + fn process_tx(&mut self) -> result::Result<(), DeviceError> { if self .net .process_tx(&mut self.queue_pair[1]) @@ -120,6 +116,17 @@ impl NetEpollHandler { Ok(()) } + fn handle_tx_event(&mut self) -> result::Result<(), DeviceError> { + let queue_evt = &self.queue_evt_pair[1]; + if let Err(e) = queue_evt.read() { + error!("Failed to get tx queue event: {:?}", e); + } + + self.process_tx()?; + + Ok(()) + } + fn handle_rx_tap_event(&mut self) -> result::Result<(), DeviceError> { if self .net