Searched refs:read_buffer (Results 1 – 3 of 3) sorted by relevance
| /webrtc/srtp/src/session/ |
| H A D | session_rtp_test.rs | 103 read_stream.read(&mut read_buffer).await?; in test_session_srtp_accept()
107 &read_buffer[RTP_HEADER_SIZE..], in test_session_srtp_accept()
110 &read_buffer[RTP_HEADER_SIZE..] in test_session_srtp_accept()
138 read_stream.read(&mut read_buffer).await?; in test_session_srtp_listen()
142 &read_buffer[RTP_HEADER_SIZE..], in test_session_srtp_listen()
145 &read_buffer[RTP_HEADER_SIZE..] in test_session_srtp_listen()
179 read_stream.read(&mut read_buffer).await?; in test_session_srtp_multi_ssrc()
183 &read_buffer[RTP_HEADER_SIZE..], in test_session_srtp_multi_ssrc()
186 &read_buffer[RTP_HEADER_SIZE..] in test_session_srtp_multi_ssrc()
217 &read_buffer[header_size..n], in payload_srtp()
[all …]
|
| H A D | session_rtcp_test.rs | 95 read_buffer.resize(test_payload.len(), 0u8); in test_session_srtcp_accept()
96 read_stream.read(&mut read_buffer).await?; in test_session_srtcp_accept()
100 &read_buffer[..], in test_session_srtcp_accept()
103 &read_buffer[..] in test_session_srtcp_accept()
127 read_buffer.resize(test_payload.len(), 0u8); in test_session_srtcp_listen()
128 read_stream.read(&mut read_buffer).await?; in test_session_srtcp_listen()
132 &read_buffer[..], in test_session_srtcp_listen()
135 &read_buffer[..] in test_session_srtcp_listen()
159 read_buffer.resize(PLI_PACKET_SIZE + auth_tag_size, 0u8); in get_sender_ssrc()
161 let (n, _) = read_stream.read_rtcp(&mut read_buffer).await?; in get_sender_ssrc()
[all …]
|
| /webrtc/media/src/io/h264_reader/ |
| H A D | mod.rs | 140 read_buffer: Vec<u8>, field
152 read_buffer: vec![], in new()
159 while self.read_buffer.len() < num_to_read { in read()
170 self.read_buffer.extend_from_slice(&buf[0..n]); in read()
173 let num_should_read = if num_to_read <= self.read_buffer.len() { in read()
176 self.read_buffer.len() in read()
180 self.read_buffer in read()
|