Searched refs:closed (Results 1 – 11 of 11) sorted by relevance
| /webrtc/stun/src/ |
| H A D | agent.rs | 36 closed: bool, field
120 closed: false, in new()
128 if self.closed { in stop_with_error()
148 if self.closed { in process()
169 if self.closed { in close()
183 self.closed = true; in close()
194 if self.closed { in start()
219 if self.closed { in collect()
257 if self.closed { in set_handler()
|
| H A D | client.rs | 112 closed: bool, field
125 closed: false, in default()
250 if self.settings.closed { in insert()
265 if self.settings.closed { in remove()
361 if self.settings.closed { in close()
365 self.settings.closed = true; in close()
430 if self.settings.closed { in send()
|
| /webrtc/util/src/buffer/ |
| H A D | mod.rs | 22 closed: bool, field
111 closed: false, in new()
133 if b.closed { in write()
249 if b.closed { in read()
272 if b.closed { in close()
276 b.closed = true; in close()
283 b.closed in is_closed()
|
| /webrtc/util/src/vnet/ |
| H A D | conn.rs | 35 closed: AtomicBool, field
52 closed: AtomicBool::new(false), in new()
144 if self.closed.load(Ordering::SeqCst) { in close()
147 self.closed.store(true, Ordering::SeqCst); in close()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 105 pub(crate) closed: AtomicBool, field
144 if self.closed.load(Ordering::SeqCst) { in init()
164 if self.closed.load(Ordering::SeqCst) { in close()
167 self.closed.store(true, Ordering::SeqCst); in close()
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 93 closed_tx.closed().await; in delete_allocations_by_username()
198 _ = close_tx.closed() => break in read_loop()
235 closed_tx.closed().await in close()
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 83 closed: AtomicBool, // Option<mpsc::Receiver<()>>, field
115 closed: AtomicBool::new(false), in new()
226 if self.closed.load(Ordering::Acquire) { in close()
230 self.closed.store(true, Ordering::Release); in close()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 80 closed: AtomicBool, // *closer.Closer field
278 closed: AtomicBool::new(false), in new()
466 if !self.closed.load(Ordering::SeqCst) { in close()
467 self.closed.store(true, Ordering::SeqCst); in close()
1130 self.closed.load(Ordering::SeqCst) in is_connection_closed()
|
| H A D | conn_test.rs | 426 closed: AtomicBool::new(false), in test_export_keying_material()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_internal.rs | 1033 let mut closed = closed_ch.lock().await; in start_candidate() localVariable
1034 *closed = Some(closed_ch_tx); in start_candidate()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 159 closed: AtomicBool::new(false), in new()
|