Searched refs:accept_ch_tx (Results 1 – 4 of 4) sorted by relevance
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener.rs | 27 accept_ch_tx: Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>, field
62 let mut accept_ch = self.accept_ch_tx.lock().await; in close()
104 let (accept_ch_tx, accept_ch_rx) = mpsc::channel(self.backlog); in listen()
110 accept_ch_tx: Arc::new(Mutex::new(Some(accept_ch_tx))), in listen()
119 let accept_ch_tx = Arc::clone(&l.accept_ch_tx); in listen() localVariable
127 accept_ch_tx, in listen()
145 accept_ch_tx: Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>, in read_loop()
162 &accept_ch_tx, in read_loop()
191 accept_ch_tx: &Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>, in get_udp_conn()
215 let accept_ch = accept_ch_tx.lock().await; in get_udp_conn()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 52 let (accept_ch_tx, _accept_ch_rx) = mpsc::channel(1); in create_association_internal()
58 accept_ch_tx, in create_association_internal()
324 let (accept_ch_tx, _accept_ch_rx) = mpsc::channel(ACCEPT_CH_SIZE); in test_assoc_create_new_stream()
326 accept_ch_tx: Some(accept_ch_tx), in test_assoc_create_new_stream()
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 289 let (accept_ch_tx, accept_ch_rx) = mpsc::channel(ACCEPT_CH_SIZE); in new()
299 accept_ch_tx, in new()
|
| H A D | association_internal.rs | 79 accept_ch_tx: Option<mpsc::Sender<Arc<Stream>>>, field
98 accept_ch_tx: mpsc::Sender<Arc<Stream>>, in new()
143 accept_ch_tx: Some(accept_ch_tx), in new()
1047 if let Some(accept_ch) = &self.accept_ch_tx { in create_stream()
|