Home
last modified time | relevance | path

Searched refs:payload (Results 1 – 25 of 49) sorted by relevance

12

/webrtc/rtp/src/codecs/h265/
H A Dmod.rs136 let mut payload = payload.slice(2..); in depacketize() localVariable
146 payload = payload.slice(2..); in depacketize()
150 self.payload = payload; in depacketize()
299 let mut payload = payload.slice(2..); in depacketize() localVariable
310 payload = payload.slice(2..); in depacketize()
316 payload = payload.slice(2..); in depacketize()
338 payload = payload.slice(1..); in depacketize()
345 payload = payload.slice(2..); in depacketize()
476 payload = payload.slice(2..); in depacketize()
481 self.payload = payload; in depacketize()
[all …]
/webrtc/rtp/src/codecs/vp8/
H A Dvp8_test.rs25 assert!(!payload.is_empty(), "Payload must be not empty"); in test_vp8_unmarshal()
30 assert!(!payload.is_empty(), "Payload must be not empty"); in test_vp8_unmarshal()
79 let payload = pck in test_vp8_unmarshal() localVariable
91 let payload = pck in test_vp8_unmarshal() localVariable
168 for (i, payload) in payloads.iter().enumerate() { in test_vp8_payload()
169 let actual = pck.payload(mtu, payload)?; in test_vp8_payload()
181 let payload = Bytes::from_static(&[0x90, 0x90, 0x90]); in test_vp8_payload_eror() localVariable
184 let result = pck.payload(1, &empty)?; in test_vp8_payload_eror()
188 let result = pck.payload(1, &payload)?; in test_vp8_payload_eror()
192 let result = pck.payload(2, &payload)?; in test_vp8_payload_eror()
[all …]
H A Dmod.rs22 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload() method
23 if payload.is_empty() || mtu == 0 { in payload()
58 let mut payload_data_remaining = payload.len() as isize; in payload()
94 &*payload.slice(payload_data_index..payload_data_index + current_fragment_size), in payload()
237 fn is_partition_head(&self, payload: &Bytes) -> bool { in is_partition_head()
238 if payload.is_empty() { in is_partition_head()
241 (payload[0] & 0x10) != 0 in is_partition_head()
/webrtc/rtp/src/packet/
H A Dpacket_test.rs581 payload, in test_rfc8285_get_extension_returns_nil_when_extension_disabled()
615 payload, in test_rfc8285_del_extension()
661 payload, in test_rfc8285_get_extension_ids()
696 payload, in test_rfc8285_get_extension_ids_return_empty_when_extension_disabled()
718 payload, in test_rfc8285_del_extension_returns_error_when_extenstions_disabled()
743 payload, in test_rfc8285_one_byte_set_extension_should_enable_extension_when_adding()
782 payload, in test_rfc8285_set_extension_should_set_correct_extension_profile_for_16_byte_extension()
1224 payload, p.payload, in test_round_trip()
1226 p.payload, payload in test_round_trip()
1236 payload, p.payload, in test_round_trip()
[all …]
H A Dmod.rs15 pub payload: Bytes, field
28 out += format!("\tPayload Length: {}\n", self.payload.len()).as_str(); in fmt()
43 let payload = raw_packet.copy_to_bytes(payload_len); in unmarshal() localVariable
46 let padding_len = payload[payload_len - 1] as usize; in unmarshal()
50 payload: payload.slice(..payload_len - padding_len), in unmarshal()
59 Ok(Packet { header, payload }) in unmarshal()
67 let payload_len = self.payload.len(); in marshal_size()
91 buf.put(&*self.payload); in marshal_to()
93 let mut padding_len = get_padding(self.payload.len()); in marshal_to()
109 Ok(n + self.payload.len() + padding_len) in marshal_to()
/webrtc/rtp/src/codecs/h264/
H A Dh264_test.rs26 let result = pck.payload(1, &empty)?; in test_h264_payload()
30 let result = pck.payload(0, &small_payload)?; in test_h264_payload()
34 let result = pck.payload(1, &small_payload)?; in test_h264_payload()
38 let result = pck.payload(5, &small_payload)?; in test_h264_payload()
47 let result = pck.payload(5, &multiple_payload)?; in test_h264_payload()
59 let result = pck.payload(5, &large_payload)?; in test_h264_payload()
67 let result = pck.payload(5, &small_payload2)?; in test_h264_payload()
147 payload, single_payload_unmarshaled, in test_h264_packet_unmarshal()
153 payload, single_payload_unmarshaled_avc, in test_h264_packet_unmarshal()
159 let payload = pkt.depacketize(p)?; in test_h264_packet_unmarshal() localVariable
[all …]
H A Dmod.rs164 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload() method
165 if payload.is_empty() || mtu == 0 { in payload()
173 self.emit(payload, mtu, &mut payloads); in payload()
215 let mut payload = BytesMut::new(); in depacketize() localVariable
229 payload.put(&*packet.clone()); in depacketize()
230 Ok(payload.freeze()) in depacketize()
255 Ok(payload.freeze()) in depacketize()
282 payload.put(fua_buffer); in depacketize()
285 Ok(payload.freeze()) in depacketize()
296 if payload.len() < 2 { in is_partition_head()
[all …]
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs53 if *payload == b { in is_partition_head()
80 payload: bytes!(1), in test_sample_builder()
98 payload: bytes!(1), in test_sample_builder()
1239 payload: bytes!(0x01), in test_sample_builder_max_late()
1247 payload: bytes!(0x01), in test_sample_builder_max_late()
1255 payload: bytes!(0x01), in test_sample_builder_max_late()
1274 payload: bytes!(0x02), in test_sample_builder_max_late()
1282 payload: bytes!(0x02), in test_sample_builder_max_late()
1290 payload: bytes!(0x02), in test_sample_builder_max_late()
1311 payload: bytes!(0x03), in test_sample_builder_max_late()
[all …]
/webrtc/rtp/src/codecs/opus/
H A Dopus_test.rs14 let payload = pck.depacketize(&raw_bytes)?; in test_opus_unmarshal() localVariable
15 assert_eq!(&raw_bytes, &payload, "Payload must be same"); in test_opus_unmarshal()
24 let payload = Bytes::from_static(&[0x90, 0x90, 0x90]); in test_opus_payload() localVariable
27 let result = pck.payload(1, &empty)?; in test_opus_payload()
31 let result = pck.payload(1, &payload)?; in test_opus_payload()
35 let result = pck.payload(2, &payload)?; in test_opus_payload()
H A Dmod.rs15 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload() method
16 if payload.is_empty() || mtu == 0 { in payload()
20 Ok(vec![payload.clone()]) in payload()
/webrtc/rtp/src/codecs/g7xx/
H A Dg7xx_test.rs19 let payloads = pck.payload(TEST_MTU, &samples_in)?; in test_g7xx_payload()
35 let payload = Bytes::from_static(&[0x90, 0x90, 0x90]); in test_g7xx_payload() localVariable
38 let result = pck.payload(1, &empty)?; in test_g7xx_payload()
42 let result = pck.payload(0, &payload)?; in test_g7xx_payload()
46 let result = pck.payload(10, &payload)?; in test_g7xx_payload()
H A Dmod.rs19 fn payload(&mut self, mtu: usize, payload: &Bytes) -> Result<Vec<Bytes>> { in payload() method
20 if payload.is_empty() || mtu == 0 { in payload()
24 let mut payload_data_remaining = payload.len(); in payload()
30 payload.slice(payload_data_index..payload_data_index + current_fragment_size), in payload()
/webrtc/media/src/io/h264_writer/
H A Dh264_writer_test.rs27 for (name, payload, want) in tests { in test_is_key_frame()
28 let got = is_key_frame(&payload); in test_is_key_frame()
73 for (_name, payload, has_key_frame, want_bytes, _reuse) in tests { in test_write_rtp()
81 payload: Bytes::from(payload), in test_write_rtp()
112 for payload in tests { in test_write_rtp_fu()
114 payload: Bytes::from(payload), in test_write_rtp_fu()
H A Dmod.rs51 if packet.payload.is_empty() { in write_rtp()
56 self.has_key_frame = is_key_frame(&packet.payload); in write_rtp()
68 let payload = cached_packet.depacketize(&packet.payload)?; in write_rtp() localVariable
70 self.writer.write_all(&payload)?; in write_rtp()
/webrtc/media/src/io/ivf_writer/
H A Divf_writer_test.rs28 payload: raw_valid_pkt.slice(20..), in test_ivf_writer_add_packet_and_close()
55 payload: raw_mid_part_pkt.slice(20..), in test_ivf_writer_add_packet_and_close()
82 payload: raw_keyframe_pkt.slice(20..), in test_ivf_writer_add_packet_and_close()
90 let payload = vp8packet.depacketize(&valid_packet.payload)?; in test_ivf_writer_add_packet_and_close() localVariable
93 payload[0] & 0x01, in test_ivf_writer_add_packet_and_close()
100 let payload = vp8packet.depacketize(&mid_part_packet.payload)?; in test_ivf_writer_add_packet_and_close() localVariable
103 payload[0] & 0x01, in test_ivf_writer_add_packet_and_close()
110 let payload = vp8packet.depacketize(&keyframe_packet.payload)?; in test_ivf_writer_add_packet_and_close() localVariable
112 assert_eq!(payload[0] & 0x01, 0, "Keyframe packet P value should be 0"); in test_ivf_writer_add_packet_and_close()
H A Dmod.rs65 let payload = depacketizer.depacketize(&packet.payload)?; in write_rtp() localVariable
67 let is_key_frame = payload[0] & 0x01; in write_rtp()
70 || (self.current_frame.is_none() && !depacketizer.is_partition_head(&packet.payload)) in write_rtp()
77 current_frame.extend(payload); in write_rtp()
81 current_frame.extend(payload); in write_rtp()
/webrtc/rtp/src/
H A Dheader.rs32 pub payload: Bytes, field
282 buf.put(&*extension.payload); in marshal_to()
290 buf.put(&*extension.payload); in marshal_to()
304 buf.put(&*extension.payload); in marshal_to()
325 .map(|extension| extension.payload.len()) in get_extension_payload_len()
346 if payload.len() > 16 { in set_extension()
354 if payload.len() > 255 { in set_extension()
371 extension.payload = payload; in set_extension()
379 self.extension_profile = match payload.len() { in set_extension()
385 self.extensions.push(Extension { id, payload }); in set_extension()
[all …]
/webrtc/rtp/src/packetizer/
H A Dpacketizer_test.rs23 format!("Packet {} length {}\n", i, packets[i].payload.len()).as_str(); in test_packetizer()
61 let payload = Bytes::from_static(&[0x11, 0x12, 0x13, 0x14]); in test_packetizer_abs_send_time() localVariable
62 let packets = pktizer.packetize(&payload, 2000)?; in test_packetizer_abs_send_time()
78 payload: Bytes::from_static(&[0x40, 0, 0]), in test_packetizer_abs_send_time()
81 payload: Bytes::from_static(&[0x11, 0x12, 0x13, 0x14]), in test_packetizer_abs_send_time()
98 let payload = Bytes::from_static(&[0; 128]); in test_packetizer_timestamp_rollover_does_not_panic() localVariable
101 packetizer.packetize(&payload, 10)?; in test_packetizer_timestamp_rollover_does_not_panic()
103 packetizer.packetize(&payload, u32::MAX)?; in test_packetizer_timestamp_rollover_does_not_panic()
H A Dmod.rs15 fn payload(&mut self, mtu: usize, b: &Bytes) -> Result<Vec<Bytes>>; in payload() method
28 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>>; in packetize()
46 fn is_partition_head(&self, payload: &Bytes) -> bool; in is_partition_head()
50 fn is_partition_tail(&self, marker: bool, payload: &Bytes) -> bool; in is_partition_tail()
110 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>> { in packetize()
111 let payloads = self.payloader.payload(self.mtu - 12, payload)?; in packetize()
114 for (i, payload) in payloads.into_iter().enumerate() { in packetize()
127 payload, in packetize()
/webrtc/srtp/src/cipher/
H A Dmod.rs43 payload: &[u8], in encrypt_rtp()
51 payload: &[u8], in decrypt_rtp()
57 fn encrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in encrypt_rtcp()
60 fn decrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in decrypt_rtcp()
/webrtc/media/src/io/ogg_writer/
H A Dmod.rs122 payload: &Bytes, in write_page()
127 self.last_payload_size = payload.len(); in write_page()
128 self.last_payload = payload.clone(); in write_page()
142 … header_writer.write_all(payload)?; // inserting at 28th since Segment Table(1) + header length(27) in write_page()
162 let payload = opus_packet.depacketize(&packet.payload)?; in write_rtp() localVariable
172 &payload, in write_rtp()
184 let payload = self.last_payload.clone(); in close() localVariable
186 &payload, in close()
/webrtc/media/src/io/ogg_reader/
H A Dmod.rs72 let (payload, page_header) = self.parse_next_page()?; in read_headers()
82 if payload.len() != ID_PAGE_PAYLOAD_SIZE { in read_headers()
86 let s = &payload[..8]; in read_headers()
91 let mut reader = Cursor::new(&payload[8..]); in read_headers()
134 let mut payload = BytesMut::with_capacity(payload_size); in parse_next_page() localVariable
135 payload.resize(payload_size, 0); in parse_next_page()
136 self.reader.read_exact(&mut payload)?; in parse_next_page()
153 for v in &payload[..] { in parse_next_page()
172 Ok((payload, page_header)) in parse_next_page()
/webrtc/media/src/io/ivf_reader/
H A Divf_reader_test.rs80 let (payload, header) = reader.parse_next_frame()?; in test_ivf_reader_parse_valid_frames()
83 assert_eq!(payload.len(), 4, "Payload should be length 4"); in test_ivf_reader_parse_valid_frames()
85 payload, in test_ivf_reader_parse_valid_frames()
96 let (payload, header) = reader.parse_next_frame()?; in test_ivf_reader_parse_valid_frames()
99 assert_eq!(payload.len(), 12, "Payload should be length 12"); in test_ivf_reader_parse_valid_frames()
101 payload, in test_ivf_reader_parse_valid_frames()
H A Dmod.rs77 let mut payload = BytesMut::with_capacity(header.frame_size as usize); in parse_next_frame() localVariable
78 payload.resize(header.frame_size as usize, 0); in parse_next_frame()
79 self.reader.read_exact(&mut payload)?; in parse_next_frame()
83 Ok((payload, header)) in parse_next_frame()
/webrtc/rtp/benches/
H A Dpacket_bench.rs18 payload: Bytes::from_static(&[3, 4]), in benchmark_packet()
22 payload: Bytes::from_static(&[5, 6]), in benchmark_packet()
27 payload: Bytes::from_static(&[0xFFu8; 15]), //vec![0x07, 0x08, 0x09, 0x0a], //MTU=1500 in benchmark_packet()

12