mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-04 21:37:58 +03:00
Code Issues Projects Releases Packages Wiki Activity

Fix op cancelation in poll driver

Browse source
This commit is contained in:
Nikolay Kim 2025-03-14 23:04:33 +05:00
parent ae5980cdd9
commit a83ed4c3fa
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex-net/src/rt_polling/driver.rs
View file

@ -156,6 +156,8 @@ impl<T> Handler for StreamOpsHandler<T> {
if result.is_pending() { if result.is_pending() {
item.flags.insert(Flags::RD); item.flags.insert(Flags::RD);
self.inner.api.register(item.fd, id, Interest::Readable); self.inner.api.register(item.fd, id, Interest::Readable);
} else {
item.flags.remove(Flags::RD);
} }
} }
Change::Writable => { Change::Writable => {
@ -170,6 +172,8 @@ impl<T> Handler for StreamOpsHandler<T> {
if result.is_pending() { if result.is_pending() {
item.flags.insert(Flags::WR); item.flags.insert(Flags::WR);
self.inner.api.register(item.fd, id, Interest::Writable); self.inner.api.register(item.fd, id, Interest::Writable);
} else {
item.flags.remove(Flags::WR);
} }
} }
Change::Error(err) => { Change::Error(err) => {