| /webrtc/rtp/src/codecs/g7xx/ |
| H A D | mod.rs | 19 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload()
20 if payload.is_empty() || mtu == 0 { in payload()
26 let mut payloads = Vec::with_capacity(payload_data_remaining / mtu); in payload()
28 let current_fragment_size = std::cmp::min(mtu, payload_data_remaining); in payload()
|
| /webrtc/rtp/src/codecs/h264/ |
| H A D | mod.rs | 55 fn emit(&mut self, nalu: &Bytes, mtu: usize, payloads: &mut Vec<Bytes>) { in emit()
82 if stap_a_nalu.len() <= mtu { in emit()
93 if nalu.len() <= mtu { in emit()
99 let max_fragment_size = mtu as isize - FUA_HEADER_SIZE as isize; in emit()
164 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload()
165 if payload.is_empty() || mtu == 0 { in payload()
173 self.emit(payload, mtu, &mut payloads); in payload()
183 mtu, in payload()
188 self.emit(&payload.slice(prev_start..), mtu, &mut payloads); in payload()
|
| /webrtc/rtp/src/packetizer/ |
| H A D | mod.rs | 15 fn payload(&mut self, mtu: usize, b: &Bytes) -> Result<Vec<Bytes>>; in payload()
60 pub(crate) mtu: usize, field
74 .field("mtu", &self.mtu) in fmt()
85 mtu: usize, in new_packetizer()
93 mtu, in new_packetizer()
111 let payloads = self.payloader.payload(self.mtu - 12, payload)?; in packetize()
|
| H A D | packetizer_test.rs | 49 mtu: 100, in test_packetizer_abs_send_time()
|
| /webrtc/rtp/src/codecs/opus/ |
| H A D | mod.rs | 15 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload()
16 if payload.is_empty() || mtu == 0 { in payload()
|
| /webrtc/rtp/src/codecs/vp8/ |
| H A D | mod.rs | 22 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload()
23 if payload.is_empty() || mtu == 0 { in payload()
57 let max_fragment_size = mtu as isize - using_header_size as isize; in payload()
|
| H A D | vp8_test.rs | 167 for (name, mut pck, mtu, payloads, expected) in tests { in test_vp8_payload()
169 let actual = pck.payload(mtu, payload)?; in test_vp8_payload()
|
| /webrtc/dtls/src/ |
| H A D | config.rs | 95 pub mtu: usize, field
123 mtu: 0, in default()
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | mod.rs | 41 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload()
80 if payload.is_empty() || mtu == 0 { in payload()
97 let max_fragment_size = mtu as isize - VP9HEADER_SIZE as isize; in payload()
|
| H A D | vp9_test.rs | 296 for (name, bs, mtu, expected) in tests { in test_vp9_payloader_payload()
304 actual.extend(pck.payload(mtu, b)?); in test_vp9_payloader_payload()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 48 pub(crate) mtu: u32, field
132 mtu: INITIAL_MTU, in new()
161 a.cwnd = std::cmp::min(4 * a.mtu, std::cmp::max(2 * a.mtu, 4380)); in new()
442 if self.mtu < fast_retrans_size + data_chunk_size { in gather_outbound_fast_retransmission_packets()
1279 self.cwnd += self.mtu; in on_cumulative_tsn_ack_point_advanced()
1326 self.ssthresh = std::cmp::max(self.cwnd / 2, 4 * self.mtu); in process_fast_retransmission()
1928 if bytes_in_packet + c.user_data.len() as u32 > self.mtu { in bundle_data_chunks_into_packets()
2287 self.ssthresh = std::cmp::max(self.cwnd / 2, 4 * self.mtu); in on_retransmission_timeout()
2288 self.cwnd = self.mtu; in on_retransmission_timeout()
|
| H A D | association_test.rs | 1619 if cwnd > a.mtu || rwnd > 0 { in test_assoc_congestion_control_slow_reader()
|
| /webrtc/util/src/ifaces/ffi/windows/ |
| H A D | mod.rs | 73 mtu: DWORD, field
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 178 let maximum_transmission_unit = if config.mtu == 0 { in new()
181 config.mtu in new()
|