| /webrtc/turn/src/server/ |
| H A D | mod.rs | 84 let tx = { in delete_allocations_by_username() localVariable
88 if let Some(tx) = tx { in delete_allocations_by_username()
122 let tx = { in get_allocations_info() localVariable
126 if let Some(tx) = tx { in get_allocations_info()
128 tx.send(Command::GetAllocationsInfo(five_tuples, infos_tx)) in get_allocations_info()
133 for _ in 0..tx.receiver_count() { in get_allocations_info()
170 let _ = tx.send(infos).await; in read_loop()
223 let tx = { in close() localVariable
228 if let Some(tx) = tx { in close()
229 if tx.receiver_count() == 0 { in close()
[all …]
|
| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 19 let (tx, mut rx) = mpsc::channel(1); in test_bridge_normal()
24 let _ = tx.send(n).await; in test_bridge_normal()
45 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn0()
50 let _ = tx.send(n).await; in test_bridge_drop_1st_packet_from_conn0()
72 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_2nd_packet_from_conn0()
77 let _ = tx.send(n).await; in test_bridge_drop_2nd_packet_from_conn0()
99 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn1()
104 let _ = tx.send(n).await; in test_bridge_drop_1st_packet_from_conn1()
131 let _ = tx.send(n).await; in test_bridge_drop_2nd_packet_from_conn1()
170 let _ = tx.send(()).await; in test_bridge_reorder_packets_from_conn0()
[all …]
|
| H A D | conn_udp_listener.rs | 216 if let Some(tx) = &*accept_ch { in get_udp_conn()
217 if tx.try_send(Arc::clone(&udp_conn)).is_err() { in get_udp_conn()
|
| /webrtc/srtp/src/ |
| H A D | stream.rs | 16 tx: mpsc::Sender<u32>, field
23 pub fn new(ssrc: u32, tx: mpsc::Sender<u32>, is_rtp: bool) -> Self { in new()
26 tx, in new()
84 let _ = self.tx.send(self.ssrc).await; in close()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 107 tx, in new()
123 tx, in with_time_gen()
135 .tx in fetch_inbound_stats()
157 .tx in fetch_outbound_stats()
362 tx: self.tx.clone(), in bind_rtcp_writer()
377 tx: self.tx.clone(), in bind_rtcp_reader()
553 .tx in read()
679 .tx in write()
692 .tx in write()
732 .tx in read()
[all …]
|
| /webrtc/examples/examples/signal/src/ |
| H A D | lib.rs | 34 if let Some(tx) = &*sdp_chan_tx { in remote_handler()
35 let _ = tx.send(sdp_str).await; in remote_handler()
56 let mut tx = SDP_CHAN_TX_MUTEX.lock().await; in http_sdp_server() localVariable
57 *tx = Some(sdp_chan_tx); in http_sdp_server()
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 30 let (tx, rx) = mpsc::channel::<String>(3);
31 (Arc::new(Mutex::new(tx)), Arc::new(Mutex::new(rx)))
35 let (tx, rx) = mpsc::channel::<String>(10);
36 (Arc::new(Mutex::new(tx)), Arc::new(Mutex::new(rx)))
50 let tx = REMOTE_AUTH_CHANNEL.0.lock().await; in remote_handler() localVariable
52 let _ = tx.send(full_body).await; in remote_handler()
65 let tx = REMOTE_CAND_CHANNEL.0.lock().await; in remote_handler() localVariable
67 let _ = tx.send(full_body).await; in remote_handler()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_test.rs | 196 tx.take(); in test_on_selected_candidate_pair_change()
470 tx.take(); in test_connectivity_on_startup()
1663 tx.take(); in test_connection_state_failed_delete_all_candidates()
1830 tx.take(); in test_agent_restart_one_side()
1988 tx.take(); in test_close_in_connection_state_callback()
1991 tx.take(); in test_close_in_connection_state_callback()
2042 tx.take(); in test_run_task_in_connection_state_callback()
2094 tx.take(); in test_run_task_in_selected_candidate_pair_change_callback()
2106 tx.take(); in test_run_task_in_selected_candidate_pair_change_callback()
2174 tx.take(); in test_lite_lifecycle()
[all …]
|
| H A D | agent_gather_test.rs | 161 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_with_nat_1to1_as_host_candidates() localVariable
162 tx.take(); in test_vnet_gather_with_nat_1to1_as_host_candidates()
278 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_with_nat_1to1_as_srflx_candidates() localVariable
279 tx.take(); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
462 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_muxed_udp() localVariable
463 tx.take(); in test_vnet_gather_muxed_udp()
|
| H A D | agent_internal.rs | 322 if let Some(tx) = &*chan_state_tx { in update_connection_state()
323 let _ = tx.send(new_state).await; in update_connection_state()
346 if let Some(tx) = &*chan_candidate_pair_tx { in set_selected_pair()
347 let _ = tx.send(()).await; in set_selected_pair()
559 (*started_ch_tx).as_ref().map(|tx| tx.subscribe()) in add_candidate()
605 if let Some(tx) = &*chan_candidate_tx { in add_candidate()
606 let _ = tx.send(Some(c.clone())).await; in add_candidate()
|
| /webrtc/turn/src/allocation/ |
| H A D | permission.rs | 73 if let Some(tx) = &self.reset_tx { in refresh()
74 let _ = tx.send(lifetime).await; in refresh()
|
| H A D | channel_bind.rs | 79 if let Some(tx) = &self.reset_tx { in refresh()
80 let _ = tx.send(lifetime).await; in refresh()
|
| /webrtc/dtls/src/flight/ |
| H A D | flight2.rs | 30 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse()
52 Err(_) => return Flight0 {}.parse(tx, state, cache, cfg).await, in parse()
|
| H A D | mod.rs | 74 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse()
|
| H A D | flight1.rs | 39 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse()
75 return flight3.parse(tx, state, cache, cfg).await; in parse()
|
| H A D | flight4.rs | 47 tx: &mut mpsc::Sender<mpsc::Sender<()>>, in parse()
398 if let Err(err) = tx.send(done_tx).await { in parse()
841 let (mut tx, _rx) = mpsc::channel::<mpsc::Sender<()>>(1); in test_flight4_process_certificateverify()
844 let res = f.parse(&mut tx, &mut state, &cache, &cfg).await; in test_flight4_process_certificateverify()
|
| /webrtc/ice/src/mdns/ |
| H A D | mdns_test.rs | 115 let mut tx = done_tx_clone.lock().await; in test_multicast_dns_static_host_name() localVariable
116 tx.take(); in test_multicast_dns_static_host_name()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_gatherer.rs | 350 let mut tx = gather_finished_tx_clone.lock().await; in test_new_ice_gatherer_success() localVariable
351 tx.take(); in test_new_ice_gatherer_success()
393 let mut tx = done_tx_clone.lock().await; in test_ice_gather_mdns_candidate_gathering() localVariable
394 tx.take(); in test_ice_gather_mdns_candidate_gathering()
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 178 if let Some(tx) = &*rtcp_in_tx { in receive_rtcp()
179 let _ = tx.send(pkts).await; in receive_rtcp()
186 if let Some(tx) = &*rtp_in_tx { in receive_rtp()
187 let _ = tx.send(pkt).await; in receive_rtp()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 19 if let Some(tx) = &*read_ch_tx { in write()
20 tx.send(Box::new(chunk)) in write()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 76 fn transition(to: Self, tx: &watch::Sender<State>) -> Result<()> { in transition()
77 let current = *tx.borrow(); in transition()
87 let _ = tx.send(to); in transition()
93 let _ = tx.send(to); in transition()
97 let _ = tx.send(to); in transition()
101 let _ = tx.send(to); in transition()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 146 let (tx, rx) = mpsc::channel(1); in new()
147 (Some(tx), Some(rx)) in new()
|
| /webrtc/util/src/vnet/ |
| H A D | net.rs | 58 if let Some(tx) = &*ch_tx { in write()
59 let _ = tx.send(c).await; in write()
166 if let Some(tx) = &*ch_tx { in on_inbound_chunk()
167 let _ = tx.send(c).await; in on_inbound_chunk()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 213 if let Some(tx) = closed_tx.take() { in close()
214 let _ = tx.send(true); in close()
|
| H A D | mod.rs | 230 if let Some(tx) = closed_tx.take() { in close()
231 let _ = tx.send(()); in close()
|