| /webrtc/turn/src/proto/ |
| H A D | chandata.rs | 28 pub raw: Vec<u8>, field 41 self.raw.clear(); in reset() 47 self.raw.clear(); in encode() 49 self.raw.extend_from_slice(&self.data); in encode() 50 let padded = nearest_padded_value_length(self.raw.len()); in encode() 51 let bytes_to_add = padded - self.raw.len(); in encode() 53 self.raw.extend_from_slice(&vec![0; bytes_to_add]); in encode() 59 let buf = &self.raw; in decode() 82 if self.raw.len() < CHANNEL_DATA_HEADER_SIZE { in write_header() 85 self.raw in write_header() [all …]
|
| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | video_orientation_extension_test.rs | 16 let raw = Bytes::from_static(&[0b1000]); in test_video_orientation_extension_back_facing_camera() localVariable 17 let buf = &mut raw.clone(); in test_video_orientation_extension_back_facing_camera() 29 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_back_facing_camera() 37 let buf = &mut raw.clone(); in test_video_orientation_extension_flip_true() 49 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_flip_true() 57 let buf = &mut raw.clone(); in test_video_orientation_extension_degree_90() 69 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_degree_90() 77 let buf = &mut raw.clone(); in test_video_orientation_extension_degree_180() 89 assert_eq!(raw, dst.freeze()); in test_video_orientation_extension_degree_180() 97 let buf = &mut raw.clone(); in test_video_orientation_extension_degree_270() [all …]
|
| /webrtc/rtp/src/codecs/h265/ |
| H A D | h265_test.rs | 171 raw: Bytes, in test_h265_single_nalunit_packet() field 179 raw: Bytes::from_static(&[]), in test_h265_single_nalunit_packet() 277 raw: Bytes, in test_h265_aggregation_packet() field 347 raw: Bytes::from_static(&[ in test_h265_aggregation_packet() 357 raw: Bytes::from_static(&[ in test_h265_aggregation_packet() 368 raw: Bytes::from_static(&[ in test_h265_aggregation_packet() 466 raw: Bytes, in test_h265_fragmentation_unit_packet() field 633 raw: Bytes, in test_h265_paci_packet() field 691 raw: Bytes::from_static(&[ in test_h265_paci_packet() 741 raw: Bytes, in test_h265_packet() field [all …]
|
| /webrtc/rtp/src/extension/abs_send_time_extension/ |
| H A D | abs_send_time_extension_test.rs | 78 let mut raw = BytesMut::with_capacity(test.marshal_size()); in test_abs_send_time_extension_roundtrip() localVariable 79 raw.resize(test.marshal_size(), 0); in test_abs_send_time_extension_roundtrip() 80 test.marshal_to(&mut raw)?; in test_abs_send_time_extension_roundtrip() 81 let raw = raw.freeze(); in test_abs_send_time_extension_roundtrip() localVariable 82 let buf = &mut raw.clone(); in test_abs_send_time_extension_roundtrip() 103 let mut raw = BytesMut::with_capacity(send.marshal_size()); in test_abs_send_time_extension_estimate() localVariable 104 raw.resize(send.marshal_size(), 0); in test_abs_send_time_extension_estimate() 105 send.marshal_to(&mut raw)?; in test_abs_send_time_extension_estimate() 106 let raw = raw.freeze(); in test_abs_send_time_extension_estimate() localVariable 107 let buf = &mut raw.clone(); in test_abs_send_time_extension_estimate()
|
| /webrtc/sctp/src/ |
| H A D | packet.rs | 84 pub(crate) fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() 85 if raw.len() < PACKET_HEADER_SIZE { in unmarshal() 89 let reader = &mut raw.clone(); in unmarshal() 99 let our_checksum = generate_packet_checksum(raw); in unmarshal() 110 if offset == raw.len() { in unmarshal() 112 } else if offset + CHUNK_HEADER_SIZE > raw.len() { in unmarshal() 116 let ct = ChunkType(raw[offset]); in unmarshal() 118 CT_INIT => Box::new(ChunkInit::unmarshal(&raw.slice(offset..))?), in unmarshal() 120 CT_ABORT => Box::new(ChunkAbort::unmarshal(&raw.slice(offset..))?), in unmarshal() 128 CT_ERROR => Box::new(ChunkError::unmarshal(&raw.slice(offset..))?), in unmarshal() [all …]
|
| H A D | error_cause.rs | 53 pub(crate) raw: Bytes, field 109 let raw = buf.slice(ERROR_CAUSE_HEADER_LENGTH..ERROR_CAUSE_HEADER_LENGTH + value_length); in unmarshal() localVariable 111 Ok(ErrorCause { code, raw }) in unmarshal() 121 let len = self.raw.len() + ERROR_CAUSE_HEADER_LENGTH; in marshal_to() 124 writer.extend(self.raw.clone()); in marshal_to() 129 self.raw.len() + ERROR_CAUSE_HEADER_LENGTH in length()
|
| /webrtc/stun/src/ |
| H A D | message.rs | 62 pub raw: Vec<u8>, field 116 raw: { in new() 119 raw in new() 129 Ok(self.raw.clone()) in marshal_binary() 135 self.raw.clear(); in unmarshal_binary() 150 self.raw.clear(); in reset() 163 self.raw.extend_from_slice(&vec![0; n - self.raw.len()]); in grow() 265 self.raw.clear(); in encode() 371 self.raw.clear(); in write() 379 b.raw.clear(); in clone_to() [all …]
|
| /webrtc/turn/src/proto/chandata/ |
| H A D | chandata_test.rs | 13 b.raw.extend_from_slice(&d.raw); in test_channel_data_encode() 19 ChannelData::is_channel_data(&b.raw) && ChannelData::is_channel_data(&d.raw), in test_channel_data_encode() 118 raw: buf, in test_channel_data_decode() 139 let mut buf = vec![0; d.raw.len()]; in test_channel_data_reset() 140 buf.copy_from_slice(&d.raw); in test_channel_data_reset() 142 d.raw = buf; in test_channel_data_reset() 186 raw: packet, in test_chrome_channel_data() 199 raw: encoded.raw.clone(), in test_chrome_channel_data()
|
| /webrtc/rtp/src/extension/transport_cc_extension/ |
| H A D | transport_cc_extension_test.rs | 16 let raw = Bytes::from_static(&[0x00, 0x02]); in test_transport_cc_extension() localVariable 17 let buf = &mut raw.clone(); in test_transport_cc_extension() 27 assert_eq!(raw, dst.freeze()); in test_transport_cc_extension() 34 let mut raw = Bytes::from_static(&[0x00, 0x02, 0x00, 0xff, 0xff]); in test_transport_cc_extension_extra_bytes() localVariable 35 let buf = &mut raw; in test_transport_cc_extension_extra_bytes()
|
| /webrtc/rtp/src/extension/audio_level_extension/ |
| H A D | audio_level_extension_test.rs | 16 let raw = Bytes::from_static(&[0x88]); in test_audio_level_extension_voice_true() localVariable 17 let buf = &mut raw.clone(); in test_audio_level_extension_voice_true() 28 assert_eq!(raw, dst.freeze()); in test_audio_level_extension_voice_true() 35 let raw = Bytes::from_static(&[0x8]); in test_audio_level_extension_voice_false() localVariable 36 let buf = &mut raw.clone(); in test_audio_level_extension_voice_false() 47 assert_eq!(raw, dst.freeze()); in test_audio_level_extension_voice_false()
|
| /webrtc/dtls/src/extension/extension_use_extended_master_secret/ |
| H A D | extension_use_extended_master_secret_test.rs | 11 let mut raw = vec![]; in test_extension_use_extended_master_secret() localVariable 13 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_use_extended_master_secret() 18 raw, raw_extension_use_extended_master_secret, in test_extension_use_extended_master_secret() 22 let mut reader = BufReader::new(raw.as_slice()); in test_extension_use_extended_master_secret()
|
| /webrtc/dtls/src/extension/extension_supported_elliptic_curves/ |
| H A D | extension_supported_elliptic_curves_test.rs | 12 let mut raw = vec![]; in test_extension_supported_groups() localVariable 14 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_supported_groups() 19 raw, raw_supported_groups, in test_extension_supported_groups() 23 let mut reader = BufReader::new(raw.as_slice()); in test_extension_supported_groups()
|
| /webrtc/dtls/src/extension/extension_use_srtp/ |
| H A D | extension_use_srtp_test.rs | 12 let mut raw = vec![]; in test_extension_use_srtp() localVariable 14 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_use_srtp() 19 raw, raw_use_srtp, in test_extension_use_srtp() 23 let mut reader = BufReader::new(raw.as_slice()); in test_extension_use_srtp()
|
| /webrtc/dtls/src/extension/extension_supported_point_formats/ |
| H A D | extension_supported_point_formats_test.rs | 12 let mut raw = vec![]; in test_extension_supported_point_formats() localVariable 14 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_supported_point_formats() 19 raw, raw_extension_supported_point_formats, in test_extension_supported_point_formats() 23 let mut reader = BufReader::new(raw.as_slice()); in test_extension_supported_point_formats()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_header.rs | 42 fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() 43 if raw.len() < CHUNK_HEADER_SIZE { in unmarshal() 47 let reader = &mut raw.clone(); in unmarshal() 56 if (length as usize) > raw.len() { in unmarshal() 63 let length_after_value = raw.len() as isize - length as isize; in unmarshal() 78 if raw[padding_offset] != 0 { in unmarshal()
|
| H A D | chunk_shutdown.rs | 38 fn unmarshal(raw: &Bytes) -> Result<Self> { in unmarshal() 39 let header = ChunkHeader::unmarshal(raw)?; in unmarshal() 45 if raw.len() != CHUNK_HEADER_SIZE + CUMULATIVE_TSN_ACK_LENGTH { in unmarshal() 49 let reader = &mut raw.slice(CHUNK_HEADER_SIZE..CHUNK_HEADER_SIZE + header.value_length()); in unmarshal()
|
| /webrtc/dtls/src/extension/extension_supported_signature_algorithms/ |
| H A D | extension_supported_signature_algorithms_test.rs | 26 let mut raw = vec![]; in test_extension_supported_signature_algorithms() localVariable 28 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_supported_signature_algorithms() 33 raw, raw_extension_supported_signature_algorithms, in test_extension_supported_signature_algorithms() 37 let mut reader = BufReader::new(raw.as_slice()); in test_extension_supported_signature_algorithms()
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 549 assert_eq!(m.raw.len(), 512, "Bad length {}", m.raw.len()); in test_message_grow() 558 assert!(m.raw.capacity() >= 20, "Bad capacity {}", m.raw.capacity()); in test_message_grow_smaller() 560 assert!(m.raw.len() >= 20, "Bad length {}", m.raw.len()); in test_message_grow_smaller() 630 let l = m.raw.len(); in test_message_full_size() 631 m.raw = m.raw[..l - 10].to_vec(); in test_message_full_size() 634 let l = m.raw.len(); in test_message_full_size() 635 decoder.raw = m.raw[..l - 10].to_vec(); in test_message_full_size() 706 m_decoded.raw.clear(); in test_decode() 707 m_decoded.raw.extend_from_slice(&m.raw); in test_decode() 730 for i in 0..m.raw.len() { in test_message_marshal_binary() [all …]
|
| /webrtc/stun/src/fingerprint/ |
| H A D | fingerprint_test.rs | 20 …assert_eq!(&m.raw[0..m.raw.len()-8], b"\x00\x00\x00\x14\x21\x12\xA4\x42\x00\x00\x00\x00\x00\x00\x0… in fingerprint_uses_crc_32_iso_hdlc() 22 assert_eq!(m.raw[m.raw.len() - 4..], [0xe4, 0x4c, 0x33, 0xd9]); in fingerprint_uses_crc_32_iso_hdlc() 40 m.raw[3] += 1; in test_fingerprint_check()
|
| /webrtc/dtls/src/extension/extension_server_name/ |
| H A D | extension_server_name_test.rs | 11 let mut raw = vec![]; in test_extension_server_name() localVariable 13 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_extension_server_name() 17 let mut reader = BufReader::new(raw.as_slice()); in test_extension_server_name()
|
| /webrtc/dtls/src/extension/renegotiation_info/ |
| H A D | renegotiation_info_test.rs | 11 let mut raw = vec![]; in test_renegotiation_info() localVariable 13 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_renegotiation_info() 17 let mut reader = BufReader::new(raw.as_slice()); in test_renegotiation_info()
|
| /webrtc/dtls/src/handshake/handshake_message_server_hello_done/ |
| H A D | handshake_message_server_hello_done_test.rs | 17 let mut raw = vec![]; in test_handshake_message_server_hello_done() localVariable 19 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_handshake_message_server_hello_done() 23 raw, raw_server_hello_done, in test_handshake_message_server_hello_done()
|
| /webrtc/dtls/src/handshake/handshake_message_finished/ |
| H A D | handshake_message_finished_test.rs | 21 let mut raw = vec![]; in test_handshake_message_finished() localVariable 23 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_handshake_message_finished() 27 raw, raw_finished, in test_handshake_message_finished()
|
| /webrtc/dtls/src/handshake/handshake_message_client_key_exchange/ |
| H A D | handshake_message_client_key_exchange_test.rs | 24 let mut raw = vec![]; in test_handshake_message_client_key_exchange() localVariable 26 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_handshake_message_client_key_exchange() 30 raw, raw_client_key_exchange, in test_handshake_message_client_key_exchange()
|
| /webrtc/dtls/src/handshake/handshake_message_hello_verify_request/ |
| H A D | handshake_message_hello_verify_request_test.rs | 29 let mut raw = vec![]; in test_handshake_message_hello_verify_request() localVariable 31 let mut writer = BufWriter::<&mut Vec<u8>>::new(raw.as_mut()); in test_handshake_message_hello_verify_request() 35 raw, raw_hello_verify_request, in test_handshake_message_hello_verify_request()
|