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

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-28 20:58:35 +01:00
parent da46ac20e2
commit aee20c0710
3 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ntex-net/Cargo.toml
View file

@ -40,7 +40,7 @@ ntex-util = "2.5"
ntex-tokio = { version = "0.5.3", optional = true }
ntex-compio = { version = "0.2.4", optional = true }
ntex-neon = { version = "0.1.14", optional = true }
ntex-neon = { version = "0.1.15", optional = true }
bitflags = { workspace = true }
cfg-if = { workspace = true }

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

@ -105,11 +105,10 @@ impl<T> Handler for StreamOpsHandler<T> {
return;
}
let item = &mut streams[id];
log::debug!("{}: FD event {:?} event: {:?}", item.tag(), id, ev);
if item.io.is_none() {
return;
}
log::debug!("{}: FD event {:?} event: {:?}", item.tag(), id, ev);
// handle HUP
if ev.is_interrupt() {

2
ntex-server/src/manager.rs
View file

@ -180,7 +180,7 @@ impl<F: ServerConfiguration> HandleCmdState<F> {
fn process(&mut self, mut item: F::Item) {
loop {
if !self.workers.is_empty() {
if self.next > self.workers.len() {
if self.next >= self.workers.len() {
self.next = self.workers.len() - 1;
}
match self.workers[self.next].send(item) {