Lines Matching refs:read_buffer
83 let mut read_buffer = BytesMut::with_capacity(RTP_HEADER_SIZE + test_payload.len()); in test_session_srtp_accept() localVariable
84 read_buffer.resize(RTP_HEADER_SIZE + test_payload.len(), 0u8); in test_session_srtp_accept()
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()
122 let mut read_buffer = BytesMut::with_capacity(RTP_HEADER_SIZE + test_payload.len()); in test_session_srtp_listen() localVariable
123 read_buffer.resize(RTP_HEADER_SIZE + test_payload.len(), 0u8); in test_session_srtp_listen()
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()
158 let mut read_buffer = BytesMut::with_capacity(RTP_HEADER_SIZE + test_payload.len()); in test_session_srtp_multi_ssrc() localVariable
159 read_buffer.resize(RTP_HEADER_SIZE + test_payload.len(), 0u8); in test_session_srtp_multi_ssrc()
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()
210 let mut read_buffer = BytesMut::with_capacity(header_size + expected_payload.len()); in payload_srtp() localVariable
211 read_buffer.resize(header_size + expected_payload.len(), 0u8); in payload_srtp()
213 let (n, hdr) = read_stream.read_rtp(&mut read_buffer).await?; in payload_srtp()
217 &read_buffer[header_size..n], in payload_srtp()
220 &read_buffer[header_size..n] in payload_srtp()