tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-30 00:00:16 +02:00
Code Issues Packages Projects Releases Wiki Activity

return NotReady when recv_from wouldblock in uds (#452)

Browse Source
This commit is contained in:
Patrick Barrett
2018-07-11 11:37:57 -07:00
committed by Carl Lerche
parent f98b81e527
commit e6fc3d209d
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio-uds/src/datagram.rs
+2
View File
@@ -104,6 +104,7 @@ impl UnixDatagram {
let r = self.io.get_ref().recv_from(buf); let r = self.io.get_ref().recv_from(buf);
if is_wouldblock(&r) { if is_wouldblock(&r) {
self.io.clear_read_ready(Ready::readable())?; self.io.clear_read_ready(Ready::readable())?;
return Ok(Async::NotReady);
} }
r.map(Async::Ready) r.map(Async::Ready)
} }
@@ -118,6 +119,7 @@ impl UnixDatagram {
let r = self.io.get_ref().recv(buf); let r = self.io.get_ref().recv(buf);
if is_wouldblock(&r) { if is_wouldblock(&r) {
self.io.clear_read_ready(Ready::readable())?; self.io.clear_read_ready(Ready::readable())?;
return Ok(Async::NotReady);
} }
r.map(Async::Ready) r.map(Async::Ready)
} }