Lines Matching refs:recv
270 let recv = match transfer::tcp::recv_channel_message(&mut rd).await {
271 Ok(recv) => recv,
277 hdc::debug!("recv hex: {}", recv.iter().map(|c| format!("{c:02x}")).collect::<Vec<_>>().join(" "));
279 let recv_str = String::from_utf8_lossy(&recv.clone()).into_owned();
280 hdc::debug!("recv str: {}", recv_str.clone());
282 String::from_utf8_lossy(&recv)
336 let recv = transfer::tcp::recv_channel_message(rd).await?;
337 let connect_key = unpack_channel_handshake(recv)?;
341 fn unpack_channel_handshake(recv: Vec<u8>) -> io::Result<String> {
342 let Ok(msg) = std::str::from_utf8(&recv[..config::HANDSHAKE_MESSAGE.len()]) else {
348 let key_buf = &recv[config::BANNER_SIZE..];