| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | operation_test.rs | 8 let ops = Operations::new(); in test_operations_enqueue() localVariable
13 ops.enqueue(Operation::new( in test_operations_enqueue()
27 ops.done().await; in test_operations_enqueue()
43 let ops = Operations::new(); in test_operations_done() localVariable
44 ops.done().await; in test_operations_done()
|
| /webrtc/util/src/sync/ |
| H A D | mod.rs | 1 use std::{ops, sync};
30 impl<'a, T> ops::Deref for MutexGuard<'a, T> {
38 impl<'a, T> ops::DerefMut for MutexGuard<'a, T> {
75 impl<'a, T> ops::Deref for RwLockReadGuard<'a, T> {
87 impl<'a, T> ops::Deref for RwLockWriteGuard<'a, T> {
95 impl<'a, T> ops::DerefMut for RwLockWriteGuard<'a, T> {
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_cbc.rs | 12 use std::ops::Not;
|
| /webrtc/constraints/src/settings/ |
| H A D | track.rs | 4 ops::{Deref, DerefMut},
|
| /webrtc/constraints/src/capabilities/ |
| H A D | track.rs | 4 ops::{Deref, DerefMut},
|
| /webrtc/constraints/src/constraints/ |
| H A D | advanced.rs | 3 ops::{Deref, DerefMut},
|
| H A D | constraint_set.rs | 3 ops::{Deref, DerefMut},
|
| H A D | mandatory.rs | 3 ops::{Deref, DerefMut},
|
| /webrtc/constraints/src/capability/ |
| H A D | value_range.rs | 1 use std::ops::{RangeFrom, RangeInclusive, RangeToInclusive};
|
| /webrtc/constraints/src/ |
| H A D | supported_constraints.rs | 4 ops::{Deref, DerefMut},
|
| H A D | capability.rs | 5 use std::ops::RangeInclusive;
|
| H A D | constraint.rs | 1 use std::ops::Deref;
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 4 use std::ops::Add;
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | mod.rs | 174 ops: Arc<Operations>, field
350 .ops in do_negotiation_needed()
388 if !params.ops.is_empty().await { in negotiation_needed_op()
1265 .ops in set_local_description()
1501 .ops in set_remote_description()
1552 .ops in set_remote_description()
1954 if let Err(err) = self.internal.ops.close().await { in close()
|
| H A D | certificate.rs | 6 use std::ops::Add;
|
| H A D | peer_connection_internal.rs | 34 pub(crate) ops: Arc<Operations>, field
84 ops: Arc::new(Operations::new()), in new()
554 ops: Arc::clone(&self.ops), in create_negotiation_needed_params()
|
| /webrtc/util/src/vnet/ |
| H A D | chunk.rs | 9 use std::ops::{BitAnd, BitOr};
|
| H A D | nat.rs | 10 use std::ops::Add;
|
| H A D | router.rs | 17 use std::ops::{Add, Sub};
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | mod.rs | 248 let is_different_timestamp = is_same_timestamp.map(std::ops::Not::not); in build_sample()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 305 offer_pc.internal.ops.done().await; in test_rtp_transceiver_set_direction_causing_negotiation()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_base.rs | 13 ops::Add,
|
| /webrtc/stun/src/ |
| H A D | client.rs | 13 use std::ops::Add;
|
| /webrtc/media/src/audio/ |
| H A D | buffer.rs | 6 ops::Range,
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 6 use std::ops::{Add, Sub};
|