Searched refs:packet_tx (Results 1 – 3 of 3) sorted by relevance
305 let (packet_tx, packet_rx) = mpsc::channel(1); in test_get_stats()308 let packet_tx = packet_tx.clone(); in test_get_stats() localVariable315 let _ = packet_tx.send(()).await; in test_get_stats()
67 packet_tx: Arc<mpsc::Sender<PacketSendRequest>>, field99 pub(crate) packet_tx: Arc<mpsc::Sender<PacketSendRequest>>, field257 let (packet_tx, mut packet_rx) = mpsc::channel(1); in new()261 let packet_tx = Arc::new(packet_tx); in new() localVariable262 let packet_tx2 = Arc::clone(&packet_tx); in new()285 packet_tx, in new()339 packet_tx: packet_tx2, in new()514 self.packet_tx.send((pkts, Some(tx))).await?; in write_packets()761 .packet_tx in read_and_buffer()842 .packet_tx in handle_queued_packets()
397 let (packet_tx, _packet_rx) = mpsc::channel(1); in test_export_keying_material()433 packet_tx: Arc::new(packet_tx), in test_export_keying_material()