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

Check service readiness for every turn

Browse source
This commit is contained in:
Nikolay Kim 2024-12-04 15:23:20 +05:00
parent e33149df1b
commit e222832270
3 changed files with 6 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex-io/CHANGES.md
View file

@ -1,5 +1,9 @@
# Changes
## [2.9.1] - 2024-12-04
* Check service readiness for every turn
## [2.9.0] - 2024-12-04
* Use updated Service trait

2
ntex-io/Cargo.toml
View file

@ -1,6 +1,6 @@
[package]
name = "ntex-io"
version = "2.9.0"
version = "2.9.1"
authors = ["ntex contributors <team@ntex.rs>"]
description = "Utilities for encoding and decoding frames"
keywords = ["network", "framework", "async", "futures"]

12
ntex-io/src/dispatcher.rs
View file

@ -160,7 +160,6 @@ where
service: PipelineBinding<S, DispatchItem<U>>,
error: Cell<Option<DispatcherError<S::Error, <U as Encoder>::Error>>>,
inflight: Cell<u32>,
ready: Cell<bool>,
}
#[derive(Copy, Clone, Debug)]
@ -222,7 +221,6 @@ where
codec,
error: Cell::new(None),
inflight: Cell::new(0),
ready: Cell::new(false),
service: Pipeline::new(service.into_service()).bind(),
});
@ -343,7 +341,6 @@ where
PollService::Continue => continue,
};
slf.shared.ready.set(false);
slf.call_service(cx, item);
}
// handle write back-pressure
@ -473,16 +470,9 @@ where
}
fn poll_service(&mut self, cx: &mut Context<'_>) -> Poll<PollService<U>> {
if self.shared.ready.get() {
return Poll::Ready(self.check_error());
}
// wait until service becomes ready
match self.shared.service.poll_ready(cx) {
Poll::Ready(Ok(_)) => {
self.shared.ready.set(true);
Poll::Ready(self.check_error())
}
Poll::Ready(Ok(_)) => Poll::Ready(self.check_error()),
// pause io read task
Poll::Pending => {
log::trace!(