Home
last modified time | relevance | path

Searched refs:sync (Results 1 – 25 of 200) sorted by relevance

12345678

/webrtc/util/src/sync/
H A Dmod.rs1 use std::{ops, sync};
5 pub struct Mutex<T>(sync::Mutex<T>);
10 Self(sync::Mutex::new(value)) in new()
28 pub struct MutexGuard<'a, T>(sync::MutexGuard<'a, T>);
46 pub struct RwLock<T>(sync::RwLock<T>);
51 Self(sync::RwLock::new(value)) in new()
73 pub struct RwLockReadGuard<'a, T>(sync::RwLockReadGuard<'a, T>);
85 pub struct RwLockWriteGuard<'a, T>(sync::RwLockWriteGuard<'a, T>);
/webrtc/util/
H A DCargo.toml16 default = ["buffer", "conn", "ifaces", "vnet", "marshal", "sync"]
18 conn = ["buffer", "sync"]
22 sync = []
/webrtc/turn/src/server/
H A Dconfig.rs8 use std::sync::Arc;
9 use tokio::sync::mpsc;
/webrtc/ice/src/rand/
H A Drand_test.rs4 use std::sync::Arc;
5 use tokio::sync::Mutex;
/webrtc/interceptor/src/twcc/sender/
H A Dmod.rs10 use std::sync::atomic::{AtomicU32, Ordering};
11 use std::sync::Arc;
12 use tokio::sync::Mutex;
/webrtc/interceptor/
H A DCargo.toml14 …th = "../util", package = "webrtc-util", default-features = false, features = ["marshal", "sync"] }
19 tokio = { version = "1.19", features = ["sync", "time"] }
/webrtc/ice/src/candidate/
H A Dcandidate_peer_reflexive.rs6 use std::sync::atomic::{AtomicU16, AtomicU8};
8 use util::sync::Mutex as SyncMutex;
H A Dcandidate_server_reflexive.rs6 use std::sync::atomic::{AtomicU16, AtomicU8};
7 use util::sync::Mutex as SyncMutex;
H A Dcandidate_relay.rs6 use std::sync::{
10 use util::sync::Mutex as SyncMutex;
/webrtc/examples/examples/data-channels-close/
H A Ddata-channels-close.rs4 use std::sync::atomic::{AtomicI32, Ordering};
5 use std::sync::Arc;
6 use tokio::sync::Mutex;
114 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
148 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
/webrtc/util/src/vnet/
H A Dconn.rs6 use crate::sync::RwLock;
10 use tokio::sync::{mpsc, Mutex};
13 use std::sync::atomic::{AtomicBool, Ordering};
14 use std::sync::Arc;
H A Dresolver.rs11 use std::sync::Arc;
12 use tokio::sync::Mutex;
/webrtc/sctp/src/timer/
H A Dack_timer.rs2 use std::sync::Weak;
3 use tokio::sync::{mpsc, Mutex};
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs12 use std::sync::atomic::{AtomicBool, Ordering};
13 use std::sync::{Arc, Weak};
14 use tokio::sync::Mutex;
22 pub(crate) struct SequenceTransformer(util::sync::Mutex<SequenceTransformerInner>);
36 Self(util::sync::Mutex::new(SequenceTransformerInner { in new()
/webrtc/webrtc/src/peer_connection/operation/
H A Dmod.rs7 use std::sync::atomic::{AtomicUsize, Ordering};
8 use std::sync::Arc;
9 use tokio::sync::mpsc;
/webrtc/webrtc/src/track/track_local/
H A Dmod.rs15 use std::sync::atomic::{AtomicBool, Ordering};
16 use std::sync::Arc;
17 use tokio::sync::Mutex;
/webrtc/util/src/conn/
H A Dconn_disconnected_packet.rs4 use std::sync::Arc;
6 use crate::sync::RwLock;
/webrtc/turn/src/client/
H A Dpermission.rs3 use std::sync::atomic::{AtomicU8, Ordering};
4 use std::sync::Arc;
H A Dperiodic_timer.rs4 use tokio::sync::{mpsc, Mutex};
7 use std::sync::Arc;
/webrtc/stun/examples/
H A Dstun_client.rs8 use std::sync::Arc;
40 let (handler_tx, mut handler_rx) = tokio::sync::mpsc::unbounded_channel(); in main()
/webrtc/rtp/src/
H A Dsequence.rs2 use std::sync::atomic::{AtomicU16, AtomicU64, Ordering};
3 use std::sync::Arc;
/webrtc/examples/examples/swap-tracks/
H A Dswap-tracks.rs4 use std::sync::atomic::{AtomicUsize, Ordering};
5 use std::sync::Arc;
138 tokio::sync::mpsc::channel::<webrtc::rtp::packet::Packet>(60); in main()
206 let (connected_tx, mut connected_rx) = tokio::sync::mpsc::channel(1); in main()
207 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel(1); in main()
/webrtc/turn/src/allocation/
H A Dpermission.rs3 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
4 use tokio::sync::Mutex;
H A Dchannel_bind.rs7 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
8 use tokio::sync::Mutex;
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs21 use std::sync::atomic::{AtomicBool, Ordering};
22 use std::sync::{Arc, Weak};
23 use tokio::sync::{mpsc, Mutex, Notify};
24 use util::sync::Mutex as SyncMutex;
108 pub(crate) initial_track_id: std::sync::Mutex<Option<String>>,
110 pub(crate) associated_media_stream_ids: std::sync::Mutex<Vec<String>>,
199 initial_track_id: std::sync::Mutex::new(None), in new()
200 associated_media_stream_ids: std::sync::Mutex::new(stream_ids), in new()

12345678