Home
last modified time | relevance | path

Searched refs:header (Results 1 – 25 of 119) sorted by relevance

12345

/webrtc/srtp/src/context/
H A Dsrtp.rs11 header: &rtp::header::Header, in decrypt_rtp_with_header()
19 header.ssrc, in decrypt_rtp_with_header()
20 header.sequence_number, in decrypt_rtp_with_header()
27 return Err(Error::SsrcMissingFromSrtp(header.ssrc)); in decrypt_rtp_with_header()
31 let dst = self.cipher.decrypt_rtp(encrypted, header, roc)?; in decrypt_rtp_with_header()
47 let header = rtp::header::Header::unmarshal(&mut buf)?; in decrypt_rtp() localVariable
48 self.decrypt_rtp_with_header(encrypted, &header) in decrypt_rtp()
54 header: &rtp::header::Header, in encrypt_rtp_with_header()
67 .encrypt_rtp(&plaintext[header.marshal_size()..], header, roc)?; in encrypt_rtp_with_header()
82 let header = rtp::header::Header::unmarshal(&mut buf)?; in encrypt_rtp() localVariable
[all …]
/webrtc/media/src/io/ivf_reader/
H A Divf_reader_test.rs15 let header = Bytes::from_static(&[ in build_ivf_container() localVariable
22 ivf.extend(header); in build_ivf_container()
36 let (_, header) = IVFReader::new(r)?; in test_ivf_reader_parse_valid_file_header()
39 assert_eq!(header.version, 0, "version should be 0"); in test_ivf_reader_parse_valid_file_header()
41 assert_eq!(header.width, 176, "width should be 176"); in test_ivf_reader_parse_valid_file_header()
42 assert_eq!(header.height, 144, "height should be 144"); in test_ivf_reader_parse_valid_file_header()
44 header.timebase_denominator, 30000, in test_ivf_reader_parse_valid_file_header()
48 header.timebase_numerator, 1000, in test_ivf_reader_parse_valid_file_header()
52 assert_eq!(header.unused, 0, "bytes should be unused"); in test_ivf_reader_parse_valid_file_header()
80 let (payload, header) = reader.parse_next_frame()?; in test_ivf_reader_parse_valid_frames()
[all …]
H A Dmod.rs54 let header = r.parse_file_header()?; in new() localVariable
56 Ok((r, header)) in new()
72 let header = IVFFrameHeader { in parse_next_frame() localVariable
77 let mut payload = BytesMut::with_capacity(header.frame_size as usize); in parse_next_frame()
78 payload.resize(header.frame_size as usize, 0); in parse_next_frame()
81 self.bytes_read += IVF_FRAME_HEADER_SIZE + header.frame_size as usize; in parse_next_frame()
83 Ok((payload, header)) in parse_next_frame()
103 let header = IVFFileHeader { in parse_file_header() localVariable
116 if header.signature != IVF_FILE_HEADER_SIGNATURE { in parse_file_header()
118 } else if header.version != 0 { in parse_file_header()
[all …]
/webrtc/rtp/src/packet/
H A Dmod.rs4 use crate::{error::Error, header::*};
14 pub header: Header, field
27 out += format!("\tSSRC: {} ({:x})\n", self.header.ssrc, self.header.ssrc).as_str(); in fmt()
41 let header = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
44 if header.padding { in unmarshal()
49 header, in unmarshal()
59 Ok(Packet { header, payload }) in unmarshal()
68 let padding_len = if self.header.padding { in marshal_size()
78 self.header.marshal_size() + payload_len + padding_len in marshal_size()
89 let n = self.header.marshal_to(buf)?; in marshal_to()
[all …]
H A Dpacket_test.rs22 header: Header { in test_basic()
101 header: Header { in test_extension()
146 header: Header { in test_packet_marshal_unmarshal()
183 header: Header { in test_rfc_8285_one_byte_extension()
243 header: Header { in test_rfc_8285_one_byte_two_extension_of_two_bytes()
297 .header in test_rfc_8285_one_byte_multiple_extensions_with_padding()
305 .header in test_rfc_8285_one_byte_multiple_extensions_with_padding()
313 .header in test_rfc_8285_one_byte_multiple_extensions_with_padding()
374 header: Header { in test_rfc_8285_one_byte_multiple_extension()
865 p.header in test_rfc8285_one_byte_set_extension_should_error_when_invalid_id_provided()
[all …]
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs75 header: Header { in test_sample_builder()
92 header: Header { in test_sample_builder()
1234 header: Header { in test_sample_builder_max_late()
1242 header: Header { in test_sample_builder_max_late()
1250 header: Header { in test_sample_builder_max_late()
1269 header: Header { in test_sample_builder_max_late()
1277 header: Header { in test_sample_builder_max_late()
1285 header: Header { in test_sample_builder_max_late()
1306 header: Header { in test_sample_builder_max_late()
1394 header: Header { in test_sample_builder_clean_reference()
[all …]
/webrtc/media/src/io/ivf_writer/
H A Dmod.rs24 pub fn new(writer: W, header: &IVFFileHeader) -> Result<Self> { in new()
30 is_vp9: &header.four_cc != b"VP80", in new()
33 w.write_header(header)?; in new()
38 fn write_header(&mut self, header: &IVFFileHeader) -> Result<()> { in write_header()
39 self.writer.write_all(&header.signature)?; // DKIF in write_header()
40 self.writer.write_u16::<LittleEndian>(header.version)?; // version in write_header()
41 self.writer.write_u16::<LittleEndian>(header.header_size)?; // Header size in write_header()
42 self.writer.write_all(&header.four_cc)?; // FOURCC in write_header()
43 self.writer.write_u16::<LittleEndian>(header.width)?; // Width in pixels in write_header()
50 self.writer.write_u32::<LittleEndian>(header.unused)?; // Unused in write_header()
[all …]
H A Divf_writer_test.rs14 header: rtp::header::Header { in test_ivf_writer_add_packet_and_close()
31 .header in test_ivf_writer_add_packet_and_close()
41 header: rtp::header::Header { in test_ivf_writer_add_packet_and_close()
58 .header in test_ivf_writer_add_packet_and_close()
68 header: rtp::header::Header { in test_ivf_writer_add_packet_and_close()
85 .header in test_ivf_writer_add_packet_and_close()
141 let header = IVFFileHeader { in test_ivf_writer_add_packet_and_close() localVariable
155 let mut writer = IVFWriter::new(Cursor::new(Vec::<u8>::new()), &header)?; in test_ivf_writer_add_packet_and_close()
/webrtc/srtp/src/
H A Dstream.rs56 pub async fn read_rtp(&self, buf: &mut [u8]) -> Result<(usize, rtp::header::Header)> { in read_rtp()
63 let header = rtp::header::Header::unmarshal(&mut b)?; in read_rtp() localVariable
65 Ok((n, header)) in read_rtp()
69 pub async fn read_rtcp(&self, buf: &mut [u8]) -> Result<(usize, rtcp::header::Header)> { in read_rtcp()
76 let header = rtcp::header::Header::unmarshal(&mut b)?; in read_rtcp() localVariable
78 Ok((n, header)) in read_rtcp()
/webrtc/sctp/src/chunk/
H A Dchunk_heartbeat_ack.rs43 write!(f, "{}", self.header()) in fmt()
48 fn header(&self) -> ChunkHeader { in header() method
57 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
59 if header.typ != CT_HEARTBEAT_ACK { in unmarshal()
68 build_param(&raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal()
69 if p.header().typ != ParamType::HeartbeatInfo { in unmarshal()
81 if self.params[0].header().typ != ParamType::HeartbeatInfo { in marshal_to()
85 self.header().marshal_to(buf)?; in marshal_to()
H A Dchunk_heartbeat.rs41 write!(f, "{}", self.header()) in fmt()
46 fn header(&self) -> ChunkHeader { in header() method
55 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
57 if header.typ != CT_HEARTBEAT { in unmarshal()
66 build_param(&raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal()
67 if p.header().typ != ParamType::HeartbeatInfo { in unmarshal()
76 self.header().marshal_to(buf)?; in marshal_to()
H A Dchunk_cookie_echo.rs24 write!(f, "{}", self.header()) in fmt()
29 fn header(&self) -> ChunkHeader { in header() method
38 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
40 if header.typ != CT_COOKIE_ECHO { in unmarshal()
44 let cookie = raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()); in unmarshal()
49 self.header().marshal_to(buf)?; in marshal_to()
H A Dchunk_shutdown.rs25 write!(f, "{}", self.header()) in fmt()
30 fn header(&self) -> ChunkHeader { in header() method
39 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
41 if header.typ != CT_SHUTDOWN { in unmarshal()
49 let reader = &mut raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()); in unmarshal()
57 self.header().marshal_to(writer)?; in marshal_to()
H A Dchunk_init.rs115 write!(f, "{} {}", self.header(), res) in fmt()
120 fn header(&self) -> ChunkHeader { in header() method
145 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
147 if !(header.typ == CT_INIT || header.typ == CT_INIT_ACK) { in unmarshal()
149 } else if header.value_length() < INIT_CHUNK_MIN_LENGTH { in unmarshal()
157 if header.flags != 0 { in unmarshal()
161 let reader = &mut raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()); in unmarshal()
173 let p = build_param(&raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal()
182 is_ack: header.typ == CT_INIT_ACK, in unmarshal()
193 self.header().marshal_to(writer)?; in marshal_to()
H A Dchunk_cookie_ack.rs19 write!(f, "{}", self.header()) in fmt()
24 fn header(&self) -> ChunkHeader { in header() method
33 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
35 if header.typ != CT_COOKIE_ACK { in unmarshal()
43 self.header().marshal_to(buf)?; in marshal_to()
H A Dchunk_shutdown_complete.rs19 write!(f, "{}", self.header()) in fmt()
24 fn header(&self) -> ChunkHeader { in header() method
33 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
35 if header.typ != CT_SHUTDOWN_COMPLETE { in unmarshal()
43 self.header().marshal_to(writer)?; in marshal_to()
H A Dchunk_shutdown_ack.rs19 write!(f, "{}", self.header()) in fmt()
24 fn header(&self) -> ChunkHeader { in header() method
33 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
35 if header.typ != CT_SHUTDOWN_ACK { in unmarshal()
43 self.header().marshal_to(writer)?; in marshal_to()
H A Dchunk_payload_data.rs149 write!(f, "{}\n{}", self.header(), self.tsn) in fmt()
154 fn header(&self) -> ChunkHeader { in header() method
177 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
179 if header.typ != CT_PAYLOAD_DATA { in unmarshal()
183 let immediate_sack = (header.flags & PAYLOAD_DATA_IMMEDIATE_SACK) != 0; in unmarshal()
184 let unordered = (header.flags & PAYLOAD_DATA_UNORDERED_BITMASK) != 0; in unmarshal()
185 let beginning_fragment = (header.flags & PAYLOAD_DATA_BEGINING_FRAGMENT_BITMASK) != 0; in unmarshal()
186 let ending_fragment = (header.flags & PAYLOAD_DATA_ENDING_FRAGMENT_BITMASK) != 0; in unmarshal()
189 if header.value_length() < PAYLOAD_DATA_HEADER_SIZE { in unmarshal()
193 let reader = &mut raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()); in unmarshal()
[all …]
H A Dchunk_error.rs36 let mut res = vec![self.header().to_string()]; in fmt()
47 fn header(&self) -> ChunkHeader { in header() method
56 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() localVariable
58 if header.typ != CT_ERROR { in unmarshal()
66 &raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()), in unmarshal()
76 self.header().marshal_to(buf)?; in marshal_to()
/webrtc/sctp/src/param/
H A Dparam_outgoing_reset_request.rs54 self.header(), in fmt()
64 fn header(&self) -> ParamHeader { in header() method
72 let header = ParamHeader::unmarshal(raw)?; in unmarshal() localVariable
75 if header.value_length() < PARAM_OUTGOING_RESET_REQUEST_STREAM_IDENTIFIERS_OFFSET { in unmarshal()
80 &mut raw.slice(PARAM_HEADER_LENGTH..PARAM_HEADER_LENGTH + header.value_length()); in unmarshal()
86 (header.value_length() - PARAM_OUTGOING_RESET_REQUEST_STREAM_IDENTIFIERS_OFFSET) / 2; in unmarshal()
101 self.header().marshal_to(buf)?; in marshal_to()
H A Dparam_chunk_list.rs16 self.header(), in fmt()
27 fn header(&self) -> ParamHeader { in header() method
35 let header = ParamHeader::unmarshal(raw)?; in unmarshal() localVariable
37 if header.typ != ParamType::ChunkList { in unmarshal()
42 &mut raw.slice(PARAM_HEADER_LENGTH..PARAM_HEADER_LENGTH + header.value_length()); in unmarshal()
53 self.header().marshal_to(buf)?; in marshal_to()
H A Dparam_unknown.rs21 write!(f, "ParamUnknown( {} {:?} )", self.header(), self.value) in fmt()
26 fn header(&self) -> ParamHeader { in header() method
43 let header = ParamHeader::unmarshal(raw)?; in unmarshal() localVariable
44 let value = raw.slice(PARAM_HEADER_LENGTH..PARAM_HEADER_LENGTH + header.value_length()); in unmarshal()
46 typ: header.typ.into(), in unmarshal()
52 self.header().marshal_to(buf)?; in marshal_to()
/webrtc/mdns/src/message/
H A Dbuilder.rs1 use super::header::*;
28 pub header: HeaderInternal, field
56 header: HeaderInternal { in new()
126 Section::Questions => (&mut self.header.questions, Error::ErrTooManyQuestions), in increment_section_count()
127 Section::Answers => (&mut self.header.answers, Error::ErrTooManyAnswers), in increment_section_count()
128 Section::Authorities => (&mut self.header.authorities, Error::ErrTooManyAuthorities), in increment_section_count()
129 Section::Additionals => (&mut self.header.additionals, Error::ErrTooManyAdditionals), in increment_section_count()
176 r.header.typ = body.real_type(); in add_resource()
182 let (mut msg, len_off) = r.header.pack(msg, &mut self.compression, self.start)?; in add_resource()
186 r.header.fix_len(&mut msg, len_off, pre_len)?; in add_resource()
[all …]
/webrtc/srtp/src/cipher/
H A Dcipher_aead_aes_gcm.rs35 header: &rtp::header::Header, in encrypt_rtp()
40 BytesMut::with_capacity(header.marshal_size() + payload.len() + self.auth_tag_len()); in encrypt_rtp()
42 let data = header.marshal()?; in encrypt_rtp()
45 let nonce = self.rtp_initialization_vector(header, roc); in encrypt_rtp()
62 header: &rtp::header::Header, in decrypt_rtp()
69 let nonce = self.rtp_initialization_vector(header, roc); in decrypt_rtp()
70 let payload_offset = header.marshal_size(); in decrypt_rtp()
196 header: &rtp::header::Header, in rtp_initialization_vector()
200 BigEndian::write_u32(&mut iv[2..], header.ssrc); in rtp_initialization_vector()
202 BigEndian::write_u16(&mut iv[10..], header.sequence_number); in rtp_initialization_vector()
/webrtc/media/src/io/ogg_reader/
H A Dogg_reader_test.rs20 let (_reader, header) = OggReader::new(r, true)?; in test_ogg_reader_parse_valid_header()
22 assert_eq!(header.channel_map, 0); in test_ogg_reader_parse_valid_header()
23 assert_eq!(header.channels, 2); in test_ogg_reader_parse_valid_header()
24 assert_eq!(header.output_gain, 0); in test_ogg_reader_parse_valid_header()
25 assert_eq!(header.pre_skip, 0xf00); in test_ogg_reader_parse_valid_header()
26 assert_eq!(header.sample_rate, 48000); in test_ogg_reader_parse_valid_header()
27 assert_eq!(header.version, 1); in test_ogg_reader_parse_valid_header()

12345