Searched refs:tx_queue_evt (Results 1 – 1 of 1) sorted by relevance
237 tx_queue_evt: EventFd, in run()257 .and_then(|pc| pc.add(&tx_queue_evt, Token::TxQueue).and(Ok(pc))) in run()292 if let Err(e) = tx_queue_evt.read() { in run()506 let tx_queue_evt = queue_evts.remove(0); in activate() localVariable507 let result = worker.run(rx_queue_evt, tx_queue_evt, kill_evt); in activate()