fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-15 02:51:25 +00:00
Code Issues Projects Releases Wiki Activity

core: Replace debug_assert!s with log messages. (#1222)

Browse Source 
* core: Replace `debug_assert!`s with log messages.

* Remove `cfg!(debug_assertions)`.
This commit is contained in:
Toralf Wittner
2019-08-13 16:46:11 +02:00
committed by Pierre Krieger
parent 2c4b52a545
commit c154771de0
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/nodes/listeners.rs
View File

@ -22,6 +22,7 @@
use crate::{Multiaddr, Transport, transport::{TransportError, ListenerEvent}}; use crate::{Multiaddr, Transport, transport::{TransportError, ListenerEvent}};
use futures::prelude::*; use futures::prelude::*;
use log::{debug, warn};
use smallvec::SmallVec; use smallvec::SmallVec;
use std::{collections::VecDeque, fmt}; use std::{collections::VecDeque, fmt};
use void::Void; use void::Void;
@ -233,9 +234,11 @@ where
if remaining == 0 { break } if remaining == 0 { break }
} }
Ok(Async::Ready(Some(ListenerEvent::Upgrade { upgrade, listen_addr, remote_addr }))) => { Ok(Async::Ready(Some(ListenerEvent::Upgrade { upgrade, listen_addr, remote_addr }))) => {
debug_assert!(listener.addresses.contains(&listen_addr), if !listener.addresses.contains(&listen_addr) {
"Transport reported listen address {} not in the list: {:?}", warn!("Transport reported listen address {} not in the list: {:?}",
listen_addr, listener.addresses); listen_addr,
listener.addresses)
}
let id = listener.id; let id = listener.id;
self.listeners.push_front(listener); self.listeners.push_front(listener);
return Async::Ready(ListenersEvent::Incoming { return Async::Ready(ListenersEvent::Incoming {
@ -246,8 +249,9 @@ where
}) })
} }
Ok(Async::Ready(Some(ListenerEvent::NewAddress(a)))) => { Ok(Async::Ready(Some(ListenerEvent::NewAddress(a)))) => {
debug_assert!(!listener.addresses.contains(&a), if listener.addresses.contains(&a) {
"Transport has reported address {} multiple times", a); debug!("Transport has reported address {} multiple times", a)
}
if !listener.addresses.contains(&a) { if !listener.addresses.contains(&a) {
listener.addresses.push(a.clone()); listener.addresses.push(a.clone());
} }