(&mut self)
| 216 | } |
| 217 | |
| 218 | fn process_tx(&mut self) -> result::Result<(), DeviceError> { |
| 219 | let res = self |
| 220 | .net |
| 221 | .process_tx(&self.mem.memory(), &mut self.queue_pair.1) |
| 222 | .map_err(DeviceError::NetQueuePair)?; |
| 223 | |
| 224 | if res { |
| 225 | self.signal_used_queue(self.queue_index_base + 1)?; |
| 226 | debug!("Signalling TX queue"); |
| 227 | } else { |
| 228 | debug!("Not signalling TX queue"); |
| 229 | } |
| 230 | Ok(()) |
| 231 | } |
| 232 | |
| 233 | fn handle_tx_event(&mut self) -> result::Result<(), DeviceError> { |
| 234 | let rate_limit_reached = self |
no test coverage detected