berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

busy loop when write to stream

This commit is contained in:
fakeshadow 2021-04-12 04:04:13 +08:00
parent ac7f2236f7
commit 0d77e0076c
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
actix-server/tests/test_server.rs
View File

@ -475,11 +475,17 @@ async fn test_worker_restart() {
let mut stream = stream.into_std().unwrap(); let mut stream = stream.into_std().unwrap();
use std::io::Write; use std::io::Write;
let str = counter.to_string(); let str = counter.to_string();
stream.write_all(str.as_bytes()).unwrap(); let buf = str.as_bytes();
let mut written = 0;
while written < buf.len() {
if let Ok(n) = stream.write(&buf[written..]) {
written += n;
}
}
stream.flush().unwrap(); stream.flush().unwrap();
stream.shutdown(net::Shutdown::Write).unwrap();
stream.shutdown(net::Shutdown::Both).unwrap();
// force worker 2 to restart service once. // force worker 2 to restart service once.
if counter == 2 { if counter == 2 {
@ -498,7 +504,6 @@ async fn test_worker_restart() {
let counter = counter.clone(); let counter = counter.clone();
actix_rt::System::new().block_on(async { actix_rt::System::new().block_on(async {
let server = Server::build() let server = Server::build()
.backlog(1)
.disable_signals() .disable_signals()
.bind("addr", addr, move || TestServiceFactory(counter.clone())) .bind("addr", addr, move || TestServiceFactory(counter.clone()))
.unwrap() .unwrap()
@ -537,13 +542,12 @@ async fn test_worker_restart() {
// worker 2 restarting and work goes to worker 1. // worker 2 restarting and work goes to worker 1.
let mut stream = TcpStream::connect(addr).await.unwrap(); let mut stream = TcpStream::connect(addr).await.unwrap();
let n = stream.read(&mut buf).await.unwrap(); let n = stream.read(&mut buf).await.unwrap();
let id = String::from_utf8_lossy(&buf[0..n]); let id = String::from_utf8_lossy(&buf[0..n]);
assert_eq!("1", id); assert_eq!("1", id);
stream.shutdown().await.unwrap(); stream.shutdown().await.unwrap();
sleep(Duration::from_secs(3)).await;
// worker 2 restarted but worker 1 was still the next to accept connection. // worker 2 restarted but worker 1 was still the next to accept connection.
let mut stream = TcpStream::connect(addr).await.unwrap(); let mut stream = TcpStream::connect(addr).await.unwrap();
let n = stream.read(&mut buf).await.unwrap(); let n = stream.read(&mut buf).await.unwrap();