Lines Matching refs:recv
153 let recv = self.recv().await?;
154 let msg = match std::str::from_utf8(&recv[..config::HANDSHAKE_MESSAGE.len()]) {
182 async fn recv(&mut self) -> io::Result<Vec<u8>> {
183 hdc::debug!("channel recv buf");
184 transfer::ChannelMap::recv().await
221 match transfer::ChannelMap::recv().await {
222 Ok(recv) => {
223 let _ = utils::print_msg(recv).await;
269 match transfer::ChannelMap::recv().await {
270 Ok(recv) => {
271 let _ = utils::print_msg(recv).await;
322 let recv = self.recv().await?;
324 "general_task recv: {:#?}",
325 recv.iter()
330 let _ = utils::print_msg(recv).await;
341 let recv = self.recv().await?;
342 file.write_all(&recv)?;
363 let recv = self.recv().await;
364 match recv {
365 Ok(recv) => {
367 "recv: {:#?}",
368 recv.iter()
373 match String::from_utf8(recv) {
375 Err(err) => return Err(Error::new(ErrorKind::Other, format!("recv data to str failed, {err}"))),
387 let recv = self.recv().await;
388 match recv {
389 Ok(recv) => {
391 "recv: {:#?}",
392 recv.iter()
399 if wait_for == String::from_utf8(recv).expect("invalid UTF-8") {
431 let recv = self.recv().await;
432 match recv {
433 Ok(recv) => {
435 "app_install_task recv: {:#?}",
436 recv.iter()
441 match String::from_utf8(recv) {
458 let recv = self.recv().await;
459 match recv {
460 Ok(recv) => {
462 "app_uninstall_task recv: {:#?}",
463 recv.iter()
468 match String::from_utf8(recv) {
486 let recv = self.recv().await;
487 match recv {
488 Ok(recv) => {
490 "check_server_task recv: {:#?}",
491 recv.iter()
498 if recv.len() < CMD_U8_LEN {
499 return Err(Error::new(io::ErrorKind::Other, "recv failed"));
502 let (cmd_slice, version_slice) = recv.split_at(CMD_U8_LEN);
508 return Err(Error::new(io::ErrorKind::Other, "recv cmd error"));