pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-07-21 15:35:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix busy loops. (#3392)

Browse Source
This commit is contained in:
Robert Klotzner
2021-07-01 08:44:13 +02:00
committed by GitHub
parent 0b10a24cd2
commit f293fb1025
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/network/availability-recovery/src/lib.rs
+2 -2
View File
@@ -806,8 +806,8 @@ impl AvailabilityRecoverySubsystem {
} }
} }
} }
output = state.interactions.next() => { output = state.interactions.select_next_some() => {
if let Some((candidate_hash, result)) = output.flatten() { if let Some((candidate_hash, result)) = output {
state.availability_lru.put(candidate_hash, result); state.availability_lru.put(candidate_hash, result);
} }
} }
polkadot/node/network/collator-protocol/src/validator_side/mod.rs
+2 -4
View File
@@ -1138,10 +1138,8 @@ pub(crate) async fn run<Context>(
_ = next_inactivity_stream.next() => { _ = next_inactivity_stream.next() => {
disconnect_inactive_peers(&mut ctx, &eviction_policy, &state.peer_data).await; disconnect_inactive_peers(&mut ctx, &eviction_policy, &state.peer_data).await;
} }
res = state.collation_fetches.next() => { res = state.collation_fetches.select_next_some() => {
if let Some(res) = res { handle_collation_fetched_result(&mut ctx, &mut state, res).await;
handle_collation_fetched_result(&mut ctx, &mut state, res).await;
}
} }
} }