| /webrtc/util/src/fixed_big_int/ |
| H A D | mod.rs | 9 n: usize, 25 pub(crate) fn new(n: usize) -> Self { in new() 43 pub(crate) fn lsh(&mut self, n: usize) { in lsh() argument 56 self.bits[(i - n_chunk) as usize] << n_n in lsh() 62 self.bits[(i - n_chunk - 1) as usize] >> (64 - n_n) in lsh() 66 self.bits[i as usize] = if n >= 64 { in lsh() 69 (self.bits[i as usize] << n) | carry in lsh() 78 pub(crate) fn bit(&self, i: usize) -> usize { in bit() argument 84 usize::from(self.bits[chunk] & (1 << pos) != 0) in bit() 88 pub(crate) fn set_bit(&mut self, i: usize) { in set_bit() argument
|
| /webrtc/mdns/src/message/resource/ |
| H A D | mod.rs | 66 compression_off: usize, in pack() argument 82 pub fn unpack(&mut self, msg: &[u8], mut off: usize) -> Result<usize> { in unpack() argument 90 pub(crate) fn skip(msg: &[u8], off: usize) -> Result<usize> { in skip() argument 96 new_off += length as usize; in skip() 149 compression_off: usize, in pack() argument 160 pub fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument 179 pub fn fix_len(&mut self, msg: &mut [u8], len_off: usize, pre_len: usize) -> Result<()> { in fix_len() argument 244 compression_off: usize, in pack() argument 247 fn unpack(&mut self, msg: &[u8], off: usize, length: usize) -> Result<usize>; in unpack() argument 253 mut off: usize, in unpack_resource_body() argument [all …]
|
| H A D | opt.rs | 50 _compression: &mut Option<HashMap<String, usize>>, in pack() argument 51 _compression_off: usize, in pack() argument 61 fn unpack(&mut self, msg: &[u8], mut off: usize, length: usize) -> Result<usize> { in unpack() argument 73 data: vec![0; l as usize], in unpack() 75 if off + l as usize > msg.len() { in unpack() 78 opt.data.copy_from_slice(&msg[off..off + l as usize]); in unpack() 79 off += l as usize; in unpack()
|
| H A D | a.rs | 25 _compression: &mut Option<HashMap<String, usize>>, in pack() argument 26 _compression_off: usize, in pack() argument 31 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument
|
| H A D | ptr.rs | 26 compression: &mut Option<HashMap<String, usize>>, in pack() argument 27 compression_off: usize, in pack() argument 32 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument
|
| H A D | aaaa.rs | 25 _compression: &mut Option<HashMap<String, usize>>, in pack() argument 26 _compression_off: usize, in pack() argument 31 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument
|
| H A D | cname.rs | 25 compression: &mut Option<HashMap<String, usize>>, in pack() argument 26 compression_off: usize, in pack() argument 31 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument
|
| H A D | ns.rs | 26 compression: &mut Option<HashMap<String, usize>>, in pack() argument 27 compression_off: usize, in pack() argument 32 fn unpack(&mut self, msg: &[u8], off: usize, _txt_length: usize) -> Result<usize> { in unpack() argument
|
| H A D | mx.rs | 32 compression: &mut Option<HashMap<String, usize>>, in pack() argument 33 compression_off: usize, in pack() argument 40 fn unpack(&mut self, msg: &[u8], off: usize, _length: usize) -> Result<usize> { in unpack() argument
|
| /webrtc/mdns/src/message/ |
| H A D | packer.rs | 10 pub(crate) fn unpack_bytes(msg: &[u8], off: usize, field: &mut [u8]) -> Result<usize> { in unpack_bytes() argument 25 pub(crate) fn unpack_uint16(msg: &[u8], off: usize) -> Result<(u16, usize)> { in unpack_uint16() argument 36 pub(crate) fn skip_uint16(msg: &[u8], off: usize) -> Result<usize> { in skip_uint16() argument 49 pub(crate) fn unpack_uint32(msg: &[u8], off: usize) -> Result<(u32, usize)> { in unpack_uint32() argument 60 pub(crate) fn skip_uint32(msg: &[u8], off: usize) -> Result<usize> { in skip_uint32() argument 78 pub(crate) fn unpack_str(msg: &[u8], off: usize) -> Result<(String, usize)> { in unpack_str() argument 83 let end_off = begin_off + msg[off] as usize; in unpack_str()
|
| H A D | name.rs | 6 const NAME_LEN: usize = 255; 43 compression: &mut Option<HashMap<String, usize>>, in pack() argument 44 compression_off: usize, in pack() argument 111 pub fn unpack(&mut self, msg: &[u8], off: usize) -> Result<usize> { in unpack() argument 118 off: usize, in unpack_compressed() argument 120 ) -> Result<usize> { in unpack_compressed() argument 148 let end_off = curr_off + c as usize; in unpack_compressed() 174 curr_off = ((c ^ 0xC0) as usize) << 8 | (c1 as usize); in unpack_compressed() 195 pub(crate) fn skip(msg: &[u8], off: usize) -> Result<usize> { in skip() argument 214 new_off += c as usize; in skip()
|
| /webrtc/util/src/buffer/ |
| H A D | mod.rs | 10 const MIN_SIZE: usize = 2048; 11 const CUTOFF_SIZE: usize = 128 * 1024; 19 head: usize, 20 tail: usize, 25 count: usize, 26 limit_count: usize, 27 limit_size: usize, 88 fn size(&self) -> usize { in size() argument 93 size as usize in size() 104 pub fn new(limit_count: usize, limit_size: usize) -> Self { in new() argument [all …]
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | mod.rs | 13 pub(crate) const SR_HEADER_LENGTH: usize = 24; 14 pub(crate) const SR_SSRC_OFFSET: usize = HEADER_LENGTH; 17 pub(crate) const SR_NTP_OFFSET: usize = SR_SSRC_OFFSET + SSRC_LENGTH; 18 pub(crate) const NTP_TIME_LENGTH: usize = 8; 19 pub(crate) const SR_RTP_OFFSET: usize = SR_NTP_OFFSET + NTP_TIME_LENGTH; 20 pub(crate) const RTP_TIME_LENGTH: usize = 4; 22 pub(crate) const SR_PACKET_COUNT_LENGTH: usize = 4; 24 pub(crate) const SR_OCTET_COUNT_LENGTH: usize = 4; 101 fn raw_size(&self) -> usize { in raw_size() argument 127 fn marshal_size(&self) -> usize { in marshal_size() argument [all …]
|
| /webrtc/util/src/conn/ |
| H A D | conn_bridge.rs | 17 id: usize, 28 async fn recv(&self, b: &mut [u8]) -> Result<usize> { in recv() argument 39 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() argument 44 async fn send(&self, b: &[u8]) -> Result<usize> { in send() argument 116 pub async fn len(&self, id: usize) -> usize { in len() argument 121 pub async fn push(&self, b: &[u8], id: usize) -> Result<usize> { in push() argument 155 pub async fn reorder(&self, id: usize) -> bool { in reorder() 162 pub async fn drop_offset(&self, id: usize, offset: usize, n: usize) { in drop_offset() argument 169 pub fn drop_next_nwrites(&self, id: usize, n: usize) { in drop_next_nwrites() argument 175 pub fn reorder_next_nwrites(&self, id: usize, n: usize) { in reorder_next_nwrites() argument [all …]
|
| /webrtc/media/src/audio/buffer/ |
| H A D | info.rs | 7 channels: usize, 8 frames: usize, 13 pub fn new(channels: usize, frames: usize) -> Self { in new() argument 22 pub fn channels(&self) -> usize { in channels() argument 27 pub fn set_channels(&mut self, channels: usize) { in set_channels() argument 32 pub fn frames(&self) -> usize { in frames() argument 37 pub fn set_frames(&mut self, frames: usize) { in set_frames() argument 41 pub fn samples(&self) -> usize { in samples() argument
|
| H A D | layout.rs | 5 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize; in index_of() argument 15 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of() argument 27 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of() argument 34 pub(crate) fn deinterleaved<T>(input: &[T], output: &mut [T], channels: usize) in deinterleaved() 43 pub(crate) fn deinterleaved_by<T, U, F>(input: &[T], output: &mut [U], channels: usize, f: F) in deinterleaved_by() argument 64 pub(crate) fn interleaved<T>(input: &[T], output: &mut [T], channels: usize) in interleaved() 73 pub(crate) fn interleaved_by<T, U, F>(input: &[T], output: &mut [U], channels: usize, f: F) in interleaved_by() argument
|
| /webrtc/srtp/src/ |
| H A D | error.rs | 46 SrtpMasterKeyLength(usize, usize), 48 SrtpSaltLength(usize, usize), 56 SrtcpSsrcDuplicated(u32, usize), 66 SrtpTooSmall(usize, usize), 68 SrtcpTooSmall(usize, usize),
|
| H A D | protection_profile.rs | 11 pub(crate) fn key_len(&self) -> usize { in key_len() argument 17 pub(crate) fn salt_len(&self) -> usize { in salt_len() argument 24 pub(crate) fn auth_tag_len(&self) -> usize { in auth_tag_len() argument 31 pub(crate) fn auth_key_len(&self) -> usize { in auth_key_len() argument
|
| /webrtc/util/src/replay_detector/ |
| H A D | mod.rs | 19 window_size: usize, 28 pub fn new(window_size: usize, max_seq: u64) -> Self { in new() argument 53 if self.mask.bit((self.latest_seq - seq) as usize) != 0 { in check() 71 self.mask.lsh((self.seq - self.latest_seq) as usize); in accept() 75 self.mask.set_bit(diff as usize); in accept() 84 window_size: usize, 92 pub fn new(window_size: usize, max_seq: u64) -> Self { in new() argument 134 if diff >= 0 && self.mask.bit(diff as usize) != 0 { in check() 161 self.mask.lsh((-diff) as usize); in accept() 165 .set_bit((self.latest_seq as isize - self.seq as isize) as usize); in accept()
|
| /webrtc/interceptor/src/ |
| H A D | lib.rs | 28 pub type Attributes = HashMap<usize, usize>; 82 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize>; in write() argument 89 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>) 98 async fn write(&self, pkt: &rtp::packet::Packet, attributes: &Attributes) -> Result<usize> { in write() argument 107 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() argument 114 ) -> Pin<Box<dyn Future<Output = Result<(usize, Attributes)>> + Send + Sync>>) 136 ) -> Result<usize>; in write() argument 143 ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + Sync>>) 157 ) -> Result<usize> { in write() argument 166 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() argument [all …]
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | mod.rs | 14 const VP9HEADER_SIZE: usize = 3; 16 const MAX_VP9REF_PICS: usize = 3; 269 mut payload_index: usize, in parse_picture_id() argument 270 ) -> Result<usize> { in parse_picture_id() argument 294 mut payload_index: usize, in parse_layer_info() argument 295 ) -> Result<usize> { in parse_layer_info() argument 314 mut payload_index: usize, in parse_layer_info_common() argument 315 ) -> Result<usize> { in parse_layer_info_common() argument 345 mut payload_index: usize, in parse_layer_info_non_flexible_mode() argument 346 ) -> Result<usize> { in parse_layer_info_non_flexible_mode() argument [all …]
|
| /webrtc/rtcp/src/ |
| H A D | reception_report.rs | 8 pub(crate) const RECEPTION_REPORT_LENGTH: usize = 24; 9 pub(crate) const FRACTION_LOST_OFFSET: usize = 4; 10 pub(crate) const TOTAL_LOST_OFFSET: usize = 5; 11 pub(crate) const LAST_SEQ_OFFSET: usize = 8; 12 pub(crate) const JITTER_OFFSET: usize = 12; 13 pub(crate) const LAST_SR_OFFSET: usize = 16; 14 pub(crate) const DELAY_OFFSET: usize = 20; 63 fn raw_size(&self) -> usize { in raw_size() argument 84 fn marshal_size(&self) -> usize { in marshal_size() argument 93 fn marshal_to(&self, mut buf: &mut [u8]) -> Result<usize, util::Error> { in marshal_to() argument
|
| /webrtc/util/src/marshal/ |
| H A D | exact_size_buf.rs | 13 fn len(&self) -> usize; in len() argument 27 fn len(&self) -> usize { in len() argument 39 fn len(&self) -> usize { in len() argument 51 fn len(&self) -> usize { in len() argument 66 fn len(&self) -> usize { in len() argument 85 fn len(&self) -> usize { in len() argument
|
| /webrtc/rtp/src/ |
| H A D | header.rs | 6 pub const HEADER_LENGTH: usize = 4; 20 pub const SEQ_NUM_OFFSET: usize = 2; 21 pub const SEQ_NUM_LENGTH: usize = 2; 22 pub const TIMESTAMP_OFFSET: usize = 4; 23 pub const TIMESTAMP_LENGTH: usize = 4; 24 pub const SSRC_OFFSET: usize = 8; 25 pub const SSRC_LENGTH: usize = 4; 26 pub const CSRC_OFFSET: usize = 12; 27 pub const CSRC_LENGTH: usize = 4; 203 fn marshal_size(&self) -> usize { in marshal_size() argument [all …]
|
| /webrtc/rtcp/src/source_description/ |
| H A D | mod.rs | 13 const SDES_SOURCE_LEN: usize = 4; 14 const SDES_TYPE_LEN: usize = 1; 15 const SDES_TYPE_OFFSET: usize = 0; 16 const SDES_OCTET_COUNT_LEN: usize = 1; 17 const SDES_OCTET_COUNT_OFFSET: usize = 1; 19 const SDES_TEXT_OFFSET: usize = 2; 80 fn raw_size(&self) -> usize { in raw_size() argument 91 fn marshal_size(&self) -> usize { in marshal_size() argument 185 fn marshal_size(&self) -> usize { in marshal_size() argument 306 fn raw_size(&self) -> usize { in raw_size() argument [all …]
|