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

Fix timeout for subscriptions test (#9043) (#9044)

Browse Source 
automerge
This commit is contained in:
mergify[bot]
2020-03-24 02:57:25 -07:00
committed by GitHub
parent 7636a0521f
commit 13676e9614
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/tests/rpc.rs
View File

@@ -271,7 +271,7 @@ fn test_rpc_subscriptions() {
}); });
let rpc_client = RpcClient::new_socket(leader_data.rpc); let rpc_client = RpcClient::new_socket(leader_data.rpc);
let transaction_count = rpc_client let mut transaction_count = rpc_client
.get_transaction_count_with_commitment(CommitmentConfig::recent()) .get_transaction_count_with_commitment(CommitmentConfig::recent())
.unwrap(); .unwrap();
@@ -281,10 +281,10 @@ fn test_rpc_subscriptions() {
.send_to(&bincode::serialize(&tx).unwrap(), leader_data.tpu) .send_to(&bincode::serialize(&tx).unwrap(), leader_data.tpu)
.unwrap(); .unwrap();
}); });
let mut x = 0;
let now = Instant::now(); let now = Instant::now();
while x < transaction_count + 500 || now.elapsed() > Duration::from_secs(5) { let expected_transaction_count = transaction_count + transactions.len() as u64;
x = rpc_client while transaction_count < expected_transaction_count && now.elapsed() < Duration::from_secs(5) {
transaction_count = rpc_client
.get_transaction_count_with_commitment(CommitmentConfig::recent()) .get_transaction_count_with_commitment(CommitmentConfig::recent())
.unwrap(); .unwrap();
sleep(Duration::from_millis(200)); sleep(Duration::from_millis(200));