Searched refs:n_bytes (Results 1 – 4 of 4) sorted by relevance
| /webrtc/sctp/src/queue/ |
| H A D | reassembly_queue.rs | 116 pub(crate) n_bytes: usize, field
132 n_bytes: 0, in new()
144 self.n_bytes += chunk.user_data.len(); in push()
162 self.n_bytes += chunk.user_data.len(); in push()
343 pub(crate) fn subtract_num_bytes(&mut self, n_bytes: usize) { in subtract_num_bytes()
344 if self.n_bytes >= n_bytes { in subtract_num_bytes()
345 self.n_bytes -= n_bytes; in subtract_num_bytes()
347 self.n_bytes = 0; in subtract_num_bytes()
352 self.n_bytes in get_num_bytes()
|
| H A D | pending_queue.rs | 41 n_bytes: AtomicUsize, field
60 n_bytes: Default::default(), in new()
85 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in push()
133 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in append_large()
161 self.n_bytes in append_unlimited()
242 self.n_bytes.fetch_sub(user_data_len, Ordering::SeqCst); in pop()
251 self.n_bytes.load(Ordering::SeqCst) in get_num_bytes()
|
| H A D | payload_queue.rs | 15 pub(crate) n_bytes: usize, field
33 self.n_bytes += p.user_data.len(); in push_no_check()
81 self.n_bytes -= c.user_data.len(); in pop()
147 self.n_bytes -= n; in mark_as_acked()
171 self.n_bytes in get_num_bytes()
|
| H A D | queue_test.rs | 12 fn make_payload(tsn: u32, n_bytes: usize) -> ChunkPayloadData { in make_payload()
17 b.resize(n_bytes, 0); in make_payload()
|