mod behaviour;
pub mod compress;
pub mod errors;
pub mod network;
mod network_group;
mod peer;
pub mod peer_registry;
pub mod peer_store;
mod protocols;
mod services;
#[cfg(test)]
mod tests;
pub use crate::{
behaviour::Behaviour,
errors::Error,
network::{
DefaultExitHandler, EventHandler, ExitHandler, NetworkController, NetworkService,
NetworkState,
},
peer::{Peer, PeerIdentifyInfo},
peer_registry::PeerRegistry,
peer_store::Score,
protocols::{
identify::Flags, support_protocols::SupportProtocols, CKBProtocol, CKBProtocolContext,
CKBProtocolHandler, PeerIndex,
},
};
pub use p2p::{
async_trait,
builder::ServiceBuilder,
bytes, multiaddr,
secio::{PeerId, PublicKey},
service::{ServiceControl, SessionType, TargetProtocol, TargetSession},
traits::ServiceProtocol,
utils::{extract_peer_id, multiaddr_to_socketaddr},
ProtocolId, SessionId,
};
pub use tokio;
pub type ProtocolVersion = String;
pub async fn observe_listen_port_occupancy(
_addrs: &[multiaddr::MultiAddr],
) -> Result<(), std::io::Error> {
#[cfg(target_os = "linux")]
{
use p2p::utils::dns::DnsResolver;
use std::net::{SocketAddr, TcpListener};
for raw_addr in _addrs {
let ip_addr: Option<SocketAddr> = match DnsResolver::new(raw_addr.clone()) {
Some(dns) => dns.await.ok().as_ref().and_then(multiaddr_to_socketaddr),
None => multiaddr_to_socketaddr(raw_addr),
};
if let Some(addr) = ip_addr {
if let Err(e) = TcpListener::bind(addr) {
ckb_logger::error!(
"addr {} can't use on your machines by error: {}, please check",
raw_addr,
e
);
return Err(e);
}
}
}
}
Ok(())
}