From b9738db087588670a094050a7a7398bfa2454aea Mon Sep 17 00:00:00 2001 From: ghassmo Date: Wed, 13 Apr 2022 08:08:01 +0400 Subject: [PATCH] src/net: keep importing dependencies in order --- src/net/acceptor.rs | 11 ++++++----- src/net/channel.rs | 21 +++++++++++---------- src/net/connector.rs | 10 +++++----- src/net/message.rs | 3 ++- src/net/message_subscriber.rs | 3 ++- src/net/p2p.rs | 15 ++++++++------- src/net/protocol/mod.rs | 2 +- src/net/protocol/protocol_address.rs | 2 +- 8 files changed, 36 insertions(+), 31 deletions(-) diff --git a/src/net/acceptor.rs b/src/net/acceptor.rs index d3a0b30f3..770fd6b6c 100644 --- a/src/net/acceptor.rs +++ b/src/net/acceptor.rs @@ -1,17 +1,18 @@ -use log::*; -use smol::{Async, Executor}; use std::{ net::{SocketAddr, TcpListener}, sync::Arc, }; -use crate::error::{Error, Result}; -//use crate::net::error::{, Result}; +use log::*; +use smol::{Async, Executor}; + use crate::{ - net::{Channel, ChannelPtr}, system::{StoppableTask, StoppableTaskPtr, Subscriber, SubscriberPtr, Subscription}, + Error, Result, }; +use super::{Channel, ChannelPtr}; + /// Atomic pointer to Acceptor class. pub type AcceptorPtr = Arc; diff --git a/src/net/channel.rs b/src/net/channel.rs index 4ceab7dfb..b93a073a5 100644 --- a/src/net/channel.rs +++ b/src/net/channel.rs @@ -1,9 +1,4 @@ use async_std::sync::Mutex; -use futures::{ - io::{ReadHalf, WriteHalf}, - AsyncReadExt, -}; -use serde_json::json; use std::{ net::{SocketAddr, TcpStream}, sync::{ @@ -12,16 +7,22 @@ use std::{ }, }; +use futures::{ + io::{ReadHalf, WriteHalf}, + AsyncReadExt, +}; use log::{debug, error, info}; +use serde_json::json; use smol::{Async, Executor}; use crate::{ - error::{Error, Result}, - net::{ - message, - message_subscriber::{MessageSubscription, MessageSubsystem}, - }, system::{StoppableTask, StoppableTaskPtr, Subscriber, SubscriberPtr, Subscription}, + Error, Result, +}; + +use super::{ + message, + message_subscriber::{MessageSubscription, MessageSubsystem}, }; /// Atomic pointer to async channel. diff --git a/src/net/connector.rs b/src/net/connector.rs index 902c66195..e3762eafa 100644 --- a/src/net/connector.rs +++ b/src/net/connector.rs @@ -1,14 +1,14 @@ use async_std::future::timeout; -use smol::Async; use std::{ net::{SocketAddr, TcpStream}, time::Duration, }; -use crate::{ - error::{Error, Result}, - net::{Channel, ChannelPtr, SettingsPtr}, -}; +use smol::Async; + +use crate::{Error, Result}; + +use super::{Channel, ChannelPtr, SettingsPtr}; /// Create outbound socket connections. pub struct Connector { diff --git a/src/net/message.rs b/src/net/message.rs index 594cd18c0..5675144cf 100644 --- a/src/net/message.rs +++ b/src/net/message.rs @@ -1,6 +1,7 @@ +use std::{io, net::SocketAddr}; + use futures::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt}; use log::debug; -use std::{io, net::SocketAddr}; use crate::{ util::serial::{Decodable, Encodable, VarInt}, diff --git a/src/net/message_subscriber.rs b/src/net/message_subscriber.rs index 45c2af833..7c2c4c621 100644 --- a/src/net/message_subscriber.rs +++ b/src/net/message_subscriber.rs @@ -7,11 +7,12 @@ use log::{debug, error, warn}; use rand::Rng; use crate::{ - net::message::Message, util::serial::{Decodable, Encodable}, Error, Result, }; +use super::message::Message; + /// 64bit identifier for message subscription. pub type MessageSubscriptionId = u64; type MessageResult = Result>; diff --git a/src/net/p2p.rs b/src/net/p2p.rs index 39d96e0c0..1ac955ea8 100644 --- a/src/net/p2p.rs +++ b/src/net/p2p.rs @@ -7,14 +7,15 @@ use log::debug; use serde_json::json; use crate::{ - error::{Error, Result}, - net::{ - message::Message, - protocol::{register_default_protocols, ProtocolRegistry}, - session::{InboundSession, ManualSession, OutboundSession, SeedSession, Session}, - Channel, ChannelPtr, Hosts, HostsPtr, Settings, SettingsPtr, - }, system::{Subscriber, SubscriberPtr, Subscription}, + Error, Result, +}; + +use super::{ + message::Message, + protocol::{register_default_protocols, ProtocolRegistry}, + session::{InboundSession, ManualSession, OutboundSession, SeedSession, Session}, + Channel, ChannelPtr, Hosts, HostsPtr, Settings, SettingsPtr, }; /// List of channels that are awaiting connection. diff --git a/src/net/protocol/mod.rs b/src/net/protocol/mod.rs index 4175ba769..7746fbc84 100644 --- a/src/net/protocol/mod.rs +++ b/src/net/protocol/mod.rs @@ -58,7 +58,7 @@ pub use protocol_version::ProtocolVersion; pub use protocol_base::{ProtocolBase, ProtocolBasePtr}; pub use protocol_registry::ProtocolRegistry; -use crate::net::{ +use super::{ session::{SESSION_ALL, SESSION_SEED}, P2pPtr, }; diff --git a/src/net/protocol/protocol_address.rs b/src/net/protocol/protocol_address.rs index fa98cfd4c..863528415 100644 --- a/src/net/protocol/protocol_address.rs +++ b/src/net/protocol/protocol_address.rs @@ -5,13 +5,13 @@ use log::debug; use smol::Executor; use crate::{ - error::Result, net::{ message, message_subscriber::MessageSubscription, protocol::{ProtocolBase, ProtocolBasePtr, ProtocolJobsManager, ProtocolJobsManagerPtr}, ChannelPtr, HostsPtr, P2pPtr, }, + Result, }; /// Defines address and get-address messages.