| /webrtc/media/src/io/ivf_writer/ |
| H A D | mod.rs | 15 writer: W, field
24 pub fn new(writer: W, header: &IVFFileHeader) -> Result<Self> { in new()
26 writer, in new()
39 self.writer.write_all(&header.signature)?; // DKIF in write_header()
42 self.writer.write_all(&header.four_cc)?; // FOURCC in write_header()
45 self.writer in write_header()
47 self.writer in write_header()
98 self.writer.write_u64::<LittleEndian>(self.count)?; // PTS in write_rtp()
107 self.writer.write_all(&frame_content)?; in write_rtp()
115 self.writer.seek(SeekFrom::Start(24))?; in close()
[all …]
|
| H A D | ivf_writer_test.rs | 157 !writer.seen_key_frame, in test_ivf_writer_add_packet_and_close()
161 let result = writer.write_rtp(&packet); in test_ivf_writer_add_packet_and_close()
169 assert_eq!(seen_key_frame, writer.seen_key_frame, "{msg1} failed"); in test_ivf_writer_add_packet_and_close()
171 assert_eq!(writer.count, 0); in test_ivf_writer_add_packet_and_close()
173 assert_eq!(writer.count, 1); in test_ivf_writer_add_packet_and_close()
176 writer.write_rtp(&mid_part_packet)?; in test_ivf_writer_add_packet_and_close()
178 assert_eq!(writer.count, 0); in test_ivf_writer_add_packet_and_close()
180 assert_eq!(writer.count, 1); in test_ivf_writer_add_packet_and_close()
182 writer.write_rtp(&valid_packet)?; in test_ivf_writer_add_packet_and_close()
183 assert_eq!(writer.count, 2); in test_ivf_writer_add_packet_and_close()
[all …]
|
| /webrtc/srtp/src/cipher/ |
| H A D | cipher_aes_cm_hmac_sha1.rs | 173 let mut writer = in encrypt_rtp() localVariable
178 writer.extend(data); in encrypt_rtp()
181 writer.extend_from_slice(payload); in encrypt_rtp()
198 writer.extend(auth_tag); in encrypt_rtp()
200 Ok(writer.freeze()) in encrypt_rtp()
246 Ok(writer.freeze()) in decrypt_rtp()
250 let mut writer = in encrypt_rtcp() localVariable
277 writer.extend(auth_tag); in encrypt_rtcp()
279 Ok(writer.freeze()) in encrypt_rtcp()
298 return Ok(writer.freeze()); in decrypt_rtcp()
[all …]
|
| H A D | cipher_aead_aes_gcm.rs | 39 let mut writer = in encrypt_rtp() localVariable
43 writer.extend(data); in encrypt_rtp()
51 aad: &writer, in encrypt_rtp()
55 writer.extend(encrypted); in encrypt_rtp()
56 Ok(writer.freeze()) in encrypt_rtp()
81 writer.extend(decrypted_msg); in decrypt_rtp()
83 Ok(writer.freeze()) in decrypt_rtp()
100 writer.extend(encrypted_data); in encrypt_rtcp()
103 Ok(writer.freeze()) in encrypt_rtcp()
124 writer.extend(decrypted_data); in decrypt_rtcp()
[all …]
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_message_server_key_exchange.rs | 37 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
40 writer.write_all(&self.identity_hint)?; in marshal()
41 return Ok(writer.flush()?); in marshal()
44 writer.write_u8(self.elliptic_curve_type as u8)?; in marshal()
45 writer.write_u16::<BigEndian>(self.named_curve as u16)?; in marshal()
47 writer.write_u8(self.public_key.len() as u8)?; in marshal()
48 writer.write_all(&self.public_key)?; in marshal()
50 writer.write_u8(self.algorithm.hash as u8)?; in marshal()
51 writer.write_u8(self.algorithm.signature as u8)?; in marshal()
54 writer.write_all(&self.signature)?; in marshal()
[all …]
|
| H A D | handshake_header.rs | 24 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
25 writer.write_u8(self.handshake_type as u8)?; in marshal()
26 writer.write_u24::<BigEndian>(self.length)?; in marshal()
27 writer.write_u16::<BigEndian>(self.message_sequence)?; in marshal()
28 writer.write_u24::<BigEndian>(self.fragment_offset)?; in marshal()
29 writer.write_u24::<BigEndian>(self.fragment_length)?; in marshal()
31 Ok(writer.flush()?) in marshal()
|
| H A D | handshake_message_certificate_request.rs | 35 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
36 writer.write_u8(self.certificate_types.len() as u8)?; in marshal()
38 writer.write_u8(*v as u8)?; in marshal()
41 writer.write_u16::<BigEndian>(2 * self.signature_hash_algorithms.len() as u16)?; in marshal()
43 writer.write_u8(v.hash as u8)?; in marshal()
44 writer.write_u8(v.signature as u8)?; in marshal()
47 writer.write_all(&[0x00, 0x00])?; // Distinguished Names Length in marshal()
49 Ok(writer.flush()?) in marshal()
|
| H A D | handshake_message_client_hello.rs | 103 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
108 writer.write_u8(self.version.major)?; in marshal()
109 writer.write_u8(self.version.minor)?; in marshal()
110 self.random.marshal(writer)?; in marshal()
113 writer.write_u8(0x00)?; in marshal()
115 writer.write_u8(self.cookie.len() as u8)?; in marshal()
116 writer.write_all(&self.cookie)?; in marshal()
120 writer.write_u16::<BigEndian>(*cipher_suite as u16)?; in marshal()
123 self.compression_methods.marshal(writer)?; in marshal()
134 writer.write_all(&extension_buffer)?; in marshal()
[all …]
|
| H A D | handshake_message_server_hello.rs | 77 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
78 writer.write_u8(self.version.major)?; in marshal()
79 writer.write_u8(self.version.minor)?; in marshal()
80 self.random.marshal(writer)?; in marshal()
83 writer.write_u8(0x00)?; in marshal()
85 writer.write_u16::<BigEndian>(self.cipher_suite as u16)?; in marshal()
87 writer.write_u8(self.compression_method as u8)?; in marshal()
97 writer.write_u16::<BigEndian>(extension_buffer.len() as u16)?; in marshal()
98 writer.write_all(&extension_buffer)?; in marshal()
100 Ok(writer.flush()?) in marshal()
|
| H A D | handshake_message_certificate_verify.rs | 27 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
28 writer.write_u8(self.algorithm.hash as u8)?; in marshal()
29 writer.write_u8(self.algorithm.signature as u8)?; in marshal()
30 writer.write_u16::<BigEndian>(self.signature.len() as u16)?; in marshal()
31 writer.write_all(&self.signature)?; in marshal()
33 Ok(writer.flush()?) in marshal()
|
| H A D | handshake_message_hello_verify_request.rs | 42 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
47 writer.write_u8(self.version.major)?; in marshal()
48 writer.write_u8(self.version.minor)?; in marshal()
49 writer.write_u8(self.cookie.len() as u8)?; in marshal()
50 writer.write_all(&self.cookie)?; in marshal()
52 Ok(writer.flush()?) in marshal()
|
| H A D | handshake_message_client_key_exchange.rs | 28 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
36 writer.write_u8(self.public_key.len() as u8)?; in marshal()
37 writer.write_all(&self.public_key)?; in marshal()
39 writer.write_u16::<BigEndian>(self.identity_hint.len() as u16)?; in marshal()
40 writer.write_all(&self.identity_hint)?; in marshal()
43 Ok(writer.flush()?) in marshal()
|
| H A D | mod.rs | 138 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
140 HandshakeMessage::ClientHello(msg) => msg.marshal(writer)?, in marshal()
141 HandshakeMessage::ServerHello(msg) => msg.marshal(writer)?, in marshal()
143 HandshakeMessage::Certificate(msg) => msg.marshal(writer)?, in marshal()
144 HandshakeMessage::ServerKeyExchange(msg) => msg.marshal(writer)?, in marshal()
146 HandshakeMessage::ServerHelloDone(msg) => msg.marshal(writer)?, in marshal()
147 HandshakeMessage::CertificateVerify(msg) => msg.marshal(writer)?, in marshal()
149 HandshakeMessage::Finished(msg) => msg.marshal(writer)?, in marshal()
190 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
191 self.handshake_header.marshal(writer)?; in marshal()
[all …]
|
| /webrtc/dtls/src/extension/ |
| H A D | extension_server_name.rs | 26 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
28 writer.write_u16::<BigEndian>(2 + 1 + 2 + self.server_name.len() as u16)?; in marshal()
29 writer.write_u16::<BigEndian>(1 + 2 + self.server_name.len() as u16)?; in marshal()
30 writer.write_u8(EXTENSION_SERVER_NAME_TYPE_DNSHOST_NAME)?; in marshal()
31 writer.write_u16::<BigEndian>(self.server_name.len() as u16)?; in marshal()
32 writer.write_all(self.server_name.as_bytes())?; in marshal()
34 Ok(writer.flush()?) in marshal()
|
| H A D | extension_supported_signature_algorithms.rs | 24 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
25 writer.write_u16::<BigEndian>(2 + 2 * self.signature_hash_algorithms.len() as u16)?; in marshal()
26 writer.write_u16::<BigEndian>(2 * self.signature_hash_algorithms.len() as u16)?; in marshal()
28 writer.write_u8(v.hash as u8)?; in marshal()
29 writer.write_u8(v.signature as u8)?; in marshal()
32 Ok(writer.flush()?) in marshal()
|
| H A D | extension_use_srtp.rs | 48 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
49 writer.write_u16::<BigEndian>( in marshal()
52 writer.write_u16::<BigEndian>(2 * self.protection_profiles.len() as u16)?; in marshal()
54 writer.write_u16::<BigEndian>(*v as u16)?; in marshal()
58 writer.write_u8(0x00)?; in marshal()
60 Ok(writer.flush()?) in marshal()
|
| H A D | extension_supported_point_formats.rs | 27 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
28 writer.write_u16::<BigEndian>(1 + self.point_formats.len() as u16)?; in marshal()
29 writer.write_u8(self.point_formats.len() as u8)?; in marshal()
31 writer.write_u8(*v)?; in marshal()
34 Ok(writer.flush()?) in marshal()
|
| H A D | extension_supported_elliptic_curves.rs | 24 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
25 writer.write_u16::<BigEndian>(2 + 2 * self.elliptic_curves.len() as u16)?; in marshal()
26 writer.write_u16::<BigEndian>(2 * self.elliptic_curves.len() as u16)?; in marshal()
28 writer.write_u16::<BigEndian>(*v as u16)?; in marshal()
31 Ok(writer.flush()?) in marshal()
|
| H A D | renegotiation_info.rs | 28 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
29 writer.write_u16::<BigEndian>(1)?; //length in marshal()
30 writer.write_u8(self.renegotiated_connection)?; in marshal()
32 Ok(writer.flush()?) in marshal()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_selective_ack.rs | 135 fn marshal_to(&self, writer: &mut BytesMut) -> Result<usize> { in marshal_to()
136 self.header().marshal_to(writer)?; in marshal_to()
138 writer.put_u32(self.cumulative_tsn_ack); in marshal_to()
139 writer.put_u32(self.advertised_receiver_window_credit); in marshal_to()
140 writer.put_u16(self.gap_ack_blocks.len() as u16); in marshal_to()
141 writer.put_u16(self.duplicate_tsn.len() as u16); in marshal_to()
143 writer.put_u16(g.start); in marshal_to()
144 writer.put_u16(g.end); in marshal_to()
147 writer.put_u32(*t); in marshal_to()
150 Ok(writer.len()) in marshal_to()
|
| H A D | chunk_forward_tsn.rs | 91 fn marshal_to(&self, writer: &mut BytesMut) -> Result<usize> { in marshal_to()
92 self.header().marshal_to(writer)?; in marshal_to()
94 writer.put_u32(self.new_cumulative_tsn); in marshal_to()
97 writer.extend(s.marshal()?); in marshal_to()
100 Ok(writer.len()) in marshal_to()
164 fn marshal_to(&self, writer: &mut BytesMut) -> Result<usize> { in marshal_to()
165 writer.put_u16(self.identifier); in marshal_to()
166 writer.put_u16(self.sequence); in marshal_to()
167 Ok(writer.len()) in marshal_to()
|
| H A D | chunk_init.rs | 192 fn marshal_to(&self, writer: &mut BytesMut) -> Result<usize> { in marshal_to()
193 self.header().marshal_to(writer)?; in marshal_to()
195 writer.put_u32(self.initiate_tag); in marshal_to()
196 writer.put_u32(self.advertised_receiver_window_credit); in marshal_to()
197 writer.put_u16(self.num_outbound_streams); in marshal_to()
198 writer.put_u16(self.num_inbound_streams); in marshal_to()
199 writer.put_u32(self.initial_tsn); in marshal_to()
203 writer.extend(pp); in marshal_to()
214 writer.extend(vec![0u8; cnt]); in marshal_to()
218 Ok(writer.len()) in marshal_to()
|
| /webrtc/interceptor/src/ |
| H A D | chain.rs | 42 mut writer: Arc<dyn RTCPWriter + Send + Sync>, in bind_rtcp_writer()
45 writer = icpr.bind_rtcp_writer(writer).await; in bind_rtcp_writer()
47 writer in bind_rtcp_writer()
55 mut writer: Arc<dyn RTPWriter + Send + Sync>, in bind_local_stream()
58 writer = icpr.bind_local_stream(info, writer).await; in bind_local_stream()
60 writer in bind_local_stream()
|
| /webrtc/dtls/src/record_layer/ |
| H A D | record_layer_header.rs | 47 pub fn marshal<W: Write>(&self, writer: &mut W) -> Result<()> { in marshal()
52 writer.write_u8(self.content_type as u8)?; in marshal()
53 writer.write_u8(self.protocol_version.major)?; in marshal()
54 writer.write_u8(self.protocol_version.minor)?; in marshal()
55 writer.write_u16::<BigEndian>(self.epoch)?; in marshal()
58 writer.write_all(&be[2..])?; // uint48 in spec in marshal()
60 writer.write_u16::<BigEndian>(self.content_len)?; in marshal()
62 Ok(writer.flush()?) in marshal()
|
| /webrtc/media/src/io/h264_writer/ |
| H A D | h264_writer_test.rs | 74 let mut writer = vec![]; in test_write_rtp() localVariable
76 let w = Cursor::new(&mut writer); in test_write_rtp()
89 assert_eq!(writer, want_bytes); in test_write_rtp()
106 let mut writer = vec![]; in test_write_rtp_fu() localVariable
108 let w = Cursor::new(&mut writer); in test_write_rtp_fu()
122 assert_eq!(writer, want_bytes); in test_write_rtp_fu()
|