| |
for (id, ka) in self
|
| |
.available_peers()
|
| |
.into_iter()
|
| - |
.flat_map(|(nid, kas)| kas.into_iter().map(move |ka| (nid, ka)))
|
| - |
.filter(|(_, ka)| match (ka.last_success, ka.last_attempt) {
|
| - |
// If we succeeded the last time we tried, this is a good address.
|
| - |
(Some(success), attempt) => success >= attempt.unwrap_or_default(),
|
| - |
// If we haven't succeeded yet, and we waited long enough, we can try this address.
|
| - |
(None, Some(attempt)) => now - attempt >= CONNECTION_RETRY_DELTA,
|
| - |
// If we've never tried this address, it's worth a try.
|
| - |
(None, None) => true,
|
| + |
.filter_map(|(nid, kas)| {
|
| + |
kas.into_iter()
|
| + |
.find(|ka| match (ka.last_success, ka.last_attempt) {
|
| + |
// If we succeeded the last time we tried, this is a good address.
|
| + |
(Some(success), attempt) => success >= attempt.unwrap_or_default(),
|
| + |
// If we haven't succeeded yet, and we waited long enough, we can try this address.
|
| + |
(None, Some(attempt)) => now - attempt >= CONNECTION_RETRY_DELTA,
|
| + |
// If we've never tried this address, it's worth a try.
|
| + |
(None, None) => true,
|
| + |
})
|
| + |
.map(|ka| (nid, ka))
|
| |
})
|
| |
.take(wanted)
|
| |
{
|