github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-27 08:08:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

Revert "fix(net): batch P2PStream sends" (#11658)

Browse Source
This commit is contained in:
Matthias Seitz
2024-10-11 14:17:07 +02:00
committed by GitHub
parent c4411991e1
commit 6d3aa5a0d5
1 changed files with 7 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -614,24 +614,19 @@ where
/// Returns `Poll::Ready(Ok(()))` when no buffered items remain.
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
let mut this = self.project();
let poll_res = loop {
match this.inner.as_mut().poll_ready(cx) {
Poll::Pending => break Poll::Pending,
Poll::Ready(Err(err)) => break Poll::Ready(Err(err.into())),
Poll::Ready(Ok(())) => {
loop {
match ready!(this.inner.as_mut().poll_flush(cx)) {
Err(err) => return Poll::Ready(Err(err.into())),
Ok(()) => {
let Some(message) = this.outgoing_messages.pop_front() else {
break Poll::Ready(Ok(()))
return Poll::Ready(Ok(()))
};
if let Err(err) = this.inner.as_mut().start_send(message) {
break Poll::Ready(Err(err.into()))
return Poll::Ready(Err(err.into()))
}
}
}
};
ready!(this.inner.as_mut().poll_flush(cx))?;
poll_res
}
}
fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {