cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Increase RPC test timeouts (#1261)

Browse Source
This commit is contained in:
Age Manning 2020-06-12 10:05:55 +10:00 committed by GitHub
parent 2dfe77a8f9
commit 320e72e2de
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
beacon_node/eth2-libp2p/tests/rpc_tests.rs
View File

@ -94,7 +94,7 @@ async fn test_status_rpc() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -204,7 +204,7 @@ async fn test_blocks_by_range_chunked_rpc() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -291,7 +291,7 @@ async fn test_blocks_by_range_chunked_rpc_terminates_correctly() {
// sent in the timeout // sent in the timeout
match futures::future::select( match futures::future::select(
Box::pin(receiver.next_event()), Box::pin(receiver.next_event()),
tokio::time::delay_for(Duration::from_millis(50)), tokio::time::delay_for(Duration::from_secs(1)),
) )
.await .await
{ {
@ -334,7 +334,7 @@ async fn test_blocks_by_range_chunked_rpc_terminates_correctly() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -441,7 +441,7 @@ async fn test_blocks_by_range_single_empty_rpc() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(800)) => { _ = delay_for(Duration::from_secs(20)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -555,7 +555,7 @@ async fn test_blocks_by_root_chunked_rpc() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -651,7 +651,7 @@ async fn test_blocks_by_root_chunked_rpc_terminates_correctly() {
// sent in the timeout // sent in the timeout
match futures::future::select( match futures::future::select(
Box::pin(receiver.next_event()), Box::pin(receiver.next_event()),
tokio::time::delay_for(Duration::from_millis(50)), tokio::time::delay_for(Duration::from_millis(1000)),
) )
.await .await
{ {
@ -694,7 +694,7 @@ async fn test_blocks_by_root_chunked_rpc_terminates_correctly() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }
@ -752,7 +752,7 @@ async fn test_goodbye_rpc() {
tokio::select! { tokio::select! {
_ = sender_future => {} _ = sender_future => {}
_ = receiver_future => {} _ = receiver_future => {}
_ = delay_for(Duration::from_millis(2000)) => { _ = delay_for(Duration::from_secs(30)) => {
panic!("Future timed out"); panic!("Future timed out");
} }
} }