Home
last modified time | relevance | path

Searched refs:read (Results 1 – 25 of 61) sorted by relevance

123

/webrtc/interceptor/src/
H A Dstream_reader.rs9 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
10 Ok((self.read(buf).await?, a.clone())) in read()
16 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
17 Ok((self.read(buf).await?, a.clone())) in read()
H A Dnoop.rs63 async fn read(&self, _buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
70 async fn read(&self, _buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
H A Dlib.rs107 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() method
123 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() method
166 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)>; in read() method
183 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() method
/webrtc/util/src/buffer/
H A Dbuffer_test.rs18 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
35 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
39 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
55 let n = assert_ok!(buffer.read(&mut packet, None).await); in test_buffer()
60 let result = buffer.read(&mut packet, None).await; in test_buffer()
87 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
96 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
101 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
103 let n = assert_ok!(buffer.read(&mut p, None).await); in test_wraparound()
140 let result = buffer2.read(&mut packet, None).await; in test_buffer_async()
[all …]
/webrtc/srtp/src/
H A Dstream.rs51 pub async fn read(&self, buf: &mut [u8]) -> Result<usize> { in read() method
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()
/webrtc/ice/src/udp_mux/
H A Dudp_mux_test.rs210 let mut read = 0; in test_mux_connection() localVariable
212 while read < TARGET_SIZE { in test_mux_connection()
225 read += n; in test_mux_connection()
226 log::debug!("Muxxed read {}, sequence: {}", read, next_sequence); in test_mux_connection()
236 let mut read = 0; in test_mux_connection() localVariable
238 while read < TARGET_SIZE { in test_mux_connection()
246 read += n; in test_mux_connection()
247 log::debug!("Remote read {}, sequence: {}", read, next_sequence); in test_mux_connection()
/webrtc/sctp/src/
H A Dfuzz_artifact_test.rs24 let artifact = std::fs::read(artifact.path()).unwrap(); in param_crash_artifacts()
40 let artifact = std::fs::read(artifact.path()).unwrap(); in packet_crash_artifacts()
/webrtc/webrtc/src/rtp_transceiver/rtp_receiver/
H A Dmod.rs170 let tracks = self.tracks.read().await; in read()
179 result = rtcp_interceptor.read(b, &a) => { in read()
200 let tracks = self.tracks.read().await; in read_simulcast()
231 let (n, attributes) = self.read(&mut b).await?; in read_rtcp()
264 let tracks = self.tracks.read().await; in read_rtp()
296 result = rtp_interceptor.read(b, &a) => { in read_rtp()
486 let tracks = self.internal.tracks.read().await; in track()
497 let tracks = self.internal.tracks.read().await; in tracks()
617 self.internal.read(b).await in read()
816 let streams = self.internal.tracks.read().await; in pause()
[all …]
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs33 async fn read(&self, buf: &mut [u8], attributes: &Attributes) -> Result<(usize, Attributes)> { in read() method
34 let (n, attr) = self.parent_rtp_reader.read(buf, attributes).await?; in read()
/webrtc/webrtc/src/rtp_transceiver/
H A Dsrtp_writer_future.rs180 pub async fn read(&self, b: &mut [u8]) -> Result<usize> { in read() method
187 return Ok(rtcp_read_stream.read(b).await?); in read()
199 return Ok(rtcp_read_stream.read(b).await?); in read()
263 async fn read(&self, buf: &mut [u8], a: &Attributes) -> IResult<(usize, Attributes)> { in read() method
264 Ok((self.read(buf).await?, a.clone())) in read()
/webrtc/media/src/io/h264_reader/
H A Dmod.rs157 fn read(&mut self, num_to_read: usize) -> Result<Bytes> { in read() method
160 let n = match self.reader.read(buf) { in read()
187 let prefix_buffer = self.read(4)?; in bit_stream_starts_with_h264prefix()
231 let buffer = self.read(1)?; in next_nal()
/webrtc/util/src/conn/
H A Dconn_disconnected_packet.rs42 let addr = *self.raddr.read(); in send()
55 let raddr = *self.raddr.read(); in remote_addr()
/webrtc/util/src/sync/
H A Dmod.rs56 pub fn read(&self) -> RwLockReadGuard<'_, T> { in read() method
57 let guard = self.0.read().unwrap(); in read()
/webrtc/sctp/src/queue/
H A Dpending_queue.rs169 let unordered_queue = self.unordered_queue.read(); in peek()
172 let ordered_queue = self.ordered_queue.read(); in peek()
178 let unordered_queue = self.unordered_queue.read(); in peek()
186 let ordered_queue = self.ordered_queue.read(); in peek()
H A Dqueue_test.rs484 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_fragments()
542 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_fragments()
591 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
598 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
663 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_complete_skips_incomplete()
739 let result = rq.read(&mut buf); in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
767 let result = rq.read(&mut buf); in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()
795 let result = rq.read(&mut buf); in test_reassembly_queue_detect_buffer_too_short()
/webrtc/util/src/vnet/
H A Dconn.rs83 let rem_addr = *self.rem_addr.read(); in recv_from()
103 let rem_addr = *self.rem_addr.read(); in send()
140 *self.rem_addr.read() in remote_addr()
H A Dchunk_queue.rs40 let chunks = self.chunks.read().await; in peek()
/webrtc/data/src/data_channel/
H A Ddata_channel_test.rs297 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_channel_type_reliable_ordered()
305 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_channel_type_reliable_ordered()
462 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_buffered_amount()
465 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_buffered_amount()
493 while let Ok(n) = dc1_cloned.read(&mut rbuf[..]).await { in test_data_channel_buffered_amount()
583 let n = dc1.read(&mut rbuf[..]).await?; in test_stats()
590 let n = dc1.read(&mut rbuf[..]).await?; in test_stats()
597 let n = dc1.read(&mut rbuf[..]).await?; in test_stats()
604 let n = dc1.read(&mut rbuf[..]).await?; in test_stats()
656 .read(&mut rbuf[..]) in test_poll_data_channel()
/webrtc/util/benches/
H A Dbench.rs11 buffer.read(&mut packet, None).await.unwrap(); in buffer_write_then_read()
/webrtc/sctp/src/stream/
H A Dstream_test.rs119 s.read(&mut buf).await?; in test_stream()
137 s.read(&mut buf).await?; in test_stream()
143 assert_eq!(s.read(&mut buf).await, Ok(0)); in test_stream()
/webrtc/srtp/src/session/
H A Dsession_rtp_test.rs103 read_stream.read(&mut read_buffer).await?; in test_session_srtp_accept()
138 read_stream.read(&mut read_buffer).await?; in test_session_srtp_listen()
179 read_stream.read(&mut read_buffer).await?; in test_session_srtp_multi_ssrc()
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs37 async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() method
52 result = rtcp_interceptor.read(b, &a) => { in read()
72 let (n, attributes) = self.read(&mut b).await?; in read_rtcp()
472 pub async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() method
473 self.internal.read(b).await in read()
/webrtc/interceptor/src/mock/
H A Dmock_stream.rs91 let n = match rtcp_reader.read(&mut buf, &a).await { in new()
124 let n = match rtp_reader.read(&mut buf, &a).await { in new()
262 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
289 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
/webrtc/interceptor/src/nack/responder/
H A Dmod.rs105 async fn read(&self, buf: &mut [u8], a: &Attributes) -> Result<(usize, Attributes)> { in read() method
106 let (n, attr) = { self.parent_rtcp_reader.read(buf, a).await? }; in read()
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs219 pub async fn read(&self, b: &mut [u8]) -> Result<(usize, Attributes)> { in read() method
283 let (n, attributes) = self.read(&mut b).await?; in read_rtp()
292 let (n, a) = self.read(b).await?; in peek()

123