octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use `DateTime32` in `validate_addrs`

This commit is contained in:
Janito Vaqueiro Ferreira Filho 2021-05-31 13:49:59 +00:00
parent b891a96a6d
commit 14ecc79f01
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
zebra-network/src/peer_set/candidate_set.rs
View File

@ -1,10 +1,11 @@
use std::{cmp::min, mem, sync::Arc, time::Duration}; use std::{cmp::min, mem, sync::Arc, time::Duration};
use chrono::{DateTime, Utc};
use futures::stream::{FuturesUnordered, StreamExt}; use futures::stream::{FuturesUnordered, StreamExt};
use tokio::time::{sleep, sleep_until, timeout, Sleep}; use tokio::time::{sleep, sleep_until, timeout, Sleep};
use tower::{Service, ServiceExt}; use tower::{Service, ServiceExt};
use zebra_chain::serialization::DateTime32;
use crate::{constants, types::MetaAddr, AddressBook, BoxError, Request, Response}; use crate::{constants, types::MetaAddr, AddressBook, BoxError, Request, Response};
/// The `CandidateSet` manages the `PeerSet`'s peer reconnection attempts. /// The `CandidateSet` manages the `PeerSet`'s peer reconnection attempts.
@ -229,7 +230,7 @@ where
?addrs, ?addrs,
"got response to GetPeers" "got response to GetPeers"
); );
let addrs = validate_addrs(addrs, Utc::now()); let addrs = validate_addrs(addrs, DateTime32::now());
self.send_addrs(addrs); self.send_addrs(addrs);
} }
Err(e) => { Err(e) => {
@ -334,7 +335,7 @@ where
#[allow(unused_variables)] #[allow(unused_variables)]
fn validate_addrs( fn validate_addrs(
addrs: impl IntoIterator<Item = MetaAddr>, addrs: impl IntoIterator<Item = MetaAddr>,
last_seen_limit: DateTime<Utc>, last_seen_limit: DateTime32,
) -> impl Iterator<Item = MetaAddr> { ) -> impl Iterator<Item = MetaAddr> {
// Note: The address book handles duplicate addresses internally, // Note: The address book handles duplicate addresses internally,
// so we don't need to de-duplicate addresses here. // so we don't need to de-duplicate addresses here.