Home
last modified time | relevance | path

Searched refs:AtomicUsize (Results 1 – 23 of 23) sorted by relevance

/webrtc/webrtc/src/peer_connection/operation/
H A Dmod.rs7 use std::sync::atomic::{AtomicUsize, Ordering};
41 length: Arc<AtomicUsize>,
48 let length = Arc::new(AtomicUsize::new(0)); in new()
78 length: &Arc<AtomicUsize>, in enqueue_inner() argument
109 length: Arc<AtomicUsize>, in start() argument
/webrtc/util/src/vnet/conn/
H A Dconn_test.rs3 use std::sync::atomic::AtomicUsize;
7 nclosed: Arc<AtomicUsize>,
55 let nclosed = Arc::new(AtomicUsize::new(0)); in test_udp_conn_send_to_recv_from()
142 let nclosed = Arc::new(AtomicUsize::new(0)); in test_udp_conn_send_recv()
/webrtc/webrtc/src/mux/
H A Dmod.rs12 use std::sync::atomic::{AtomicUsize, Ordering};
32 id: Arc<AtomicUsize>,
43 id: Arc::new(AtomicUsize::new(0)), in new()
H A Dmux_test.rs6 use std::sync::atomic::{AtomicUsize, Ordering};
44 idx: AtomicUsize,
101 idx: AtomicUsize::new(0), in test_non_fatal_read()
/webrtc/ice/src/agent/
H A Dagent_transport.rs88 pub(crate) bytes_received: AtomicUsize,
89 pub(crate) bytes_sent: AtomicUsize,
102 bytes_received: AtomicUsize::new(0), in new()
103 bytes_sent: AtomicUsize::new(0), in new()
H A Dmod.rs41 use std::sync::atomic::{AtomicU8, AtomicUsize, Ordering};
/webrtc/sctp/src/queue/
H A Dpayload_queue.rs6 use std::sync::atomic::{AtomicUsize, Ordering};
11 pub(crate) length: Arc<AtomicUsize>,
19 pub(crate) fn new(length: Arc<AtomicUsize>) -> Self { in new()
H A Dpending_queue.rs6 sync::atomic::{AtomicBool, AtomicUsize, Ordering},
40 queue_len: AtomicUsize,
41 n_bytes: AtomicUsize,
H A Dqueue_test.rs26 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_push_no_check()
73 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_get_gap_ack_block()
111 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_get_last_tsn_received()
142 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_mark_all_to_retrasmit()
165 let mut pq = PayloadQueue::new(Arc::new(AtomicUsize::new(0))); in test_payload_queue_reset_retransmit_flag_on_ack()
447 use std::sync::atomic::AtomicUsize;
/webrtc/sctp/src/association/
H A Dmod.rs47 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, AtomicUsize, Ordering};
203 inflight_queue_length: Arc<AtomicUsize>,
209 bytes_received: Arc<AtomicUsize>,
210 bytes_sent: Arc<AtomicUsize>,
304 let bytes_received = Arc::new(AtomicUsize::new(0)); in new()
305 let bytes_sent = Arc::new(AtomicUsize::new(0)); in new()
425 bytes_received: Arc<AtomicUsize>, in read_loop() argument
480 bytes_sent: Arc<AtomicUsize>, in write_loop() argument
H A Dassociation_test.rs2105 bytes_sent: AtomicUsize,
2106 bytes_received: AtomicUsize,
2121 bytes_sent: AtomicUsize::new(0), in default()
2122 bytes_received: AtomicUsize::new(0), in default()
H A Dassociation_internal.rs16 pub(crate) inflight_queue_length: Arc<AtomicUsize>,
114 let inflight_queue_length = Arc::new(AtomicUsize::new(0)); in new()
127 payload_queue: PayloadQueue::new(Arc::new(AtomicUsize::new(0))), in new()
/webrtc/util/src/conn/
H A Dconn_bridge.rs7 use std::sync::atomic::{AtomicUsize, Ordering};
74 drop_nwrites: [AtomicUsize; 2],
75 reorder_nwrites: [AtomicUsize; 2],
/webrtc/examples/examples/swap-tracks/
H A Dswap-tracks.rs4 use std::sync::atomic::{AtomicUsize, Ordering};
133 let curr_track = Arc::new(AtomicUsize::new(0)); in main()
135 let track_count = Arc::new(AtomicUsize::new(0)); in main()
/webrtc/data/src/data_channel/
H A Dmod.rs22 use std::sync::atomic::{AtomicUsize, Ordering};
46 messages_sent: Arc<AtomicUsize>,
47 messages_received: Arc<AtomicUsize>,
48 bytes_sent: Arc<AtomicUsize>,
49 bytes_received: Arc<AtomicUsize>,
H A Ddata_channel_test.rs425 let n_cbs = Arc::new(AtomicUsize::new(0)); in test_data_channel_buffered_amount()
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs15 use std::sync::atomic::{AtomicU32, AtomicU8, AtomicUsize, Ordering};
23 static ref TRACK_REMOTE_UNIQUE_ID: AtomicUsize = AtomicUsize::new(0);
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs3 atomic::{AtomicUsize, Ordering},
120 let total_bytes_received = Arc::new(AtomicUsize::new(0)); in create_responder()
/webrtc/sctp/src/stream/
H A Dmod.rs18 sync::atomic::{AtomicBool, AtomicU16, AtomicU32, AtomicU8, AtomicUsize, Ordering},
84 pub(crate) buffered_amount: AtomicUsize,
85 pub(crate) buffered_amount_low: AtomicUsize,
140 buffered_amount: AtomicUsize::new(0), in new()
141 buffered_amount_low: AtomicUsize::new(0), in new()
/webrtc/webrtc/src/rtp_transceiver/
H A Drtp_transceiver_test.rs1 use std::sync::atomic::AtomicUsize;
260 let count = Arc::new(AtomicUsize::new(0)); in test_rtp_transceiver_set_direction_causing_negotiation()
/webrtc/turn/src/allocation/
H A Dmod.rs19 use std::sync::atomic::AtomicUsize;
84 pub(crate) relayed_bytes: AtomicUsize,
/webrtc/webrtc/src/data_channel/
H A Dmod.rs18 atomic::{AtomicBool, AtomicU16, AtomicU8, AtomicUsize, Ordering},
66 pub(crate) buffered_amount_low_threshold: AtomicUsize,
/webrtc/util/src/vnet/router/
H A Drouter_test.rs2 use std::sync::atomic::{AtomicI32, AtomicUsize};
318 let n = AtomicUsize::new(0); in test_router_standalone_add_chunk_filter()