Searched refs:process_tx_queue (Results 1 – 2 of 2) sorted by relevance
639 fn process_tx_queue(&mut self, vring: &VringRwLock) -> Result<bool> { in process_tx_queue() method707 self.process_tx_queue(vring_lock)?; in process_tx()713 self.process_tx_queue(vring_lock)?; in process_tx()
671 async fn process_tx_queue( in process_tx_queue() method1477 let tx_handler = self.process_tx_queue(tx_queue, tx_evt_async, send, stop_rx); in run()