diff --git a/lightning-net-tokio/src/lib.rs b/lightning-net-tokio/src/lib.rs index 06aed3194f9..5527d85adf6 100644 --- a/lightning-net-tokio/src/lib.rs +++ b/lightning-net-tokio/src/lib.rs @@ -31,10 +31,9 @@ use bitcoin::secp256k1::PublicKey; -use tokio::net::{tcp, TcpStream}; -use tokio::{io, time}; +use tokio::net::TcpStream; +use tokio::time; use tokio::sync::mpsc; -use tokio::io::AsyncWrite; use lightning::ln::peer_handler; use lightning::ln::peer_handler::SocketDescriptor as LnSocketTrait; @@ -231,7 +230,7 @@ impl Connection { // readable() is allowed to spuriously wake, so we have to handle // WouldBlock here. }, - Err(e) => break Disconnect::PeerDisconnected, + Err(_) => break Disconnect::PeerDisconnected, } }, } @@ -493,10 +492,10 @@ impl peer_handler::SocketDescriptor for SocketDescriptor { written_len += res; if written_len == data.len() { return written_len; } }, - Err(e) => return written_len, + Err(_) => return written_len, } }, - task::Poll::Ready(Err(e)) => return written_len, + task::Poll::Ready(Err(_)) => return written_len, task::Poll::Pending => { // We're queued up for a write event now, but we need to make sure we also // pause read given we're now waiting on the remote end to ACK (and in diff --git a/lightning/src/ln/mod.rs b/lightning/src/ln/mod.rs index bacb9e86c79..824550eb3e9 100644 --- a/lightning/src/ln/mod.rs +++ b/lightning/src/ln/mod.rs @@ -13,7 +13,6 @@ #[macro_use] pub mod functional_test_utils; -pub mod channel_id; pub mod channelmanager; pub mod inbound_payment; pub mod msgs; @@ -21,6 +20,7 @@ pub mod peer_handler; pub mod chan_utils; pub mod features; pub mod script; +mod channel_id; #[cfg(fuzzing)] pub mod peer_channel_encryptor; @@ -33,7 +33,7 @@ pub mod channel; pub(crate) mod channel; // Re-export ChannelId -pub use self::channel_id::ChannelId; +pub use channel_id::ChannelId; pub(crate) mod onion_utils; mod outbound_payment; diff --git a/lightning/src/ln/monitor_tests.rs b/lightning/src/ln/monitor_tests.rs index 4af0f41becf..ece24794f63 100644 --- a/lightning/src/ln/monitor_tests.rs +++ b/lightning/src/ln/monitor_tests.rs @@ -2231,7 +2231,7 @@ fn test_anchors_aggregated_revoked_htlc_tx() { assert!(nodes[1].chain_monitor.chain_monitor.get_and_clear_pending_events().is_empty()); let spendable_output_events = nodes[0].chain_monitor.chain_monitor.get_and_clear_pending_events(); assert_eq!(spendable_output_events.len(), 2); - for (idx, event) in spendable_output_events.iter().enumerate() { + for event in spendable_output_events.iter() { if let Event::SpendableOutputs { outputs, channel_id } = event { assert_eq!(outputs.len(), 1); assert!(vec![chan_b.2, chan_a.2].contains(&channel_id.unwrap())); diff --git a/lightning/src/ln/shutdown_tests.rs b/lightning/src/ln/shutdown_tests.rs index 1310d25d476..f105edc19c0 100644 --- a/lightning/src/ln/shutdown_tests.rs +++ b/lightning/src/ln/shutdown_tests.rs @@ -11,7 +11,7 @@ use crate::sign::{EntropySource, SignerProvider}; use crate::chain::transaction::OutPoint; -use crate::events::{Event, MessageSendEvent, MessageSendEventsProvider, ClosureReason}; +use crate::events::{MessageSendEvent, MessageSendEventsProvider, ClosureReason}; use crate::ln::channelmanager::{self, PaymentSendFailure, PaymentId, RecipientOnionFields, ChannelShutdownState, ChannelDetails}; use crate::routing::router::{PaymentParameters, get_route, RouteParameters}; use crate::ln::msgs; diff --git a/lightning/src/util/test_utils.rs b/lightning/src/util/test_utils.rs index 09c99815bb7..785b40befd4 100644 --- a/lightning/src/util/test_utils.rs +++ b/lightning/src/util/test_utils.rs @@ -427,7 +427,7 @@ impl chainmonitor::Persist fo } } -pub(crate) struct TestStore { +pub struct TestStore { persisted_bytes: Mutex>>>, read_only: bool, }