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

It is not required to close compio sockets explicitly #444 (#446)

Browse source
This commit is contained in:
Nikolay Kim 2024-10-31 16:21:20 +05:00 • committed by GitHub
parent fc67031a3a
commit d8f2c87781
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 8 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex-compio/CHANGES.md
View file

@ -1,5 +1,9 @@
# Changes # Changes
## [0.2.1] - 2024-10-31
* It's not required to close compio sockets explicitly #444
## [0.2.0] - 2024-09-24 ## [0.2.0] - 2024-09-24
* Update to compio v0.12 * Update to compio v0.12

2
ntex-compio/Cargo.toml
View file

@ -1,6 +1,6 @@
[package] [package]
name = "ntex-compio" name = "ntex-compio"
version = "0.2.0" version = "0.2.1"
authors = ["ntex contributors <team@ntex.rs>"] authors = ["ntex contributors <team@ntex.rs>"]
description = "compio runtime intergration for ntex framework" description = "compio runtime intergration for ntex framework"
keywords = ["network", "framework", "async", "futures"] keywords = ["network", "framework", "async", "futures"]

19
ntex-compio/src/io.rs
View file

@ -9,14 +9,7 @@ use ntex_io::{types, Handle, IoStream, ReadContext, WriteContext, WriteContextBu
impl IoStream for crate::TcpStream { impl IoStream for crate::TcpStream {
fn start(self, read: ReadContext, write: WriteContext) -> Option<Box<dyn Handle>> { fn start(self, read: ReadContext, write: WriteContext) -> Option<Box<dyn Handle>> {
let io = self.0.clone(); let io = self.0.clone();
compio::runtime::spawn(async move { compio::runtime::spawn(async move { run(io.clone(), &read, write).await }).detach();
run(io.clone(), &read, write).await;
match io.close().await {
Ok(_) => log::debug!("{} Stream is closed", read.tag()),
Err(e) => log::error!("{} Stream is closed, {:?}", read.tag(), e),
}
})
.detach();
Some(Box::new(HandleWrapper(self.0))) Some(Box::new(HandleWrapper(self.0)))
} }
@ -25,14 +18,8 @@ impl IoStream for crate::TcpStream {
#[cfg(unix)] #[cfg(unix)]
impl IoStream for crate::UnixStream { impl IoStream for crate::UnixStream {
fn start(self, read: ReadContext, write: WriteContext) -> Option<Box<dyn Handle>> { fn start(self, read: ReadContext, write: WriteContext) -> Option<Box<dyn Handle>> {
compio::runtime::spawn(async move { compio::runtime::spawn(async move { run(self.0.clone(), &read, write).await })
run(self.0.clone(), &read, write).await; .detach();
match self.0.close().await {
Ok(_) => log::debug!("{} Unix stream is closed", read.tag()),
Err(e) => log::error!("{} Unix stream is closed, {:?}", read.tag(), e),
}
})
.detach();
None None
} }