| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 284 let track = self.track.lock().await; in track()
507 let lock = self.initial_track_id.lock().unwrap(); in initial_track_id() localVariable
509 lock.clone() in initial_track_id()
513 let mut lock = self.initial_track_id.lock().unwrap(); in set_initial_track_id() localVariable
515 if lock.is_some() { in set_initial_track_id()
519 *lock = Some(id); in set_initial_track_id()
525 let mut lock = self.associated_media_stream_ids.lock().unwrap(); in associate_media_stream_id() localVariable
527 if lock.contains(&id) { in associate_media_stream_id()
531 lock.push(id); in associate_media_stream_id()
537 let lock = self.associated_media_stream_ids.lock().unwrap(); in associated_media_stream_ids() localVariable
[all …]
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 37 let mut net = nic.lock().await; in add_addrs_to_interface()
43 let net = nic.lock().await; in set_router()
100 let net = nic.lock().await; in get_static_ips()
106 let n = nic.lock().await; in get_ipaddr()
170 let mut w = wan.lock().await; in test_router_standalone_add_net()
174 let n = nic.lock().await; in test_router_standalone_add_net()
219 let n = nic.lock().await; in test_router_standalone_routing()
225 let n = nic.lock().await; in test_router_standalone_routing()
239 let mut r = wan.lock().await; in test_router_standalone_routing()
716 let n = lan.lock().await; in test_router_static_ips_1to1_nat()
[all …]
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 55 let mut guard = self.0.lock(); in enable()
71 self.0.lock().reset_needed = true; in reset_offset()
79 let mut guard = self.0.lock(); in seq_number()
150 let mut stream = self.rtcp_read_stream.lock().await; in init()
156 let mut session = self.rtp_write_session.lock().await; in init()
170 let mut stream = self.rtcp_read_stream.lock().await; in close()
183 let stream = self.rtcp_read_stream.lock().await; in read()
195 let stream = self.rtcp_read_stream.lock().await; in read()
209 let session = self.rtp_write_session.lock().await; in write_rtp()
221 let session = self.rtp_write_session.lock().await; in write_rtp()
[all …]
|
| /webrtc/ |
| H A D | .gitignore | 8 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
9 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
10 Cargo.lock
11 /crates/Cargo.lock
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 109 let conn = self.conn.lock().await; in conn()
123 let mut f = handler.lock().await; in state_change()
146 let srtcp_session = self.srtcp_session.lock().await; in write_rtcp()
205 let mut srtp_session = self.srtp_session.lock().await; in start_srtp()
207 let se = self.srtp_endpoint.lock().await; in start_srtp()
245 let mut srtcp_session = self.srtcp_session.lock().await; in start_srtp()
247 let se = self.srtcp_endpoint.lock().await; in start_srtp()
275 let srtp_session = self.srtp_session.lock().await; in get_srtp_session()
280 let srtcp_session = self.srtcp_session.lock().await; in get_srtcp_session()
335 let mut rp = self.remote_parameters.lock().await; in prepare_transport()
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 124 let permissions = self.permissions.lock().await; in has_permission()
133 let permissions = self.permissions.lock().await; in add_permission()
144 let mut permissions = self.permissions.lock().await; in add_permission()
151 let mut permissions = self.permissions.lock().await; in remove_permission()
234 let mut permissions = self.permissions.lock().await; in close()
268 self.reset_tx.lock().replace(reset_tx); in start()
283 let mut alls = allocs.lock().await; in start()
305 let reset_tx = self.reset_tx.lock().take(); in stop()
311 let reset_tx = self.reset_tx.lock().clone(); in refresh()
381 let cbs = channel_bindings.lock().await; in packet_handler()
[all …]
|
| H A D | allocation_manager.rs | 41 let allocations = self.allocations.lock().await; in close()
56 let guarded = self.allocations.lock().await; in get_allocations_info()
77 let allocations = self.allocations.lock().await; in get_allocation()
118 let mut allocations = self.allocations.lock().await; in create_allocation()
127 let allocation = self.allocations.lock().await.remove(five_tuple); in delete_allocation()
139 let mut allocations = self.allocations.lock().await; in delete_allocations_by_username()
175 let mut reservations = reservations.lock().await; in create_reservation()
181 let mut reservations = self.reservations.lock().await; in create_reservation()
187 let reservations = self.reservations.lock().await; in get_reservation()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 117 let id = self.id.lock(); in id()
122 let mut id = self.id.lock(); in set_id()
128 let stream_id = self.stream_id.lock(); in stream_id()
133 let mut stream_id = self.stream_id.lock(); in set_stream_id()
178 let codec = self.codec.lock(); in codec()
183 let mut c = self.codec.lock(); in set_codec()
188 let p = self.params.lock(); in params()
193 let mut p = self.params.lock(); in set_params()
264 let mut codec = self.codec.lock(); in check_and_update_track()
320 (f.lock().await)().await in fire_onmute()
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | periodic_timer.rs | 49 let close_tx = self.close_tx.lock().await; in start()
66 let mut handler = timeout_handler.lock().await; in start()
75 let mut close = self.close_tx.lock().await; in start()
84 let mut close_tx = self.close_tx.lock().await; in stop()
91 let close_tx = self.close_tx.lock().await; in is_running()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | mod.rs | 210 let _ = self.on_open_handler.lock().replace(f); in on_open()
259 let mut f = handler.lock().await; in do_message()
356 let mut f = handler.lock().await; in read_loop()
370 let data_channel = self.data_channel.lock().await; in send()
382 let data_channel = self.data_channel.lock().await; in send_text()
411 let data_channel = self.data_channel.lock().await; in detach()
431 let data_channel = self.data_channel.lock().await; in close()
502 let data_channel = self.data_channel.lock().await; in buffered_amount()
517 let data_channel = self.data_channel.lock().await; in buffered_amount_low_threshold()
530 let data_channel = self.data_channel.lock().await; in set_buffered_amount_low_threshold()
[all …]
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 90 let close_tx = self.close_tx.lock().await; in is_closed()
99 let mut close_rx = internal.close_rx.lock().await; in run()
107 let mut packet_chan_rx = internal.packet_chan_rx.lock().await; in run()
125 let mut recorder = internal.recorder.lock().await; in run()
132 let mut recorder = internal.recorder.lock().await; in run()
171 let mut recorder = self.internal.recorder.lock().await; in bind_rtcp_writer()
176 let wait_group = self.wg.lock().await; in bind_rtcp_writer()
232 let mut streams = self.internal.streams.lock().await; in bind_remote_stream()
241 let mut streams = self.internal.streams.lock().await; in unbind_remote_stream()
248 let mut close_tx = self.close_tx.lock().await; in close()
[all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_time.rs | 21 let mut cur_now = self.cur_now.lock(); in set_now()
27 let cur_now = self.cur_now.lock(); in now()
33 let mut cur_now = self.cur_now.lock(); in advance()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 40 let close_tx = self.close_tx.lock().await; in is_closed()
50 let mut close_rx = internal.close_rx.lock().await; in run()
68 let m = internal.streams.lock().await; in run()
110 let wait_group = self.wg.lock().await; in bind_rtcp_writer()
139 let mut streams = self.internal.streams.lock().await; in bind_local_stream()
148 let mut streams = self.internal.streams.lock().await; in unbind_local_stream()
168 let mut close_tx = self.close_tx.lock().await; in close()
173 let mut wait_group = self.wg.lock().await; in close()
|
| /webrtc/util/src/vnet/ |
| H A D | nat.rs | 202 let mut filters = m.filters.lock().await; in translate_outbound()
259 let mut filters = m.filters.lock().await; in translate_outbound()
322 let filters = m.filters.lock().await; in translate_inbound()
369 let outbound_map = self.outbound_map.lock().await; in find_outbound_mapping()
374 let mut expires = m.expires.lock().await; in find_outbound_mapping()
402 let outbound_map = self.outbound_map.lock().await; in find_outbound_mapping()
410 let inbound_map = self.inbound_map.lock().await; in find_inbound_mapping()
415 let expires = m.expires.lock().await; in find_inbound_mapping()
441 let inbound_map = self.inbound_map.lock().await; in find_inbound_mapping()
455 let inbound_map = self.inbound_map.lock().await; in inbound_map_len()
[all …]
|
| /webrtc/interceptor/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/rtp/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/turn/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/srtp/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/media/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/data/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/mdns/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/sctp/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/stun/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/ice/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|
| /webrtc/examples/ |
| H A D | .gitignore | 6 # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries
7 # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html
8 Cargo.lock
|