cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Cleanup network shutdown messages

Browse Source
This commit is contained in:
Age Manning 2019-03-18 18:22:01 +11:00
parent 66f09e1b8e
commit 6a89da43b7
No known key found for this signature in database
GPG Key ID: 05EED64B79E06A93
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
beacon_node/network/src/message_handler.rs
View File

@ -71,7 +71,7 @@ impl MessageHandler {
executor.spawn(future::poll_fn(move || -> Result<_, _> { executor.spawn(future::poll_fn(move || -> Result<_, _> {
loop { loop {
handler.handle_message(handler_recv.recv().map_err(|_| { handler.handle_message(handler_recv.recv().map_err(|_| {
debug!(log, "Handler channel closed. Handler terminating"); debug!(log, "Network message handler terminated.");
})?); })?);
} }
})); }));

4
beacon_node/network/src/service.rs
View File

@ -9,7 +9,7 @@ use futures::sync::oneshot;
use futures::Stream; use futures::Stream;
use libp2p::Service as LibP2PService; use libp2p::Service as LibP2PService;
use libp2p::{Libp2pEvent, PeerId}; use libp2p::{Libp2pEvent, PeerId};
use slog::{debug, o}; use slog::{debug, info, o};
use std::sync::Arc; use std::sync::Arc;
use tokio::runtime::TaskExecutor; use tokio::runtime::TaskExecutor;
@ -80,7 +80,7 @@ fn spawn_service(
// allow for manual termination // allow for manual termination
.select(exit_rx.then(|_| Ok(()))) .select(exit_rx.then(|_| Ok(())))
.then(move |_| { .then(move |_| {
debug!(log.clone(), "Network service ended"); info!(log.clone(), "Network service shutdown");
Ok(()) Ok(())
}), }),
); );