MCPcopy Create free account
hub / github.com/cloud-hypervisor/cloud-hypervisor / process_tx

Method process_tx

virtio-devices/src/net.rs:218–231  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

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

Callers 3

handle_eventMethod · 0.45
handle_tx_eventMethod · 0.45
handle_eventMethod · 0.45

Calls 2

memoryMethod · 0.80
signal_used_queueMethod · 0.45

Tested by

no test coverage detected