jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: wake future after buffering pong (#4536)

Browse Source
This commit is contained in:
Dan Cline
2023-09-09 06:27:22 -04:00
committed by GitHub
parent b87dfe507d
commit b151d6ea8d
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/net/eth-wire/src/p2pstream.rs
View File

@ -401,6 +401,9 @@ where
_ if id == P2PMessageID::Ping as u8 => {
tracing::trace!("Received Ping, Sending Pong");
this.send_pong();
// This is required because the `Sink` may not be polled externally, and if
// that happens, the pong will never be sent.
cx.waker().wake_by_ref();
}
_ if id == P2PMessageID::Disconnect as u8 => {
let reason = DisconnectReason::decode(&mut &decompress_buf[1..]).map_err(|err| {