safe-async/foxtrot
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Add prints for failing to own io resource

Browse source
This commit is contained in:
Aode (lion) 2022-03-05 14:03:11 -06:00
parent 8364de60d1
commit c4601b38e9
1 changed files with 11 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
src/io.rs
View file

@ -157,6 +157,8 @@ impl<T: AsFd + 'static> Async<T> {
{
if let Some(io) = self.io.ensure_owned() {
poll_std!(std::io::Read::read(io, buf))
} else {
println!("Read: Failed to own");
}
ReactorRef::with(|mut reactor| {
@ -207,6 +209,8 @@ impl<T: AsFd + 'static> Async<T> {
{
if let Some(io) = self.io.ensure_owned() {
poll_std!(std::io::Write::write(io, buf))
} else {
println!("Write: Failed to own");
}
ReactorRef::with(|mut reactor| {
@ -315,9 +319,7 @@ where
cx: &mut Context<'_>,
buf: &mut [u8],
) -> Poll<Result<usize>> {
self.get_mut()
.futures_poll_read(cx, buf)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_read(cx, buf)
}
}
@ -327,21 +329,15 @@ where
T: std::io::Write + AsFd + Unpin,
{
fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> Poll<Result<usize>> {
self.get_mut()
.futures_poll_write(cx, buf)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_write(cx, buf)
}
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
self.get_mut()
.futures_poll_flush(cx)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_flush(cx)
}
fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
self.get_mut()
.futures_poll_flush(cx)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_flush(cx)
}
}
@ -351,21 +347,15 @@ where
T: std::io::Write + AsFd + Unpin,
{
fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> Poll<Result<usize>> {
self.get_mut()
.futures_poll_write(cx, buf)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_write(cx, buf)
}
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
self.get_mut()
.futures_poll_flush(cx)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_flush(cx)
}
fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>> {
self.get_mut()
.futures_poll_flush(cx)
.map(|res| res.map_err(From::from))
self.get_mut().futures_poll_flush(cx)
}
}