Home
last modified time | relevance | path

Searched refs:buffer (Results 1 – 25 of 36) sorted by relevance

12

/webrtc/util/src/buffer/
H A Dbuffer_test.rs10 let buffer = Buffer::new(0, 0); in test_buffer() localVariable
48 buffer.close().await; in test_buffer()
68 let mut b = buffer.buffer.lock().await; in test_wraparound()
91 let mut b = buffer.buffer.lock().await; in test_wraparound()
107 let b = buffer.buffer.lock().await; in test_wraparound()
132 let buffer2 = buffer.clone(); in test_buffer_async()
158 buffer.close().await; in test_buffer_async()
218 buffer.close().await; in test_buffer_limit_count()
286 buffer.close().await; in test_buffer_limit_size()
351 buffer.close().await; in test_buffer_misc()
[all …]
H A Dmod.rs99 buffer: Arc<Mutex<BufferInternal>>, field
106 buffer: Arc::new(Mutex::new(BufferInternal { in new()
131 let mut b = self.buffer.lock().await; in write()
194 let mut b = self.buffer.lock().await; in read()
270 let mut b = self.buffer.lock().await; in close()
281 let b = self.buffer.lock().await; in is_closed()
288 let b = self.buffer.lock().await; in count()
297 let mut b = self.buffer.lock().await; in set_limit_count()
304 let b = self.buffer.lock().await; in size()
317 let mut b = self.buffer.lock().await; in set_limit_size()
/webrtc/ice/src/udp_mux/
H A Dsocket_addr_ext.rs30 if buffer.len() < MAX_ADDR_SIZE { in encode()
40 buffer[0] = marker; in encode()
53 buffer[0] = marker; in encode()
67 match buffer[0] { in decode()
73 let ip_parts = &buffer[1..5]; in decode()
135 &buffer[0..7], in test_ipv4()
160 &buffer[0..27], in test_ipv6()
206 let result = ip.encode(&mut buffer); in test_encode_ipv4_with_short_buffer()
223 let result = ip.encode(&mut buffer); in test_encode_ipv6_with_short_buffer()
230 let buffer = vec![IPV4_MARKER, 0]; in test_decode_ipv4_with_short_buffer() localVariable
[all …]
H A Dudp_mux_test.rs197 let mut buffer = vec![0u8; RECEIVE_MTU]; in test_mux_connection() localVariable
199 assert_eq!(buffer[..len], stun_msg); in test_mux_connection()
214 .recv_from(&mut buffer) in test_mux_connection()
240 .recv(&mut buffer) in test_mux_connection()
254 let mut buffer = vec![0u8; RECEIVE_MTU]; in test_mux_connection() localVariable
256 thread_rng().fill(&mut buffer[24..]); in test_mux_connection()
258 let hash = sha1_hash(&buffer[24..]); in test_mux_connection()
284 let hash = sha1_hash(&buffer[24..]); in verify_packet()
285 assert_eq!(hash, buffer[4..24]); in verify_packet()
288 fn sha1_hash(buffer: &[u8]) -> Vec<u8> { in sha1_hash()
[all …]
H A Dudp_mux_conn.rs57 buffer: Buffer::new(0, 0), in new()
71 let mut buffer = make_buffer(); in write_packet() localVariable
86 buffer[offset..offset + data.len()].copy_from_slice(data); in write_packet()
89 let len = addr.encode(&mut buffer[offset + 2..])?; in write_packet()
93 self.inner.buffer.write(&buffer[..offset]).await?; in write_packet()
147 buffer: Buffer, field
154 let mut buffer = make_buffer(); in recv_from() localVariable
157 let len = self.buffer.read(&mut buffer, None).await?; in recv_from()
167 let data_len: usize = buffer[..2] in recv_from()
182 let address_len: usize = buffer[offset..offset + 2] in recv_from()
[all …]
H A Dmod.rs119 async fn conn_from_stun_message(&self, buffer: &[u8], addr: &SocketAddr) -> Option<UDPMuxConn> { in conn_from_stun_message()
123 (m.unmarshal_binary(buffer), m) in conn_from_stun_message()
165 let mut buffer = [0u8; RECEIVE_MTU]; in start_conn_worker() localVariable
172 res = conn.recv_from(&mut buffer) => { in start_conn_worker()
187 None if is_stun_message(&buffer) => { in start_conn_worker()
188 loop_self.conn_from_stun_message(&buffer, &addr).await in start_conn_worker()
199 … if let Err(err) = conn.write_packet(&buffer[..len], addr).await { in start_conn_worker()
/webrtc/dtls/src/crypto/
H A Dcrypto_gcm.rs66 let mut buffer: Vec<u8> = Vec::new(); in encrypt() localVariable
67 buffer.extend_from_slice(payload); in encrypt()
70 .encrypt_in_place(nonce, &additional_data, &mut buffer) in encrypt()
73 let mut r = Vec::with_capacity(raw.len() + nonce.len() + buffer.len()); in encrypt()
76 r.extend_from_slice(&buffer); in encrypt()
107 let mut buffer: Vec<u8> = Vec::new(); in decrypt() localVariable
108 buffer.extend_from_slice(out); in decrypt()
111 .decrypt_in_place(nonce, &additional_data, &mut buffer) in decrypt()
114 let mut d = Vec::with_capacity(RECORD_LAYER_HEADER_SIZE + buffer.len()); in decrypt()
116 d.extend_from_slice(&buffer); in decrypt()
H A Dcrypto_ccm.rs118 let mut buffer: Vec<u8> = Vec::new(); in encrypt() localVariable
119 buffer.extend_from_slice(payload); in encrypt()
123 ccm.encrypt_in_place(nonce, &additional_data, &mut buffer) in encrypt()
127 ccm8.encrypt_in_place(nonce, &additional_data, &mut buffer) in encrypt()
132 let mut r = Vec::with_capacity(raw.len() + nonce.len() + buffer.len()); in encrypt()
136 r.extend_from_slice(&buffer); in encrypt()
165 let mut buffer: Vec<u8> = Vec::new(); in decrypt() localVariable
166 buffer.extend_from_slice(out); in decrypt()
172 ccm.decrypt_in_place(nonce, &additional_data, &mut buffer) in decrypt()
178 ccm8.decrypt_in_place(nonce, &additional_data, &mut buffer) in decrypt()
[all …]
/webrtc/srtp/src/
H A Dstream.rs17 pub(crate) buffer: Buffer, field
28 buffer: Buffer::new( in new()
52 Ok(self.buffer.read(buf, None).await?) in read()
61 let n = self.buffer.read(buf, None).await?; in read_rtp()
74 let n = self.buffer.read(buf, None).await?; in read_rtcp()
83 self.buffer.close().await; in close()
/webrtc/media/src/io/sample_builder/
H A Dmod.rs23 buffer: Vec<Option<Packet>>, field
61 buffer: vec![None; u16::MAX as usize + 1], in new()
90 if let Some(ref packet) = self.buffer[i as usize] { in too_old()
103 if let Some(ref packet) = self.buffer[i as usize] { in too_old()
123 (self.buffer[location.head as usize]) in fetch_timestamp()
132 self.buffer[i as usize] = None; in release_packet()
202 self.buffer[sequence_number as usize] = Some(p); in push()
243 while let Some(ref packet) = self.buffer[i as usize] { in build_sample()
291 if let Some(ref packet) = self.buffer[i as usize] { in build_sample()
299 let head_payload = self.buffer[consume.head as usize] in build_sample()
[all …]
/webrtc/util/benches/
H A Dbench.rs7 let buffer = Buffer::new(0, 0); in buffer_write_then_read() localVariable
10 buffer.write(&[0, 1]).await.unwrap(); in buffer_write_then_read()
11 buffer.read(&mut packet, None).await.unwrap(); in buffer_write_then_read()
/webrtc/media/src/audio/
H A Dbuffer.rs98 fn from(buffer: Buffer<T, Deinterleaved>) -> Self { in from()
99 Self::from(buffer.as_ref()) in from()
123 buffer.samples, in from()
125 buffer.info.channels(), in from()
133 let info = buffer.info.into(); in from()
142 fn from(buffer: Buffer<T, Interleaved>) -> Self { in from()
143 Self::from(buffer.as_ref()) in from()
151 fn from(buffer: BufferRef<'a, T, Interleaved>) -> Self { in from()
167 buffer.samples, in from()
169 buffer.info.channels(), in from()
[all …]
H A Dmod.rs1 pub mod buffer; module
/webrtc/util/
H A DCargo.toml16 default = ["buffer", "conn", "ifaces", "vnet", "marshal", "sync"]
17 buffer = []
18 conn = ["buffer", "sync"]
/webrtc/webrtc/src/mux/
H A Dendpoint.rs14 pub(crate) buffer: Buffer, field
23 self.buffer.close().await; in close()
43 match self.buffer.read(buf, None).await { in recv()
H A Dmod.rs70 buffer: Buffer::new(0, MAX_BUFFER_SIZE), in new_endpoint()
137 ep.buffer.write(buf).await?; in dispatch()
/webrtc/util/src/
H A Dlib.rs63 pub mod buffer; module
78 pub use crate::buffer::Buffer;
/webrtc/util/src/conn/
H A Dconn_udp_listener.rs174 let _ = conn.buffer.write(&buf[..n]).await; in read_loop()
239 buffer: Buffer, field
252 buffer: Buffer::new(0, 0), in new()
264 Ok(self.buffer.read(buf, None).await?) in recv()
268 let n = self.buffer.read(buf, None).await?; in recv_from()
/webrtc/util/src/ifaces/ffi/windows/
H A Dmod.rs279 unsafe fn local_ifaces_with_buffer(buffer: &mut Vec<u8>) -> io::Result<()> { in local_ifaces_with_buffer()
280 let mut length = buffer.capacity() as u32; in local_ifaces_with_buffer()
286 buffer.as_mut_ptr(), in local_ifaces_with_buffer()
296 buffer.reserve_exact(length as usize); in local_ifaces_with_buffer()
298 local_ifaces_with_buffer(buffer) in local_ifaces_with_buffer()
/webrtc/media/src/io/h264_reader/
H A Dmod.rs231 let buffer = self.read(1)?; in next_nal() localVariable
232 let n = buffer.len(); in next_nal()
237 let read_byte = buffer[0]; in next_nal()
/webrtc/examples/examples/data-channels-detach-create/
H A Ddata-channels-detach-create.rs206 let mut buffer = vec![0u8; MESSAGE_SIZE]; in read_loop() localVariable
208 let n = match d.read(&mut buffer).await { in read_loop()
218 String::from_utf8(buffer[..n].to_vec())? in read_loop()
/webrtc/examples/examples/data-channels-detach/
H A Ddata-channels-detach.rs214 let mut buffer = vec![0u8; MESSAGE_SIZE]; in read_loop() localVariable
216 let n = match d.read(&mut buffer).await { in read_loop()
226 String::from_utf8(buffer[..n].to_vec())? in read_loop()
/webrtc/ice/src/agent/
H A Dagent_transport.rs87 pub(crate) buffer: Buffer, field
101 buffer: Buffer::new(0, MAX_BUFFER_SIZE), in new()
175 let n = match self.buffer.read(buf, None).await { in recv()
/webrtc/media/benches/
H A Daudio_buffer.rs3 use webrtc_media::audio::buffer::{
/webrtc/turn/src/allocation/
H A Dmod.rs348 let mut buffer = vec![0u8; RTP_MTU]; in packet_handler() localVariable
354 result = relay_socket.recv_from(&mut buffer) => { in packet_handler()
393 data: buffer[..n].to_vec(), in packet_handler()
421 let data_attr = Data(buffer[..n].to_vec()); in packet_handler()

12