| /webrtc/rtp/src/packet/ |
| H A D | mod.rs | 20 let mut out = "RTP PACKET:\n".to_string(); in fmt() localVariable
22 out += format!("\tVersion: {}\n", self.header.version).as_str(); in fmt()
23 out += format!("\tMarker: {}\n", self.header.marker).as_str(); in fmt()
24 out += format!("\tPayload Type: {}\n", self.header.payload_type).as_str(); in fmt()
25 out += format!("\tSequence Number: {}\n", self.header.sequence_number).as_str(); in fmt()
26 out += format!("\tTimestamp: {}\n", self.header.timestamp).as_str(); in fmt()
27 out += format!("\tSSRC: {} ({:x})\n", self.header.ssrc, self.header.ssrc).as_str(); in fmt()
28 out += format!("\tPayload Length: {}\n", self.payload.len()).as_str(); in fmt()
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | mod.rs | 64 let mut out = format!("SenderReport from {}\n", self.ssrc); in fmt() localVariable
65 out += format!("\tNTPTime:\t{}\n", self.ntp_time).as_str(); in fmt()
66 out += format!("\tRTPTIme:\t{}\n", self.rtp_time).as_str(); in fmt()
67 out += format!("\tPacketCount:\t{}\n", self.packet_count).as_str(); in fmt()
68 out += format!("\tOctetCount:\t{}\n", self.octet_count).as_str(); in fmt()
69 out += "\tSSRC \tLost\tLastSequence\n"; in fmt()
71 out += format!( in fmt()
77 out += format!("\tProfile Extension Data: {:?}\n", self.profile_extensions).as_str(); in fmt()
96 let mut out: Vec<u32> = self.reports.iter().map(|x| x.ssrc).collect(); in destination_ssrc() localVariable
97 out.push(self.ssrc); in destination_ssrc()
[all …]
|
| /webrtc/dtls/src/prf/ |
| H A D | mod.rs | 40 let mut out = "EncryptionKeys:\n".to_string(); in fmt() localVariable
42 out += format!("- master_secret: {:?}\n", self.master_secret).as_str(); in fmt()
43 out += format!("- client_mackey: {:?}\n", self.client_mac_key).as_str(); in fmt()
62 let mut out = vec![0u8; 2 + psk_len + 2]; in prf_psk_pre_master_secret() localVariable
64 out.extend_from_slice(psk); in prf_psk_pre_master_secret()
66 out[..2].copy_from_slice(&be); in prf_psk_pre_master_secret()
67 out[2 + psk_len..2 + psk_len + 2].copy_from_slice(&be); in prf_psk_pre_master_secret()
69 out in prf_psk_pre_master_secret()
162 let mut out = vec![]; in prf_p_hash() localVariable
172 out.extend_from_slice(&with_secret); in prf_p_hash()
[all …]
|
| /webrtc/dtls/examples/certificates/ |
| H A D | README.md | 14 $ openssl ecparam -name prime256v1 -genkey -noout -out "${SERVER_NAME}.pem"
15 $ openssl req -key "${SERVER_NAME}.pem" -new -sha256 -subj '/C=NL' -out "${SERVER_NAME}.csr"
16 …sr" -extfile "${EXTFILE}" -days 365 -signkey "${SERVER_NAME}.pem" -sha256 -out "${SERVER_NAME}.pub…
20 $ openssl ecparam -name prime256v1 -genkey -noout -out "${CLIENT_NAME}.pem"
21 $ openssl req -key "${CLIENT_NAME}.pem" -new -sha256 -subj '/C=NL' -out "${CLIENT_NAME}.csr"
22 …R_NAME}.pub.pem" -CAkey "${SERVER_NAME}.pem" -set_serial '0xabcd' -sha256 -out "${CLIENT_NAME}.pub…
|
| /webrtc/stun/src/uri/ |
| H A D | uri_test.rs | 49 let out = Uri::parse_uri(input)?; in test_parse_uri() localVariable
50 assert_eq!(out, output, "{name}: {out} != {output}"); in test_parse_uri()
51 assert_eq!(out.to_string(), expected_str, "{name}"); in test_parse_uri()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | transport_layer_nack_test.rs | 209 let out = Arc::new(Mutex::new(vec![])); in test_nack_pair_range() localVariable
210 let out1 = Arc::clone(&out); in test_nack_pair_range()
219 let o = out.lock().unwrap(); in test_nack_pair_range()
223 let out = Arc::new(Mutex::new(vec![])); in test_nack_pair_range() localVariable
224 let out1 = Arc::clone(&out); in test_nack_pair_range()
233 let o = out.lock().unwrap(); in test_nack_pair_range()
|
| H A D | mod.rs | 115 let mut out = format!("TransportLayerNack from {:x}\n", self.sender_ssrc); in fmt() localVariable
116 out += format!("\tMedia Ssrc {:x}\n", self.media_ssrc).as_str(); in fmt()
117 out += "\tID\tLostPackets\n"; in fmt()
119 out += format!("\t{}\t{:b}\n", nack.packet_id, nack.lost_packets).as_str(); in fmt()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_cache.rs | 76 let mut out = vec![]; in pull() localVariable
92 out.push(c); in pull()
96 out in pull()
131 let mut out = HashMap::new(); in full_pull_map() localVariable
145 out.insert(t, raw_handshake.handshake_message); in full_pull_map()
149 Ok((seq, out)) in full_pull_map()
|
| /webrtc/srtp/src/ |
| H A D | key_derivation.rs | 48 let mut out = vec![0u8; ((out_len + n_master_key) / n_master_key) * n_master_key]; in aes_cm_key_derivation() localVariable
54 out[n..n + n_master_key].copy_from_slice(&prf_in); in aes_cm_key_derivation()
55 let out_key = GenericArray::from_mut_slice(&mut out[n..n + n_master_key]); in aes_cm_key_derivation()
59 Ok(out[..out_len].to_vec()) in aes_cm_key_derivation()
|
| /webrtc/util/src/replay_detector/ |
| H A D | replay_detector_test.rs | 266 let mut out = vec![]; in test_replay_detector() localVariable
270 out.push(*seq); in test_replay_detector()
275 assert_eq!(&out, exp, "{name} failed"); in test_replay_detector()
|
| /webrtc/dtls/src/record_layer/ |
| H A D | mod.rs | 86 let mut out = vec![]; in unpack_datagram() localVariable
101 out.push(buf[offset..offset + pkt_len].to_vec()); in unpack_datagram()
105 Ok(out) in unpack_datagram()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_cc/ |
| H A D | mod.rs | 451 let mut out = String::new(); in fmt() localVariable
452 out += format!("TransportLayerCC:\n\tSender Ssrc {}\n", self.sender_ssrc).as_str(); in fmt()
453 out += format!("\tMedia Ssrc {}\n", self.media_ssrc).as_str(); in fmt()
454 out += format!("\tBase Sequence Number {}\n", self.base_sequence_number).as_str(); in fmt()
455 out += format!("\tStatus Count {}\n", self.packet_status_count).as_str(); in fmt()
456 out += format!("\tReference Time {}\n", self.reference_time).as_str(); in fmt()
457 out += format!("\tFeedback Packet Count {}\n", self.fb_pkt_count).as_str(); in fmt()
458 out += "\tpacket_chunks "; in fmt()
459 out += "\n\trecv_deltas "; in fmt()
461 out += format!("{delta:?} ").as_str(); in fmt()
[all …]
|
| /webrtc/dtls/src/signature_hash_algorithm/ |
| H A D | mod.rs | 191 let mut out = vec![]; in parse_signature_schemes() localVariable
204 out.push(SignatureHashAlgorithm { in parse_signature_schemes()
210 if out.is_empty() { in parse_signature_schemes()
213 Ok(out) in parse_signature_schemes()
|
| /webrtc/rtp/src/codecs/vp8/ |
| H A D | mod.rs | 71 let mut out = BytesMut::with_capacity(using_header_size + current_fragment_size); in payload() localVariable
91 out.put(&buf[..using_header_size]); in payload()
93 out.put( in payload()
96 payloads.push(out.freeze()); in payload()
|
| /webrtc/rtcp/src/receiver_report/ |
| H A D | mod.rs | 33 let mut out = format!("ReceiverReport from {}\n", self.ssrc); in fmt() localVariable
34 out += "\tSSRC \tLost\tLastSequence\n"; in fmt()
36 out += format!( in fmt()
42 out += format!("\tProfile Extension Data: {:?}\n", self.profile_extensions).as_str(); in fmt()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | fragment_buffer_test.rs | 134 let (out, epoch) = fragment_buffer.pop()?; in test_fragment_buffer()
136 out, expected, in test_fragment_buffer()
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_ccm.rs | 163 let out = &r[RECORD_LAYER_HEADER_SIZE + 8..]; in decrypt() localVariable
166 buffer.extend_from_slice(out); 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()
|
| H A D | crypto_gcm.rs | 103 let out = &r[RECORD_LAYER_HEADER_SIZE + 8..]; in decrypt() localVariable
105 let additional_data = generate_aead_additional_data(&h, out.len() - CRYPTO_GCM_TAG_LENGTH); in decrypt()
108 buffer.extend_from_slice(out); in decrypt()
|
| /webrtc/rtp/src/codecs/h264/ |
| H A D | mod.rs | 125 let mut out = BytesMut::with_capacity(FUA_HEADER_SIZE + current_fragment_size as usize); in emit() localVariable
132 out.put_u8(b0); in emit()
148 out.put_u8(b1); in emit()
150 out.put( in emit()
154 payloads.push(out.freeze()); in emit()
|
| /webrtc/util/src/fixed_big_int/ |
| H A D | mod.rs | 15 let mut out = String::new(); in fmt() localVariable
17 out += format!("{:016X}", self.bits[i]).as_str(); in fmt()
|
| /webrtc/rtcp/src/goodbye/ |
| H A D | mod.rs | 24 let mut out = "Goodbye:\n\tSources:\n".to_string(); in fmt() localVariable
26 out += format!("\t{}\n", *s).as_str(); in fmt()
28 out += format!("\tReason: {:?}\n", self.reason).as_str(); in fmt()
|
| /webrtc/rtp/src/extension/abs_send_time_extension/ |
| H A D | abs_send_time_extension_test.rs | 83 let out = AbsSendTimeExtension::unmarshal(buf)?; in test_abs_send_time_extension_roundtrip() localVariable
84 assert_eq!(test.timestamp, out.timestamp); in test_abs_send_time_extension_roundtrip()
|
| /webrtc/srtp/src/context/ |
| H A D | srtp_test.rs | 107 let out = encrypt_context.encrypt_rtp(&pkt_raw)?; in test_rtp_invalid_auth() localVariable
109 let result = invalid_context.decrypt_rtp(&out); in test_rtp_invalid_auth()
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | mod.rs | 109 let mut out = BytesMut::with_capacity(VP9HEADER_SIZE + current_fragment_size); in payload() localVariable
121 out.put(&buf[..]); in payload()
123 out.put( in payload()
127 payloads.push(out.freeze()); in payload()
|
| /webrtc/rtcp/src/ |
| H A D | packet.rs | 43 let mut out = BytesMut::new(); in marshal() localVariable
46 out.put(data); in marshal()
48 Ok(out.freeze()) in marshal()
|