| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_builder_test.rs | 6 macro_rules! bytes { macro
17 head_bytes: Vec<bytes::Bytes>,
26 head_bytes: Vec<bytes::Bytes>,
80 payload: bytes!(1), in test_sample_builder()
239 data: bytes!(1), in test_sample_builder()
1239 payload: bytes!(0x01), in test_sample_builder_max_late()
1247 payload: bytes!(0x01), in test_sample_builder_max_late()
1255 payload: bytes!(0x01), in test_sample_builder_max_late()
1274 payload: bytes!(0x02), in test_sample_builder_max_late()
1282 payload: bytes!(0x02), in test_sample_builder_max_late()
[all …]
|
| /webrtc/data/src/message/ |
| H A D | message_test.rs | 5 use bytes::{Bytes, BytesMut};
9 let mut bytes = Bytes::from_static(&[ in test_message_unmarshal_open_success() localVariable
20 let actual = Message::unmarshal(&mut bytes).unwrap(); in test_message_unmarshal_open_success()
35 let mut bytes = Bytes::from_static(&[0x02]); in test_message_unmarshal_ack_success() localVariable
37 let actual = Message::unmarshal(&mut bytes)?; in test_message_unmarshal_ack_success()
47 let mut bytes = Bytes::from_static(&[0x01]); in test_message_unmarshal_invalid_message_type() localVariable
49 let result = Message::unmarshal(&mut bytes); in test_message_unmarshal_invalid_message_type()
82 let bytes = buf.freeze(); in test_message_marshal() localVariable
84 let actual = &bytes[..]; in test_message_marshal()
|
| H A D | message_type.rs | 64 use bytes::{Bytes, BytesMut};
68 let mut bytes = Bytes::from_static(&[0x03]); in test_message_type_unmarshal_open_success() localVariable
69 let msg_type = MessageType::unmarshal(&mut bytes)?; in test_message_type_unmarshal_open_success()
78 let mut bytes = Bytes::from_static(&[0x02]); in test_message_type_unmarshal_ack_success() localVariable
79 let msg_type = MessageType::unmarshal(&mut bytes)?; in test_message_type_unmarshal_ack_success()
87 let mut bytes = Bytes::from_static(&[0x01]); in test_message_type_unmarshal_invalid() localVariable
88 match MessageType::unmarshal(&mut bytes) { in test_message_type_unmarshal_invalid()
118 let bytes = buf.freeze(); in test_message_type_marshal() localVariable
121 assert_eq!(&bytes[..], &[0x02]); in test_message_type_marshal()
|
| H A D | message_channel_open.rs | 234 use bytes::{Bytes, BytesMut};
238 let mut bytes = Bytes::from_static(&[0x00]); in test_channel_type_unmarshal_success() localVariable
248 match ChannelType::unmarshal(&mut bytes) { in test_channel_type_unmarshal_invalid()
265 let mut bytes = Bytes::from_static(&[]); in test_channel_type_unmarshal_unexpected_end_of_buffer() localVariable
266 match ChannelType::unmarshal(&mut bytes) { in test_channel_type_unmarshal_unexpected_end_of_buffer()
302 let bytes = buf.freeze(); in test_channel_type_marshal() localVariable
303 assert_eq!(&bytes[..], &[0x00]); in test_channel_type_marshal()
333 let mut bytes = Bytes::from_static(&[ in test_channel_open_unmarshal_invalid_channel_type() localVariable
379 let mut bytes = Bytes::from_static(&[ in test_channel_open_unmarshal_unexpected_length_mismatch() localVariable
434 let bytes = buf.freeze(); in test_channel_open_marshal() localVariable
[all …]
|
| H A D | message_channel_ack.rs | 44 use bytes::{Bytes, BytesMut};
48 let mut bytes = Bytes::from_static(&[]); in test_channel_ack_unmarshal() localVariable
50 let channel_ack = DataChannelAck::unmarshal(&mut bytes)?; in test_channel_ack_unmarshal()
70 let bytes = buf.freeze(); in test_channel_ack_marshal() localVariable
73 assert_eq!(&bytes[..], &[]); in test_channel_ack_marshal()
|
| /webrtc/sctp/fuzz/fuzz_targets/ |
| H A D | param.rs | 5 use bytes::Bytes;
8 let bytes = Bytes::from(data.to_vec()); localVariable
9 build_param(&bytes);
|
| H A D | packet.rs | 5 use bytes::Bytes;
8 let bytes = Bytes::from(data.to_vec()); localVariable
9 Packet::unmarshal(&bytes);
|
| /webrtc/rtcp/src/extended_report/ |
| H A D | unknown.rs | 7 pub bytes: Bytes, field
37 XR_HEADER_LENGTH + self.bytes.len() in raw_size()
71 buf.put(self.bytes.clone()); in marshal_to()
94 let bytes = raw_packet.copy_to_bytes(block_length as usize); in unmarshal() localVariable
96 Ok(UnknownReportBlock { bytes }) in unmarshal()
|
| /webrtc/media/src/audio/ |
| H A D | buffer.rs | 29 bytes: &mut [u8], in to_bytes()
187 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
190 let chunks_ptr = bytes.as_ptr() as *const [u8; STRIDE]; in from_bytes()
191 let chunks_len = bytes.len() / STRIDE; in from_bytes()
210 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
213 let chunks_ptr = bytes.as_ptr() as *const [u8; STRIDE]; in from_bytes()
214 let chunks_len = bytes.len() / STRIDE; in from_bytes()
247 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
251 let chunks_len = bytes.len() / STRIDE; in from_bytes()
270 assert_eq!(bytes.len() % STRIDE, 0); in from_bytes()
[all …]
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_message.rs | 1 use bytes::Bytes;
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 128 let bytes = bytes::Bytes::from(buf); in main() localVariable
132 while stream.write(&bytes).await.is_ok() { in main()
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 15 use bytes::{Buf, Bytes};
109 label: config.label.bytes().collect(), in client()
110 protocol: config.protocol.bytes().collect(), in client()
567 let bytes = Bytes::copy_from_slice(buf); in poll_write() localVariable
569 Some(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
578 let bytes = Bytes::copy_from_slice(buf); in poll_write() localVariable
580 Some(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
586 let bytes = Bytes::copy_from_slice(buf); in poll_write() localVariable
589 .insert(Box::pin(async move { data_channel.write(&bytes).await })); in poll_write()
|
| /webrtc/rtp/src/extension/video_orientation_extension/ |
| H A D | mod.rs | 6 use bytes::BufMut;
71 B: bytes::Buf, in unmarshal()
|
| /webrtc/srtp/src/cipher/ |
| H A D | mod.rs | 4 use bytes::Bytes;
|
| /webrtc/util/src/marshal/ |
| H A D | mod.rs | 3 use bytes::{Buf, Bytes, BytesMut};
|
| /webrtc/sctp/fuzz/ |
| H A D | Cargo.toml | 13 bytes = "*"
|
| /webrtc/rtcp/ |
| H A D | Cargo.toml | 16 bytes = "1"
|
| /webrtc/sctp/src/ |
| H A D | fuzz_artifact_test.rs | 12 use bytes::Bytes;
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_cookie_ack.rs | 3 use bytes::{Bytes, BytesMut};
|
| H A D | chunk_shutdown_complete.rs | 3 use bytes::{Bytes, BytesMut};
|
| H A D | chunk_shutdown_ack.rs | 3 use bytes::{Bytes, BytesMut};
|
| /webrtc/sctp/src/param/ |
| H A D | param_forward_tsn_supported.rs | 3 use bytes::{Bytes, BytesMut};
|
| /webrtc/rtp/src/codecs/g7xx/ |
| H A D | mod.rs | 7 use bytes::Bytes;
|
| /webrtc/rtp/ |
| H A D | Cargo.toml | 16 bytes = "1"
|
| /webrtc/rtp/src/extension/transport_cc_extension/ |
| H A D | transport_cc_extension_test.rs | 3 use bytes::{Bytes, BytesMut};
|