add more delay to test

This commit is contained in:
fakeshadow 2021-04-12 03:08:17 +08:00
parent 9da557f61d
commit 5c64ad9750
1 changed files with 4 additions and 0 deletions

View File

@ -479,6 +479,8 @@ async fn test_worker_restart() {
stream.flush().unwrap();
stream.shutdown(net::Shutdown::Both).unwrap();
// force worker 2 to restart service once.
if counter == 2 {
panic!("panic on purpose")
@ -533,6 +535,8 @@ async fn test_worker_restart() {
assert_eq!("1", id);
stream.shutdown().await.unwrap();
sleep(Duration::from_secs(3)).await;
// worker 2 restarting and work goes to worker 1.
let mut stream = TcpStream::connect(addr).await.unwrap();
let n = stream.read(&mut buf).await.unwrap();