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

signal: Fix a bug with most recent tokio-core release

Browse Source
This commit is contained in:
Alex Crichton
2018-09-10 11:30:02 -07:00
committed by Carl Lerche
parent 5ecd929b1a
commit 9c9760cfbb
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/unix.rs
+6 -1
View File
@@ -184,7 +184,12 @@ struct EventedReceiver;
impl Evented for EventedReceiver { impl Evented for EventedReceiver {
fn register(&self, poll: &MioPoll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> { fn register(&self, poll: &MioPoll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> {
let fd = globals().receiver.as_raw_fd(); let fd = globals().receiver.as_raw_fd();
EventedFd(&fd).register(poll, token, events, opts) match EventedFd(&fd).register(poll, token, events, opts) {
Ok(()) => Ok(()),
// Due to tokio-rs/tokio-core#307
Err(ref e) if e.kind() == io::ErrorKind::AlreadyExists => Ok(()),
Err(e) => Err(e),
}
} }
fn reregister(&self, poll: &MioPoll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> { fn reregister(&self, poll: &MioPoll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> {
let fd = globals().receiver.as_raw_fd(); let fd = globals().receiver.as_raw_fd();