| /webrtc/dtls/src/flight/ |
| H A D | flight3.rs | 66 let h = match message { in parse() localVariable
67 HandshakeMessage::HelloVerifyRequest(h) => h, in parse()
81 if h.version != PROTOCOL_VERSION1_0 && h.version != PROTOCOL_VERSION1_2 { in parse()
171 let h = match message { in parse() localVariable
172 HandshakeMessage::ServerHello(h) => h, in parse()
249 h.cipher_suite in parse()
293 let h = match message { in parse() localVariable
294 HandshakeMessage::Certificate(h) => h, in parse()
309 let h = match message { in parse() localVariable
310 HandshakeMessage::ServerKeyExchange(h) => h, in parse()
[all …]
|
| H A D | flight5.rs | 64 h in parse()
275 Ok(h) => h, in generate()
288 HandshakeMessage::ServerKeyExchange(h) => server_key_exchange = h, in generate()
305 let h = match &mut p.record.content { in generate() localVariable
306 Content::Handshake(h) => h, in generate()
452 Content::Handshake(h) => h, in generate()
605 h: &HandshakeMessageServerKeyExchange, in initalize_cipher_suite()
690 if ss.hash == h.algorithm.hash && ss.signature == h.algorithm.signature { in initalize_cipher_suite()
706 value_key_message(&client_random, &server_random, &h.public_key, h.named_curve); in initalize_cipher_suite()
709 &h.algorithm, in initalize_cipher_suite()
[all …]
|
| H A D | flight1.rs | 81 let h = match message { in parse() localVariable
82 HandshakeMessage::HelloVerifyRequest(h) => h, in parse()
94 if h.version != PROTOCOL_VERSION1_0 && h.version != PROTOCOL_VERSION1_2 { in parse()
104 state.cookie = h.cookie.clone(); in parse()
|
| H A D | flight4.rs | 82 let client_key_exchange = if let Some(HandshakeMessage::ClientKeyExchange(h)) = in parse()
85 h in parse()
97 let h = match message { in parse() localVariable
98 HandshakeMessage::Certificate(h) => h, in parse()
110 state.peer_certificates = h.certificate.clone(); in parse()
118 let h = match message { in parse() localVariable
119 HandshakeMessage::CertificateVerify(h) => h, in parse()
197 if ss.hash == h.algorithm.hash && ss.signature == h.algorithm.signature { in parse()
214 &h.algorithm, in parse()
215 &h.signature, in parse()
[all …]
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_cbc.rs | 61 let h = pkt_rlh; in encrypt() localVariable
64 h.epoch, in encrypt()
65 h.sequence_number, in encrypt()
66 h.content_type, in encrypt()
67 h.protocol_version, in encrypt()
94 let h = RecordLayerHeader::unmarshal(&mut reader)?; in decrypt() localVariable
95 if h.content_type == ContentType::ChangeCipherSpec { in decrypt()
112 h.epoch, in decrypt()
113 h.sequence_number, in decrypt()
114 h.content_type, in decrypt()
[all …]
|
| H A D | crypto_ccm.rs | 148 let h = RecordLayerHeader::unmarshal(&mut reader)?; in decrypt() localVariable
149 if h.content_type == ContentType::ChangeCipherSpec { in decrypt()
171 generate_aead_additional_data(&h, out.len() - CRYPTO_CCM_TAG_LENGTH); in decrypt()
177 generate_aead_additional_data(&h, out.len() - CRYPTO_CCM_8_TAG_LENGTH); in decrypt()
|
| /webrtc/dtls/src/prf/ |
| H A D | mod.rs | 144 let mut mac = match h { in hmac_sha()
159 h: CipherSuiteHash, in prf_p_hash()
181 h: CipherSuiteHash, in prf_extended_master_secret()
192 h: CipherSuiteHash, in prf_master_secret()
207 h: CipherSuiteHash, in prf_encryption_keys()
217 h, in prf_encryption_keys()
253 h: CipherSuiteHash, in prf_verify_data()
269 h: CipherSuiteHash, in prf_verify_data_client()
275 h, in prf_verify_data_client()
282 h: CipherSuiteHash, in prf_verify_data_server()
[all …]
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | mod.rs | 96 let h = self.header(); in marshal_to() localVariable
97 let n = h.marshal_to(buf)?; in marshal_to()
110 if h.padding { in marshal_to()
130 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
132 if raw_packet_len < (HEADER_LENGTH + (4 * h.length) as usize) { in unmarshal()
136 if h.packet_type != PacketType::PayloadSpecificFeedback || h.count != FORMAT_FIR { in unmarshal()
145 while i < HEADER_LENGTH + (h.length * 4) as usize { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/slice_loss_indication/ |
| H A D | mod.rs | 103 let h = self.header(); in marshal_to() localVariable
104 let n = h.marshal_to(buf)?; in marshal_to()
118 if h.padding { in marshal_to()
138 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
140 if raw_packet_len < (HEADER_LENGTH + (4 * h.length as usize)) { in unmarshal()
144 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_SLI { in unmarshal()
153 while i < HEADER_LENGTH + h.length as usize * 4 { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/picture_loss_indication/ |
| H A D | mod.rs | 91 let h = self.header(); in marshal_to() localVariable
92 let n = h.marshal_to(buf)?; in marshal_to()
98 if h.padding { in marshal_to()
118 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
119 if h.packet_type != PacketType::PayloadSpecificFeedback || h.count != FORMAT_PLI { in unmarshal()
|
| /webrtc/rtcp/src/transport_feedbacks/rapid_resynchronization_request/ |
| H A D | mod.rs | 93 let h = self.header(); in marshal_to() localVariable
94 let n = h.marshal_to(buf)?; in marshal_to()
100 if h.padding { in marshal_to()
120 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
122 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_RRR { in unmarshal()
|
| /webrtc/rtcp/src/ |
| H A D | raw_packet.rs | 24 Ok(h) => h, in header()
65 let h = Header::unmarshal(&mut self.0.clone())?; in marshal_to() localVariable
67 if h.padding { in marshal_to()
86 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
88 let raw_hdr = h.marshal()?; in unmarshal()
|
| H A D | packet.rs | 83 let h = Header::unmarshal(raw_data)?; in unmarshaller() localVariable
85 let length = (h.length as usize) * 4; in unmarshaller()
90 let mut in_packet = h.marshal()?.chain(raw_data.take(length)); in unmarshaller()
92 let p: Box<dyn Packet + Send + Sync> = match h.packet_type { in unmarshaller()
98 PacketType::TransportSpecificFeedback => match h.count { in unmarshaller()
104 PacketType::PayloadSpecificFeedback => match h.count { in unmarshaller()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 179 let h = self.header(); in marshal_to() localVariable
180 let n = h.marshal_to(buf)?; in marshal_to()
191 if h.padding { in marshal_to()
211 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
213 if raw_packet_len < (HEADER_LENGTH + (4 * h.length) as usize) { in unmarshal()
217 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_TLN { in unmarshal()
225 for _i in 0..(h.length as i32 - NACK_OFFSET as i32 / 4) { in unmarshal()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_test.rs | 54 let h = Handshake::unmarshal(&mut reader)?; in test_handshake_message() localVariable
56 h, parsed_handshake, in test_handshake_message()
63 h.marshal(&mut writer)?; in test_handshake_message()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 562 h, in handle_outgoing_packets()
637 h: &Handshake, in process_handshake_packet()
887 Ok(h) => h, in handle_incoming_packet()
902 if h.epoch > epoch { in handle_incoming_packet()
903 if h.epoch > epoch + 1 { in handle_incoming_packet()
907 h.epoch, in handle_incoming_packet()
931 let ok = ctx.replay_detector[h.epoch as usize].check(h.sequence_number); in handle_incoming_packet()
936 h.epoch, in handle_incoming_packet()
937 h.sequence_number, in handle_incoming_packet()
943 if h.epoch != 0 { in handle_incoming_packet()
[all …]
|
| /webrtc/turn/src/proto/ |
| H A D | proto_test.rs | 17 for h in &CHROME_ALLOC_REQ_TEST_HEX { in test_chrome_alloc_request()
18 let b = match hex::decode(h) { in test_chrome_alloc_request()
|
| /webrtc/dtls/src/signature_hash_algorithm/ |
| H A D | mod.rs | 197 let h: HashAlgorithm = (((*ss >> 8) & 0xFF) as u8).into(); in parse_signature_schemes() localVariable
198 if h == HashAlgorithm::Unsupported || h.invalid() { in parse_signature_schemes()
201 if h.insecure() && !insecure_hashes { in parse_signature_schemes()
205 hash: h, in parse_signature_schemes()
|
| /webrtc/turn/src/auth/ |
| H A D | mod.rs | 40 let mut h = Md5::new(); in generate_auth_key() localVariable
41 h.update(s.as_bytes()); in generate_auth_key()
42 h.finalize().as_slice().to_vec() in generate_auth_key()
|
| /webrtc/dtls/examples/listen/selfsign/ |
| H A D | listen_selfsign.rs | 71 let h = Arc::new(hub::Hub::new()); in main() localVariable
74 let h2 = Arc::clone(&h); in main()
82 h.chat().await; in main()
|
| /webrtc/dtls/examples/listen/psk/ |
| H A D | listen_psk.rs | 74 let h = Arc::new(hub::Hub::new()); in main() localVariable
77 let h2 = Arc::clone(&h); in main()
85 h.chat().await; in main()
|
| /webrtc/stun/src/ |
| H A D | integrity.rs | 72 let mut h = Md5::new(); in new_long_term_integrity() localVariable
73 h.update(s.as_bytes()); in new_long_term_integrity()
75 MessageIntegrity(h.finalize().as_slice().to_vec()) in new_long_term_integrity()
|
| /webrtc/dtls/examples/listen/verify/ |
| H A D | listen_verify.rs | 83 let h = Arc::new(hub::Hub::new()); in main() localVariable
89 let h2 = Arc::clone(&h); in main()
111 h.chat().await; in main()
|
| /webrtc/media/src/io/ogg_reader/ |
| H A D | mod.rs | 112 let mut h = [0u8; PAGE_HEADER_SIZE]; in parse_next_page() localVariable
113 self.reader.read_exact(&mut h)?; in parse_next_page()
115 let mut head_reader = Cursor::new(h); in parse_next_page()
141 for (index, v) in h.iter().enumerate() { in parse_next_page()
|
| /webrtc/rtcp/src/source_description/ |
| H A D | mod.rs | 368 let h = self.header(); in marshal_to() localVariable
369 let n = h.marshal_to(buf)?; in marshal_to()
377 if h.padding { in marshal_to()
411 let h = Header::unmarshal(raw_packet)?; in unmarshal() localVariable
412 if h.packet_type != PacketType::SourceDescription { in unmarshal()
424 if chunks.len() != h.count as usize { in unmarshal()
|