| /webrtc/dtls/src/signature_hash_algorithm/ |
| H A D | signature_hash_algorithm_test.rs | 9 SignatureScheme::EcdsaWithP256AndSha256 as u16, in test_parse_signature_schemes()
10 SignatureScheme::EcdsaWithP384AndSha384 as u16, in test_parse_signature_schemes()
11 SignatureScheme::EcdsaWithP521AndSha512 as u16, in test_parse_signature_schemes()
12 SignatureScheme::Pkcs1WithSha256 as u16, in test_parse_signature_schemes()
13 SignatureScheme::Pkcs1WithSha384 as u16, in test_parse_signature_schemes()
14 SignatureScheme::Pkcs1WithSha512 as u16, in test_parse_signature_schemes()
48 SignatureScheme::EcdsaWithP256AndSha256 as u16, // Valid in test_parse_signature_schemes()
58 SignatureScheme::EcdsaWithP256AndSha256 as u16, // Valid in test_parse_signature_schemes()
68 SignatureScheme::EcdsaWithP256AndSha256 as u16, // Valid in test_parse_signature_schemes()
100 SignatureScheme::EcdsaWithSha1 as u16, // Insecure in test_parse_signature_schemes()
[all …]
|
| /webrtc/interceptor/src/twcc/ |
| H A D | twcc_test.rs | 14 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
97 c.add(SymbolTypeTcc::PacketReceivedSmallDelta as u16); in test_chunk_add()
99 c.add(SymbolTypeTcc::PacketReceivedSmallDelta as u16); in test_chunk_add()
101 c.add(SymbolTypeTcc::PacketReceivedSmallDelta as u16); in test_chunk_add()
131 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
133 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
135 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
137 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
139 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
141 c.add(SymbolTypeTcc::PacketNotReceived as u16); in test_chunk_add()
[all …]
|
| H A D | mod.rs | 27 last_sequence_number: u16,
96 base_sequence_number: u16,
99 next_sequence_number: u16,
100 sequence_number_count: u16,
120 fn set_base(&mut self, sequence_number: u16, time_us: i64) { in set_base() argument
168 if !self.last_chunk.can_add(recv_delta as u16) { in add_received()
171 self.last_chunk.add(recv_delta as u16); in add_received()
191 deltas: Vec<u16>,
195 fn can_add(&self, delta: u16) -> bool { in can_add()
214 fn add(&mut self, delta: u16) { in add() argument
[all …]
|
| /webrtc/rtp/src/codecs/h265/ |
| H A D | mod.rs | 32 H265NALUHeader(((high_byte as u16) << 8) | low_byte as u16) in new()
105 donl: Option<u16>,
144 let donl = ((payload[0] as u16) << 8) | (payload[1] as u16); in depacketize()
191 donl: Option<u16>,
192 nal_unit_size: u16,
232 nal_unit_size: u16,
307 let donl = ((payload[0] as u16) << 8) | (payload[1] as u16); in depacketize()
344 unit.nal_unit_size = ((payload[0] as u16) << 8) | (payload[1] as u16); in depacketize()
437 donl: Option<u16>,
474 let donl = ((payload[0] as u16) << 8) | (payload[1] as u16); in depacketize()
[all …]
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | generator_stream.rs | 10 size: u16,
11 end: u16,
13 last_consecutive: u16,
27 fn add(&mut self, seq: u16) { in add() argument
67 fn get(&self, seq: u16) -> bool { in get()
80 fn missing_seq_numbers(&self, skip_last_n: u16) -> Vec<u16> { in missing_seq_numbers() argument
140 pub(super) fn missing_seq_numbers(&self, skip_last_n: u16) -> Vec<u16> { in missing_seq_numbers() argument
172 let tests: Vec<u16> = vec![ in test_generator_stream()
179 let all = |min: u16, max: u16| -> Vec<u16> { in test_generator_stream()
190 let join = |parts: &[&[u16]]| -> Vec<u16> { in test_generator_stream()
[all …]
|
| /webrtc/ice/src/ |
| H A D | udp_network.rs | 8 port_min: u16,
9 port_max: u16,
13 pub fn new(port_min: u16, port_max: u16) -> Result<Self, Error> { in new() argument
20 pub fn port_min(&self) -> u16 { in port_min() argument
24 pub fn port_max(&self) -> u16 { in port_max() argument
28 pub fn set_ports(&mut self, port_min: u16, port_max: u16) -> Result<(), Error> { in set_ports() argument
|
| /webrtc/rtcp/src/ |
| H A D | util.rs | 27 src: u16, in set_nbits_of_uint16() argument
28 size: u16, in set_nbits_of_uint16() argument
29 start_index: u16, in set_nbits_of_uint16() argument
30 mut val: u16, in set_nbits_of_uint16() argument
31 ) -> Result<u16> { in set_nbits_of_uint16() argument
48 pub(crate) fn get_nbits_from_byte(b: u8, begin: u16, n: u16) -> u16 { in get_nbits_from_byte() argument
51 (b & mask) as u16 >> end_shift in get_nbits_from_byte()
|
| /webrtc/sctp/src/ |
| H A D | util.rs | 52 pub(crate) fn sna16lt(i1: u16, i2: u16) -> bool { in sna16lt() argument
57 pub(crate) fn sna16lte(i1: u16, i2: u16) -> bool { in sna16lte() argument
62 pub(crate) fn sna16gt(i1: u16, i2: u16) -> bool { in sna16gt() argument
67 pub(crate) fn sna16gte(i1: u16, i2: u16) -> bool { in sna16gte() argument
72 pub(crate) fn sna16eq(i1: u16, i2: u16) -> bool { in sna16eq() argument
166 const SERIAL_BITS: u16 = 16; in test_serial_number_arithmetic16bit()
167 const INTERVAL: u16 = ((1u64 << (SERIAL_BITS as u64)) / (DIV as u64)) as u16; in test_serial_number_arithmetic16bit()
168 const MAX_FORWARD_DISTANCE: u16 = 1 << ((SERIAL_BITS - 1) - 1); in test_serial_number_arithmetic16bit()
169 const MAX_BACKWARD_DISTANCE: u16 = 1 << (SERIAL_BITS - 1); in test_serial_number_arithmetic16bit()
171 for i in 0..DIV as u16 { in test_serial_number_arithmetic16bit()
|
| /webrtc/mdns/src/message/ |
| H A D | header.rs | 6 pub id: u16,
34 pub fn pack(&self) -> (u16, u16) { in pack() argument
36 let mut bits = self.op_code << 11 | self.rcode as u16; in pack()
101 pub id: u16,
102 pub bits: u16,
103 pub questions: u16,
104 pub answers: u16,
105 pub authorities: u16,
106 pub additionals: u16,
110 pub(crate) fn count(&self, sec: Section) -> u16 { in count() argument
|
| H A D | mod.rs | 50 impl From<u16> for DnsType {
51 fn from(v: u16) -> Self { in from()
103 pack_uint16(msg, *self as u16) in pack()
119 pub struct DnsClass(pub u16);
162 pub type OpCode = u16;
228 const HEADER_BIT_AA: u16 = 1 << 10; // authoritative
229 const HEADER_BIT_TC: u16 = 1 << 9; // truncated
291 if self.questions.len() > u16::MAX as usize { in append_pack()
294 if self.answers.len() > u16::MAX as usize { in append_pack()
306 let questions = self.questions.len() as u16; in append_pack()
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | binding.rs | 12 const MIN_CHANNEL_NUMBER: u16 = 0x4000;
13 const MAX_CHANNEL_NUMBER: u16 = 0x7fff;
26 pub(crate) number: u16,
54 chan_map: HashMap<u16, String>,
56 next: u16,
68 pub(crate) fn assign_channel_number(&mut self) -> u16 { in assign_channel_number() argument
99 pub(crate) fn find_by_number(&self, number: u16) -> Option<&Binding> { in find_by_number()
107 pub(crate) fn get_by_number(&mut self, number: u16) -> Option<&mut Binding> { in get_by_number()
124 pub(crate) fn delete_by_number(&mut self, number: u16) -> bool { in delete_by_number()
|
| /webrtc/rtp/src/ |
| H A D | sequence.rs | 7 fn next_sequence_number(&self) -> u16; in next_sequence_number() argument
22 sequence_number: Arc::new(AtomicU16::new(rand::random::<u16>())), in new_random_sequencer()
30 pub fn new_fixed_sequencer(s: u16) -> impl Sequencer { in new_fixed_sequencer()
31 let sequence_number = if s == 0 { u16::MAX } else { s - 1 }; in new_fixed_sequencer()
53 fn next_sequence_number(&self) -> u16 { in next_sequence_number() argument
54 if self.0.sequence_number.load(Ordering::SeqCst) == u16::MAX { in next_sequence_number()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_message_server_key_exchange.rs | 39 writer.write_u16::<BigEndian>(self.identity_hint.len() as u16)?; in marshal()
45 writer.write_u16::<BigEndian>(self.named_curve as u16)?; in marshal()
53 writer.write_u16::<BigEndian>(self.signature.len() as u16)?; in marshal()
64 let psk_length = ((data[0] as u16) << 8) | data[1] as u16; in unmarshal()
85 let named_curve = (((data[1] as u16) << 8) | data[2] as u16).into(); in unmarshal()
112 let signature_length = (((data[offset] as u16) << 8) | data[offset + 1] as u16) as usize; in unmarshal()
|
| /webrtc/stun/src/ |
| H A D | message.rs | 473 pub struct Method(u16);
547 const METHOD_BSHIFT: u16 = 1;
548 const METHOD_DSHIFT: u16 = 2;
550 const FIRST_BIT: u16 = 0x1;
551 const SECOND_BIT: u16 = 0x2;
553 const C0BIT: u16 = FIRST_BIT;
554 const C1BIT: u16 = SECOND_BIT;
556 const CLASS_C0SHIFT: u16 = 4;
557 const CLASS_C1SHIFT: u16 = 7;
574 pub fn value(&self) -> u16 { in value() argument
[all …]
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_cc/ |
| H A D | mod.rs | 43 #[repr(u16)]
52 #[repr(u16)]
68 #[repr(u16)]
77 fn from(val: u16) -> Self { in from()
86 fn from(val: u16) -> Self { in from()
94 impl From<u16> for SymbolTypeTcc {
95 fn from(val: u16) -> Self { in from()
146 pub run_length: u16,
195 let run_length = ((get_nbits_from_byte(b0, 3, 5) as usize) << 8) as u16 + (b1 as u16); in unmarshal()
436 pub base_sequence_number: u16,
[all …]
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_init.rs | 12 pub max_packet_life_time: Option<u16>,
17 pub max_retransmits: Option<u16>,
28 pub negotiated: Option<u16>,
|
| H A D | data_channel_parameters.rs | 9 pub max_packet_life_time: u16,
10 pub max_retransmits: u16,
11 pub negotiated: Option<u16>,
|
| /webrtc/dtls/src/extension/ |
| H A D | extension_use_srtp.rs | 18 impl From<u16> for SrtpProtectionProfile {
19 fn from(val: u16) -> Self { in from()
50 2 + /* MKI Length */ 1 + 2 * self.protection_profiles.len() as u16, 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()
|
| /webrtc/turn/src/relay/ |
| H A D | relay_range.rs | 14 pub min_port: u16,
17 pub max_port: u16,
20 pub max_retries: u16,
49 requested_port: u16, in allocate_conn() argument
69 let port = self.min_port + rand::random::<u16>() % (self.max_port - self.min_port + 1); in allocate_conn()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_sequence_location.rs | 14 i: u16,
34 pub(crate) head: u16,
37 pub(crate) tail: u16,
53 pub(crate) fn count(&self) -> u16 { in count() argument
57 pub(crate) fn compare(&self, pos: u16) -> Comparison { in compare()
|
| /webrtc/turn/src/proto/ |
| H A D | chandata.rs | 63 let num = u16::from_be_bytes([buf[0], buf[1]]); in decode()
68 let l = u16::from_be_bytes([ in decode()
90 .copy_from_slice(&(self.data.len() as u16).to_be_bytes()); in write_header()
99 if u16::from_be_bytes([ in is_channel_data()
102 ]) > buf[CHANNEL_DATA_HEADER_SIZE..].len() as u16 in is_channel_data()
108 let num = ChannelNumber(u16::from_be_bytes([buf[0], buf[1]])); in is_channel_data()
|
| H A D | channum.rs | 16 pub const MIN_CHANNEL_NUMBER: u16 = 0x4000;
17 pub const MAX_CHANNEL_NUMBER: u16 = 0x7FFF;
26 pub struct ChannelNumber(pub u16);
53 self.0 = u16::from_be_bytes([v[0], v[1]]); in get_from()
|
| /webrtc/rtcp/src/extended_report/ |
| H A D | vm.rs | 3 const VM_REPORT_BLOCK_LENGTH: u16 = 4 + 4 + 2 * 4 + 10 + 2 * 3;
36 pub burst_duration: u16,
37 pub gap_duration: u16,
38 pub round_trip_delay: u16,
39 pub end_system_delay: u16,
50 pub jb_nominal: u16,
51 pub jb_maximum: u16,
52 pub jb_abs_max: u16,
66 block_length: (self.raw_size() / 4 - 1) as u16, in xr_header()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 13 type PacketBitmap = u16;
20 pub packet_id: u16,
26 packet_id: u16,
32 type Item = u16;
58 pub fn new(seq: u16) -> Self { in new()
66 pub fn packet_list(&self) -> Vec<u16> { in packet_list() argument
72 F: Fn(u16) -> bool, in range()
84 type Item = u16;
132 length: ((self.marshal_size() / 4) - 1) as u16, in header()
246 pub fn nack_pairs_from_sequence_numbers(seq_nos: &[u16]) -> Vec<NackPair> { in nack_pairs_from_sequence_numbers()
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 11 size: u16,
12 last_added: u16,
50 fn get(&self, seq: u16) -> Option<&rtp::packet::Packet> { in get()
82 pub(super) async fn get(&self, seq: u16) -> Option<rtp::packet::Packet> { in get()
105 let tests: Vec<u16> = vec![ in test_responder_stream()
112 let add = |sb: &mut ResponderStreamInternal, nums: &[u16]| { in test_responder_stream()
125 let assert_get = |sb: &ResponderStreamInternal, nums: &[u16]| { in test_responder_stream()
140 let assert_not_get = |sb: &ResponderStreamInternal, nums: &[u16]| { in test_responder_stream()
|