Lines Matching refs:read_buffer
94 let mut read_buffer = BytesMut::with_capacity(test_payload.len()); in test_session_srtcp_accept() localVariable
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()
126 let mut read_buffer = BytesMut::with_capacity(test_payload.len()); in test_session_srtcp_listen() localVariable
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()
158 let mut read_buffer = BytesMut::with_capacity(PLI_PACKET_SIZE + auth_tag_size); in get_sender_ssrc() localVariable
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()
162 let mut reader = &read_buffer[0..n]; in get_sender_ssrc()