Searched refs:read_ch_tx (Results 1 – 4 of 4) sorted by relevance
73 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, field205 read_ch_tx: Arc::new(Mutex::new(None)), in new()221 let read_ch_tx = Arc::clone(&self.read_ch_tx); in listen() localVariable239 &read_ch_tx, in listen()265 read_ch_tx: &Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, in handle_inbound()405 let read_ch_tx_opt = read_ch_tx.lock().await; in handle_inbound_relay_conn()427 let mut read_ch_tx = self.read_ch_tx.lock().await; in close() localVariable428 read_ch_tx.take(); in close()486 let read_ch_tx = self.read_ch_tx.lock().await; in allocate() localVariable488 if read_ch_tx.is_some() { in allocate()[all …]
33 read_ch_tx: Arc<Mutex<Option<ChunkChTx>>>, field45 let (read_ch_tx, read_ch_rx) = mpsc::channel(MAX_READ_QUEUE_SIZE); in new()50 read_ch_tx: Arc::new(Mutex::new(Some(read_ch_tx))), in new()58 Arc::clone(&self.read_ch_tx) in get_inbound_ch()149 let mut reach_ch = self.read_ch_tx.lock().await; in close()
56 let read_ch_tx = conn.get_inbound_ch(); in write() localVariable57 let ch_tx = read_ch_tx.lock().await; in write()164 let read_ch_tx = conn.get_inbound_ch(); in on_inbound_chunk() localVariable165 let ch_tx = read_ch_tx.lock().await; in on_inbound_chunk()
9 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<Box<dyn Chunk + Send + Sync>>>>>, field18 let read_ch_tx = self.read_ch_tx.lock().await; in write() localVariable19 if let Some(tx) = &*read_ch_tx { in write()68 dummy.read_ch_tx = conn.get_inbound_ch(); in test_udp_conn_send_to_recv_from()155 dummy.read_ch_tx = conn.get_inbound_ch(); in test_udp_conn_send_recv()