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

wip

Browse source
This commit is contained in:
Nikolay Kim 2025-03-17 21:54:51 +01:00
parent ca4ceefd0e
commit b231bb9dc4
3 changed files with 4 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ntex-net/CHANGES.md
View file

@ -1,6 +1,6 @@
# Changes # Changes
## [2.5.5] - 2025-03-xx ## [2.5.5] - 2025-03-17
* Add check for required io-uring opcodes * Add check for required io-uring opcodes

2
ntex-net/Cargo.toml
View file

@ -1,6 +1,6 @@
[package] [package]
name = "ntex-net" name = "ntex-net"
version = "2.5.4" version = "2.5.5"
authors = ["ntex contributors <team@ntex.rs>"] authors = ["ntex contributors <team@ntex.rs>"]
description = "ntexwork utils for ntex framework" description = "ntexwork utils for ntex framework"
keywords = ["network", "framework", "async", "futures"] keywords = ["network", "framework", "async", "futures"]

17
ntex-net/src/rt_uring/io.rs
View file

@ -54,19 +54,7 @@ enum Status {
async fn run<T>(ctl: StreamCtl<T>, context: IoContext) { async fn run<T>(ctl: StreamCtl<T>, context: IoContext) {
// Handle io readiness // Handle io readiness
let st = poll_fn(|cx| { let st = poll_fn(|cx| {
let read_st = context.poll_read_ready(cx); let read = match context.poll_read_ready(cx) {
let write_st = context.poll_write_ready(cx);
// log::debug!(
// "{}: io ctl read: {:?} write: {:?}, flags: {:?}",
// context.tag(),
// read_st,
// write_st,
// context.flags()
// );
//let read = match context.poll_read_ready(cx) {
let read = match read_st {
Poll::Ready(ReadStatus::Ready) => { Poll::Ready(ReadStatus::Ready) => {
ctl.resume_read(); ctl.resume_read();
Poll::Pending Poll::Pending
@ -78,8 +66,7 @@ async fn run<T>(ctl: StreamCtl<T>, context: IoContext) {
} }
}; };
// let write = match context.poll_write_ready(cx) { let write = match context.poll_write_ready(cx) {
let write = match write_st {
Poll::Ready(WriteStatus::Ready) => { Poll::Ready(WriteStatus::Ready) => {
ctl.resume_write(); ctl.resume_write();
Poll::Pending Poll::Pending