Home
last modified time | relevance | path

Searched refs:buffered_amount (Results 1 – 10 of 10) sorted by relevance

/webrtc/sctp/src/stream/
H A Dstream_test.rs11 assert_eq!(s.buffered_amount(), 0); in test_stream_buffered_amount()
14 s.buffered_amount.store(8192, Ordering::SeqCst); in test_stream_buffered_amount()
16 assert_eq!(s.buffered_amount(), 8192, "unexpected bufferedAmount"); in test_stream_buffered_amount()
30 s.buffered_amount.store(4096, Ordering::SeqCst); in test_stream_amount_on_buffered_amount_low()
63 assert_eq!(s.buffered_amount(), 0, "unexpected bufferedAmount"); in test_stream_amount_on_buffered_amount_low()
68 assert_eq!(s.buffered_amount(), 0, "unexpected bufferedAmount"); in test_stream_amount_on_buffered_amount_low()
88 assert_eq!(s.buffered_amount(), 0); in test_stream()
99 assert_eq!(s.buffered_amount(), 6); in test_stream()
104 assert_eq!(s.buffered_amount(), 11); in test_stream()
163 assert_eq!(poll_stream.buffered_amount(), 0); in test_poll_stream()
[all …]
H A Dmod.rs84 pub(crate) buffered_amount: AtomicUsize, field
106 .field("buffered_amount", &self.buffered_amount) in fmt()
140 buffered_amount: AtomicUsize::new(0), in new()
357 let old_value = self.buffered_amount.fetch_add(raw.len(), Ordering::SeqCst); in packetize()
405 pub fn buffered_amount(&self) -> usize { in buffered_amount() method
406 self.buffered_amount.load(Ordering::SeqCst) in buffered_amount()
435 let from_amount = self.buffered_amount.load(Ordering::SeqCst); in on_buffer_released()
437 self.buffered_amount.store(0, Ordering::SeqCst); in on_buffer_released()
446 self.buffered_amount in on_buffer_released()
634 pub fn buffered_amount(&self) -> usize { in buffered_amount() method
[all …]
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs86 let buffered_amount = shared_dc.buffered_amount().await; in create_requester() localVariable
88 if buffered_amount + buf.len() > MAX_BUFFERED_AMOUNT { in create_requester()
H A DREADME.md5 * pub async fn buffered_amount(&self) -> usize
/webrtc/sctp/src/association/
H A Dassociation_test.rs173 if a0.buffered_amount() == 0 && a1.buffered_amount() == 0 { in flush_buffers()
256 assert_eq!(a.buffered_amount(), 0, "incorrect bufferedAmount"); in test_assoc_reliable_simple()
265 assert_eq!(a.buffered_amount(), MSG.len(), "incorrect bufferedAmount"); in test_assoc_reliable_simple()
282 assert_eq!(a.buffered_amount(), 0, "incorrect bufferedAmount"); in test_assoc_reliable_simple()
331 assert_eq!(a.buffered_amount(), 0, "incorrect bufferedAmount"); in test_assoc_reliable_ordered_reordered()
727 assert_eq!(a.buffered_amount(), 0, "incorrect bufferedAmount"); in test_assoc_reliable_short_buffer()
736 assert_eq!(a.buffered_amount(), MSG.len(), "incorrect bufferedAmount"); in test_assoc_reliable_short_buffer()
759 assert_eq!(a.buffered_amount(), 0, "incorrect bufferedAmount"); in test_assoc_reliable_short_buffer()
1467 while s0.buffered_amount() > 0 && n_packets_received < N_PACKETS_TO_SEND { in test_assoc_congestion_control_congestion_avoidance()
1823 assert_eq!(0, a.buffered_amount(), "incorrect bufferedAmount"); in test_assoc_reset_close_one_way()
[all …]
H A Dassociation_internal.rs2209 pub(crate) fn buffered_amount(&self) -> usize { in buffered_amount() method
/webrtc/data/src/data_channel/
H A Dmod.rs323 pub fn buffered_amount(&self) -> usize { in buffered_amount() method
324 self.stream.buffered_amount() in buffered_amount()
465 pub fn buffered_amount(&self) -> usize { in buffered_amount() method
466 self.data_channel.buffered_amount() in buffered_amount()
H A Ddata_channel_test.rs448 while dc0.buffered_amount() > 0 { in test_data_channel_buffered_amount()
454 assert_eq!(dc0.buffered_amount(), 1, "incorrect bufferedAmount"); in test_data_channel_buffered_amount()
458 assert_eq!(dc0.buffered_amount(), 2, "incorrect bufferedAmount"); in test_data_channel_buffered_amount()
486 dc0.buffered_amount(), in test_data_channel_buffered_amount()
/webrtc/webrtc/src/data_channel/
H A Dmod.rs501 pub async fn buffered_amount(&self) -> usize { in buffered_amount() method
504 dc.buffered_amount() in buffered_amount()
H A Ddata_channel_test.rs793 assert_eq!(0, dc.buffered_amount().await, "should match"); in test_data_channel_parameters_go()