Home
last modified time | relevance | path

Searched refs:u32 (Results 1 – 25 of 131) sorted by relevance

123456

/webrtc/sctp/src/
H A Dutil.rs14 pub(crate) const ISCSI_CRC: Crc<u32> = Crc::<u32>::new(&CRC_32_ISCSI);
17 pub(crate) fn generate_packet_checksum(raw: &Bytes) -> u32 { in generate_packet_checksum() argument
27 pub(crate) fn sna32lt(i1: u32, i2: u32) -> bool { in sna32lt() argument
32 pub(crate) fn sna32lte(i1: u32, i2: u32) -> bool { in sna32lte() argument
37 pub(crate) fn sna32gt(i1: u32, i2: u32) -> bool { in sna32gt() argument
42 pub(crate) fn sna32gte(i1: u32, i2: u32) -> bool { in sna32gte() argument
47 pub(crate) fn sna32eq(i1: u32, i2: u32) -> bool { in sna32eq() argument
86 const SERIAL_BITS: u32 = 32; in test_serial_number_arithmetic32bit()
87 const INTERVAL: u32 = ((1u64 << (SERIAL_BITS as u64)) / (DIV as u64)) as u32; in test_serial_number_arithmetic32bit()
89 const MAX_BACKWARD_DISTANCE: u32 = 1 << (SERIAL_BITS - 1); in test_serial_number_arithmetic32bit()
[all …]
/webrtc/srtp/src/context/
H A Dmod.rs25 ssrc: u32,
26 rollover_counter: u32,
36 ssrc: u32,
41 pub fn next_rollover_count(&self, sequence_number: u16) -> u32 { in next_rollover_count() argument
105 srtp_ssrc_states: HashMap<u32, SrtpSsrcState>,
106 srtcp_ssrc_states: HashMap<u32, SrtcpSsrcState>,
161 fn get_srtp_ssrc_state(&mut self, ssrc: u32) -> Option<&mut SrtpSsrcState> { in get_srtp_ssrc_state()
183 fn get_roc(&self, ssrc: u32) -> Option<u32> { in get_roc() argument
188 fn set_roc(&mut self, ssrc: u32, roc: u32) { in set_roc() argument
195 fn get_index(&self, ssrc: u32) -> Option<usize> { in get_index()
[all …]
/webrtc/sctp/src/queue/
H A Dpayload_queue.rs12 pub(crate) chunk_map: HashMap<u32, ChunkPayloadData>,
13 pub(crate) sorted: VecDeque<u32>,
14 pub(crate) dup_tsn: Vec<u32>,
27 pub(crate) fn can_push(&self, p: &ChunkPayloadData, cumulative_tsn: u32) -> bool { in can_push()
42 fn compare_tsn(a: u32, b: u32) -> std::cmp::Ordering { in push_no_check() argument
76 pub(crate) fn pop(&mut self, tsn: u32) -> Option<ChunkPayloadData> { in pop()
90 pub(crate) fn get(&self, tsn: u32) -> Option<&ChunkPayloadData> { in get()
93 pub(crate) fn get_mut(&mut self, tsn: u32) -> Option<&mut ChunkPayloadData> { in get_mut()
98 pub(crate) fn pop_duplicates(&mut self) -> Vec<u32> { in pop_duplicates() argument
142 pub(crate) fn mark_as_acked(&mut self, tsn: u32) -> usize { in mark_as_acked()
[all …]
/webrtc/interceptor/src/report/sender/
H A Dsender_stream.rs12 ssrc: u32,
16 last_rtp_time_rtp: u32,
39 * self.clock_rate) as u32, in generate_report()
57 ssrc: u32, in new() argument
58 clock_rate: u32, in new() argument
108 packets: u32,
109 octets: u32,
125 u32::MAX in count_octets()
129 pub fn packet_count(&self) -> u32 { in packet_count() argument
133 pub fn octet_count(&self) -> u32 { in octet_count() argument
[all …]
/webrtc/interceptor/src/stats/
H A Dmod.rs37 remote_packets_sent: u32,
40 remote_bytes_sent: u32,
85 pub(super) fn record_sender_report(&mut self, packets_sent: u32, bytes_sent: u32) { in record_sender_report() argument
114 remote_packets_sent: u32,
117 remote_bytes_sent: u32,
234 remote_total_lost: u32,
237 remote_jitter: u32,
286 rr_ext_seq_num: u32, in update_remote_inbound_packets_received() argument
287 rr_total_lost: u32, in update_remote_inbound_packets_received() argument
350 remote_total_lost: u32,
[all …]
/webrtc/rtcp/src/
H A Dutil.rs43 pub(crate) fn append_nbits_to_uint32(src: u32, n: u32, val: u32) -> u32 { in append_nbits_to_uint32() argument
55 pub(crate) fn get_24bits_from_bytes(b: &[u8]) -> u32 { in get_24bits_from_bytes() argument
56 ((b[0] as u32) << 16) + ((b[1] as u32) << 8) + (b[2] as u32) in get_24bits_from_bytes()
H A Dreception_report.rs22 pub ssrc: u32,
29 pub total_lost: u32,
33 pub last_sequence_number: u32,
37 pub jitter: u32,
41 pub last_sender_report: u32,
45 pub delay: u32,
59 fn destination_ssrc(&self) -> Vec<u32> { in destination_ssrc() argument
185 let total_lost = (t2 as u32) | (t1 as u32) << 8 | (t0 as u32) << 16; in unmarshal()
/webrtc/interceptor/src/report/receiver/
H A Dreceiver_stream.rs10 ssrc: u32,
11 receiver_ssrc: u32,
19 last_rtp_time_rtp: u32,
22 last_sender_report: u32,
24 total_lost: u32,
85 self.last_sender_report = (sr.ntp_time >> 16) as u32; in process_sender_report()
122 | (self.last_seq_num as u32), in generate_report()
137 jitter: self.jitter as u32, in generate_report()
157 ssrc: u32, in new() argument
158 clock_rate: u32, in new() argument
[all …]
/webrtc/srtp/src/cipher/
H A Dmod.rs45 roc: u32, in encrypt_rtp() argument
53 roc: u32, in decrypt_rtp() argument
57 fn encrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in encrypt_rtcp()
60 fn decrypt_rtcp(&mut self, payload: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes>; in decrypt_rtcp()
H A Dcipher_aead_aes_gcm.rs36 roc: u32, in encrypt_rtp() argument
63 roc: u32, in decrypt_rtp() argument
86 fn encrypt_rtcp(&mut self, decrypted: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes> { in encrypt_rtcp()
106 fn decrypt_rtcp(&mut self, encrypted: &[u8], srtcp_index: usize, ssrc: u32) -> Result<Bytes> { in decrypt_rtcp()
133 (val & !((RTCP_ENCRYPTION_FLAG as u32) << 24)) as usize in get_rtcp_index()
197 roc: u32, in rtp_initialization_vector() argument
218 pub(crate) fn rtcp_initialization_vector(&self, srtcp_index: usize, ssrc: u32) -> Vec<u8> { in rtcp_initialization_vector()
222 BigEndian::write_u32(&mut iv[8..], srtcp_index as u32); in rtcp_initialization_vector()
245 BigEndian::write_u32(&mut aad[8..], srtcp_index as u32); in rtcp_additional_authenticated_data()
/webrtc/stun/src/
H A Dfingerprint.rs24 pub const FINGERPRINT_XOR_VALUE: u32 = 0x5354554e;
33 pub fn fingerprint_value(b: &[u8]) -> u32 { in fingerprint_value() argument
34 let checksum = Crc::<u32>::new(&CRC_32_ISO_HDLC).checksum(b); in fingerprint_value()
43 m.length += (FINGERPRINT_SIZE + ATTRIBUTE_HEADER_SIZE) as u32; // increasing length in add_to()
59 let val = u32::from_be_bytes([b[0], b[1], b[2], b[3]]); in check()
/webrtc/rtp/src/packetizer/
H A Dmod.rs28 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>>; in packetize()
29 fn skip_samples(&mut self, skipped_samples: u32); in skip_samples() argument
62 pub(crate) ssrc: u32,
65 pub(crate) timestamp: u32,
66 pub(crate) clock_rate: u32,
87 ssrc: u32, in new_packetizer() argument
90 clock_rate: u32, in new_packetizer() argument
98 timestamp: rand::random::<u32>(), in new_packetizer()
110 fn packetize(&mut self, payload: &Bytes, samples: u32) -> Result<Vec<Packet>> { in packetize()
154 fn skip_samples(&mut self, skipped_samples: u32) { in skip_samples() argument
/webrtc/media/src/io/ogg_writer/
H A Dmod.rs16 sample_rate: u32,
18 serial: u32,
19 page_index: u32,
20 checksum_table: [u32; 256],
22 previous_timestamp: u32,
29 pub fn new(writer: W, sample_rate: u32, channel_count: u8) -> Result<Self> { in new() argument
34 serial: rand::random::<u32>(), in new()
125 page_index: u32, in write_page() argument
/webrtc/media/src/io/ogg_reader/
H A Dmod.rs25 checksum_table: [u32; 256],
37 pub sample_rate: u32,
50 serial: u32,
51 index: u32,
182 fn update_checksum(&self, v: u8, sum: u32) -> u32 { in update_checksum() argument
187 pub(crate) fn generate_checksum_table() -> [u32; 256] { in generate_checksum_table()
189 const POLY: u32 = 0x04c11db7;
192 let mut r = (i as u32) << 24;
/webrtc/ice/src/stats/
H A Dmod.rs27 pub packets_sent: u32,
30 pub packets_received: u32,
92 pub circuit_breaker_trigger_count: u32,
160 pub priority: u32,
/webrtc/srtp/src/
H A Dstream.rs15 ssrc: u32,
16 tx: mpsc::Sender<u32>,
23 pub fn new(ssrc: u32, tx: mpsc::Sender<u32>, is_rtp: bool) -> Self { in new() argument
41 pub fn get_ssrc(&self) -> u32 { in get_ssrc() argument
H A Derror.rs52 SsrcMissingFromSrtp(u32),
54 SrtpSsrcDuplicated(u32, u16),
56 SrtcpSsrcDuplicated(u32, usize),
58 SsrcMissingFromSrtcp(u32),
60 StreamWithSsrcExists(u32),
/webrtc/rtcp/src/payload_feedbacks/receiver_estimated_maximum_bitrate/
H A Dmod.rs18 pub sender_ssrc: u32,
24 pub ssrcs: Vec<u32>,
68 fn destination_ssrc(&self) -> Vec<u32> { in destination_ssrc() argument
159 let mantissa = bitrate.floor() as u32; in marshal_to()
194 const MANTISSA_MAX: u32 = 0x7FFFFF; in unmarshal()
252 let mut mantissa = ((b17 & 3) as u32) << 16 | (b18 as u32) << 8 | b19 as u32; in unmarshal()
263 let bitrate = f32::from_bits(((exp as u32) << 23) | (mantissa & MANTISSA_MAX)); in unmarshal()
/webrtc/mdns/src/message/resource/
H A Dsoa.rs11 pub serial: u32,
12 pub refresh: u32,
13 pub retry: u32,
14 pub expire: u32,
19 pub min_ttl: u32,
/webrtc/rtcp/src/extended_report/
H A Dssr.rs40 pub ssrc: u32,
43 pub lost_packets: u32,
44 pub dup_packets: u32,
45 pub min_jitter: u32,
46 pub max_jitter: u32,
47 pub mean_jitter: u32,
48 pub dev_jitter: u32,
120 fn destination_ssrc(&self) -> Vec<u32> { in destination_ssrc() argument
/webrtc/mdns/src/message/
H A Dpacker.rs44 pub(crate) fn pack_uint32(mut msg: Vec<u8>, field: u32) -> Vec<u8> { in pack_uint32()
49 pub(crate) fn unpack_uint32(msg: &[u8], off: usize) -> Result<(u32, usize)> { in unpack_uint32() argument
53 let v = (msg[off] as u32) << 24 in unpack_uint32()
54 | (msg[off + 1] as u32) << 16 in unpack_uint32()
55 | (msg[off + 2] as u32) << 8 in unpack_uint32()
56 | (msg[off + 3] as u32); in unpack_uint32()
/webrtc/media/src/io/h264_writer/
H A Dmod.rs11 const NALU_TTYPE_STAP_A: u32 = 24;
12 const NALU_TTYPE_SPS: u32 = 7;
13 const NALU_TYPE_BITMASK: u32 = 0x1F;
19 let word = u32::from_be_bytes([data[0], data[1], data[2], data[3]]); in is_key_frame()
/webrtc/srtp/src/session/
H A Dmod.rs33 streams_map: Arc<Mutex<HashMap<u32, Arc<Stream>>>>,
35 close_stream_tx: mpsc::Sender<u32>,
124 async fn close_stream(streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, ssrc: u32) { in close_stream() argument
132 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in incoming() argument
133 close_stream_tx: &mpsc::Sender<u32>, in incoming() argument
185 streams_map: &Arc<Mutex<HashMap<u32, Arc<Stream>>>>, in get_or_create_stream() argument
186 close_stream_tx: mpsc::Sender<u32>, in get_or_create_stream() argument
188 ssrc: u32, in get_or_create_stream() argument
203 pub async fn open(&self, ssrc: u32) -> Arc<Stream> { in open()
266 fn destination_ssrc(pkts: &[Box<dyn rtcp::packet::Packet + Send + Sync>]) -> Vec<u32> { in destination_ssrc() argument
/webrtc/interceptor/src/twcc/
H A Dmod.rs15 sequence_number: u32,
26 cycles: u32,
29 sender_ssrc: u32,
30 media_ssrc: u32,
37 pub fn new(sender_ssrc: u32) -> Self { in new()
45 pub fn record(&mut self, media_ssrc: u32, sequence_number: u16, arrival_time: i64) { in record() argument
51 sequence_number: self.cycles | sequence_number as u32, in record()
108 fn new(sender_ssrc: u32, media_ssrc: u32, fb_pkt_count: u8) -> Self { in new() argument
129 self.rtcp.reference_time = self.ref_timestamp64ms as u32; in get_rtcp()
/webrtc/media/src/io/ivf_reader/
H A Dmod.rs25 pub timebase_denominator: u32, // 16-19
26 pub timebase_numerator: u32, // 20-23
27 pub num_frames: u32, // 24-27
28 pub unused: u32, // 28-31
35 pub frame_size: u32, // 0-3

123456