nordic-dev.net/embassy
2
0
Fork 0
mirror of https://github.com/embassy-rs/embassy.git synced 2024-11-22 06:42:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

net/tcp: fix flush() waiting forever if socket is reset with pending write data

Browse Source
This commit is contained in:
Samuel Hicks 2024-07-19 17:45:29 +01:00
parent 2766993099
commit e6f4db507d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
embassy-net/src/tcp.rs
View File

@ -515,7 +515,7 @@ impl<'d> TcpIo<'d> {
async fn flush(&mut self) -> Result<(), Error> { async fn flush(&mut self) -> Result<(), Error> {
poll_fn(move |cx| { poll_fn(move |cx| {
self.with_mut(|s, _| { self.with_mut(|s, _| {
let data_pending = s.send_queue() > 0; let data_pending = (s.send_queue() > 0) && s.state() != tcp::State::Closed;
let fin_pending = matches!( let fin_pending = matches!(
s.state(), s.state(),
tcp::State::FinWait1 | tcp::State::Closing | tcp::State::LastAck tcp::State::FinWait1 | tcp::State::Closing | tcp::State::LastAck