Home
last modified time | relevance | path

Searched refs:AtomicBool (Results 1 – 25 of 28) sorted by relevance

12

/webrtc/sctp/src/chunk/
H A Dchunk_payload_data.rs5 use std::sync::atomic::{AtomicBool, Ordering};
114 pub(crate) abandoned: Arc<AtomicBool>,
116 pub(crate) all_inflight: Arc<AtomicBool>,
139 abandoned: Arc::new(AtomicBool::new(false)), in default()
140 all_inflight: Arc::new(AtomicBool::new(false)), in default()
218 abandoned: Arc::new(AtomicBool::new(false)), in unmarshal()
219 all_inflight: Arc::new(AtomicBool::new(false)), in unmarshal()
/webrtc/webrtc/src/track/track_local/
H A Dmod.rs15 use std::sync::atomic::{AtomicBool, Ordering};
38 pub(crate) paused: Arc<AtomicBool>,
109 sender_paused: Arc<AtomicBool>,
120 sender_paused: Arc<AtomicBool>,
124 pub(crate) fn new(paused: Arc<AtomicBool>) -> Self { in new()
/webrtc/ice/src/candidate/
H A Dmod.rs25 use std::sync::atomic::{AtomicBool, AtomicU16, AtomicU8, Ordering};
229 pub(crate) ice_role_controlling: AtomicBool,
234 pub(crate) nominated: AtomicBool,
240 ice_role_controlling: AtomicBool::new(false), in default()
245 nominated: AtomicBool::new(false), in default()
292 ice_role_controlling: AtomicBool::new(controlling), in new()
297 nominated: AtomicBool::new(false), in new()
/webrtc/turn/src/allocation/
H A Dpermission.rs3 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
16 timer_expired: Arc<AtomicBool>,
26 timer_expired: Arc::new(AtomicBool::new(false)), in new()
H A Dchannel_bind.rs7 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
19 timer_expired: Arc<AtomicBool>,
30 timer_expired: Arc::new(AtomicBool::new(false)), in new()
H A Dmod.rs24 sync::{atomic::AtomicBool, atomic::Ordering, Arc},
82 timer_expired: Arc<AtomicBool>,
83 closed: AtomicBool, // Option<mpsc::Receiver<()>>,
114 timer_expired: Arc::new(AtomicBool::new(false)), in new()
115 closed: AtomicBool::new(false), in new()
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs21 use std::sync::atomic::{AtomicBool, Ordering};
31 pub(crate) stop_called_signal: Arc<AtomicBool>,
99 pub(crate) negotiated: AtomicBool,
116 stop_called_signal: Arc<AtomicBool>,
118 pub(crate) paused: Arc<AtomicBool>,
148 let stop_called_signal = Arc::new(AtomicBool::new(false)); in new()
159 closed: AtomicBool::new(false), in new()
193 negotiated: AtomicBool::new(false), in new()
208 paused: Arc::new(AtomicBool::new(start_paused)), in new()
/webrtc/util/src/conn/
H A Dconn_udp_listener.rs9 use std::sync::atomic::AtomicBool;
26 accepting: Arc<AtomicBool>,
109 accepting: Arc::new(AtomicBool::new(true)), in listen()
143 accepting: Arc<AtomicBool>, in read_loop() argument
189 accepting: &Arc<AtomicBool>, in get_udp_conn() argument
/webrtc/util/src/vnet/
H A Dconn.rs13 use std::sync::atomic::{AtomicBool, Ordering};
35 closed: AtomicBool,
52 closed: AtomicBool::new(false), in new()
/webrtc/sctp/src/stream/
H A Dmod.rs18 sync::atomic::{AtomicBool, AtomicU16, AtomicU32, AtomicU8, AtomicUsize, Ordering},
79 pub(crate) read_shutdown: AtomicBool,
80 pub(crate) write_shutdown: AtomicBool,
81 pub(crate) unordered: AtomicBool,
135 read_shutdown: AtomicBool::new(false), in new()
136 write_shutdown: AtomicBool::new(false), in new()
137 unordered: AtomicBool::new(false), in new()
320 let head_abandoned = Arc::new(AtomicBool::new(false)); in packetize()
321 let head_all_inflight = Arc::new(AtomicBool::new(false)); in packetize()
/webrtc/sctp/src/queue/
H A Dpending_queue.rs6 sync::atomic::{AtomicBool, AtomicUsize, Ordering},
42 selected: AtomicBool,
43 unordered_is_selected: AtomicBool,
/webrtc/ice/src/agent/
H A Dagent_transport.rs7 use std::sync::atomic::{AtomicBool, Ordering};
90 pub(crate) done: AtomicBool,
104 done: AtomicBool::new(false), in new()
H A Dagent_internal.rs7 use std::sync::atomic::{AtomicBool, AtomicU64};
43 pub(crate) is_controlling: AtomicBool,
44 pub(crate) lite: AtomicBool,
114 is_controlling: AtomicBool::new(config.is_controlling), in new()
115 lite: AtomicBool::new(config.lite), in new()
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs80 abandoned: Arc::new(AtomicBool::new(true)), in test_create_forward_tsn_forward_one_abandoned()
110 abandoned: Arc::new(AtomicBool::new(true)), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
121 abandoned: Arc::new(AtomicBool::new(true)), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
132 abandoned: Arc::new(AtomicBool::new(true)), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
/webrtc/mdns/src/conn/
H A Dmod.rs35 is_server_closed: Arc<atomic::AtomicBool>,
105 let is_server_closed = Arc::new(atomic::AtomicBool::new(false)); in server()
245 close_server: Arc<atomic::AtomicBool>, in start() argument
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs12 use std::sync::atomic::{AtomicBool, Ordering};
105 pub(crate) closed: AtomicBool,
H A Dmod.rs22 use std::sync::atomic::{AtomicBool, AtomicU8, Ordering};
186 pub(crate) stopped: AtomicBool,
216 stopped: AtomicBool::new(false), in new()
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs31 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, Ordering};
72 is_started: AtomicBool,
107 is_started: AtomicBool::new(false), in new()
/webrtc/dtls/src/conn/
H A Dmod.rs34 use std::sync::atomic::{AtomicBool, AtomicU16, Ordering};
77 handshake_completed_successfully: Arc<AtomicBool>,
80 closed: AtomicBool, // *closer.Closer
268 let handshake_completed_successfully = Arc::new(AtomicBool::new(false)); in new()
278 closed: AtomicBool::new(false), in new()
752 handshake_completed_successfully: &Arc<AtomicBool>, in read_and_buffer() argument
835 handshake_completed_successfully: &Arc<AtomicBool>, in handle_queued_packets() argument
/webrtc/webrtc/src/data_channel/
H A Dmod.rs18 atomic::{AtomicBool, AtomicU16, AtomicU8, AtomicUsize, Ordering},
67 pub(crate) detach_called: Arc<AtomicBool>,
113 detach_called: Arc::new(AtomicBool::new(false)), in new()
/webrtc/sctp/src/association/
H A Dmod.rs47 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, AtomicUsize, Ordering};
204 will_send_shutdown: Arc<AtomicBool>,
487 let done = Arc::new(AtomicBool::new(false)); in write_loop()
/webrtc/webrtc/src/dtls_transport/
H A Dmod.rs5 use std::sync::atomic::{AtomicBool, AtomicU8, Ordering};
81 pub(crate) srtp_ready_signal: Arc<AtomicBool>,
99 srtp_ready_signal: Arc::new(AtomicBool::new(false)), in new()
/webrtc/webrtc/src/api/media_engine/
H A Dmod.rs23 use std::sync::atomic::{AtomicBool, Ordering};
85 pub(crate) negotiated_video: AtomicBool,
86 pub(crate) negotiated_audio: AtomicBool,
/webrtc/webrtc/src/peer_connection/
H A Dmod.rs83 use std::sync::atomic::{AtomicBool, AtomicU64, AtomicU8, Ordering};
157 is_closed: Arc<AtomicBool>,
173 is_closed: Arc<AtomicBool>,
176 is_negotiation_needed: Arc<AtomicBool>,
862 is_closed: &Arc<AtomicBool>, in update_connection_state() argument
H A Dpeer_connection_internal.rs29 pub(super) is_closed: Arc<AtomicBool>,
36 pub(super) is_negotiation_needed: Arc<AtomicBool>,
85 is_closed: Arc::new(AtomicBool::new(false)), in new()
86 is_negotiation_needed: Arc::new(AtomicBool::new(false)), in new()

12