Request::Peers not GetPeers
This commit is contained in:
parent
97aceae461
commit
8f5e7c268b
|
@ -39,3 +39,6 @@ tracing-error = "0.1.2"
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
abscissa_core = { version = "0.5", features = ["testing"] }
|
abscissa_core = { version = "0.5", features = ["testing"] }
|
||||||
once_cell = "1.4"
|
once_cell = "1.4"
|
||||||
|
|
||||||
|
[features]
|
||||||
|
dos = []
|
||||||
|
|
|
@ -131,7 +131,7 @@ impl SeedCmd {
|
||||||
info!("begin tower-based peer handling test stub");
|
info!("begin tower-based peer handling test stub");
|
||||||
|
|
||||||
let (addressbook_tx, addressbook_rx) = oneshot::channel();
|
let (addressbook_tx, addressbook_rx) = oneshot::channel();
|
||||||
let seed_service = SeedService {
|
let mut seed_service = SeedService {
|
||||||
state: SeederState::AwaitingAddressBook(addressbook_rx),
|
state: SeederState::AwaitingAddressBook(addressbook_rx),
|
||||||
};
|
};
|
||||||
let node = Buffer::new(seed_service, 1);
|
let node = Buffer::new(seed_service, 1);
|
||||||
|
@ -147,10 +147,10 @@ impl SeedCmd {
|
||||||
|
|
||||||
info!("peer_set became ready");
|
info!("peer_set became ready");
|
||||||
|
|
||||||
#[cfg(dos)]
|
#[cfg(feature = "dos")]
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
|
||||||
#[cfg(dos)]
|
#[cfg(feature = "dos")]
|
||||||
// Fire GetPeers requests at ourselves, for testing.
|
// Fire GetPeers requests at ourselves, for testing.
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
let mut interval_stream = tokio::time::interval(Duration::from_secs(1));
|
let mut interval_stream = tokio::time::interval(Duration::from_secs(1));
|
||||||
|
@ -158,7 +158,7 @@ impl SeedCmd {
|
||||||
loop {
|
loop {
|
||||||
interval_stream.next().await;
|
interval_stream.next().await;
|
||||||
|
|
||||||
let _ = seed_service.call(Request::GetPeers);
|
let _ = seed_service.call(Request::Peers);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue