gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Extend TestBroadcastReceiver::recv timeout (#20957) (#20961)

Browse Source 
* Extend TestBroadcastReceiver timeout

* Add elapsed log

(cherry picked from commit 337b94b3bc)

Co-authored-by: Tyera Eulberg <teulberg@gmail.com>
This commit is contained in:
mergify[bot]
2021-10-26 00:51:29 +00:00
committed by GitHub
parent e84c57b659
commit d18f553e2d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
rpc/src/rpc_pubsub_service.rs
View File

@ -172,12 +172,16 @@ impl TestBroadcastReceiver {
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
use tokio::sync::broadcast::error::TryRecvError; use tokio::sync::broadcast::error::TryRecvError;
let timeout = Duration::from_millis(500); let timeout = Duration::from_secs(5);
let started = Instant::now(); let started = Instant::now();
loop { loop {
match self.inner.try_recv() { match self.inner.try_recv() {
Ok(notification) => { Ok(notification) => {
debug!(
"TestBroadcastReceiver: {:?}ms elapsed",
started.elapsed().as_millis()
);
if let Some(json) = self.handler.handle(notification).expect("handler failed") { if let Some(json) = self.handler.handle(notification).expect("handler failed") {
return json.to_string(); return json.to_string();
} }