Skip to content

Commit 2b8867a

Browse files
committed
test(xtask): don't read TCP to end
1 parent 250f22e commit 2b8867a

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

xtask/src/ci/qemu.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -574,9 +574,9 @@ fn test_miotcp(guest_ip: IpAddr) -> Result<()> {
574574
let mut stream = TcpStream::connect(socket_addr)?;
575575
stream.write_all(buf.as_bytes())?;
576576

577-
let mut buf = vec![];
578-
let received = stream.read_to_end(&mut buf)?;
579-
eprintln!("[CI] receive: {}", from_utf8(&buf[..received])?);
577+
let mut buf = vec![0; buf.len()];
578+
let received = stream.read_exact(&mut buf)?;
579+
eprintln!("[CI] receive: {}", from_utf8(&buf)?);
580580

581581
Ok(())
582582
}
@@ -589,9 +589,9 @@ fn test_poll(guest_ip: IpAddr) -> Result<()> {
589589
let mut stream = TcpStream::connect(socket_addr)?;
590590
stream.write_all(buf.as_bytes())?;
591591

592-
let mut buf = vec![];
593-
let received = stream.read_to_end(&mut buf)?;
594-
eprintln!("[CI] receive: {}", from_utf8(&buf[..received])?);
592+
let mut buf = vec![0; buf.len()];
593+
let received = stream.read_exact(&mut buf)?;
594+
eprintln!("[CI] receive: {}", from_utf8(&buf)?);
595595

596596
Ok(())
597597
}

0 commit comments

Comments
 (0)