mirrors/rust-lightning
1
0
Fork 0
mirror of https://github.com/lightningdevkit/rust-lightning.git synced 2025-02-24 15:02:20 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix warnings in lightning-net-tokio

Browse source
This commit is contained in:
Elias Rohrer 2023-09-12 13:47:09 +02:00
parent 190867c373
commit ba05f9b3f5
No known key found for this signature in database
GPG key ID: 36153082BDF676FD
1 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lightning-net-tokio/src/lib.rs
View file

@ -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