rust
/
smol
mirror of https://github.com/stjepang/smol
1
0
Fork 0
Code Issues Releases Wiki Activity

Check for EINPROGRESS in UnixStream::connect

This commit is contained in:
Stjepan Glavina 2020-05-07 16:36:10 +02:00
parent 34fcc57a7f
commit ef701a4128
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/async_io.rs
View File

@ -22,14 +22,13 @@ use std::{
use futures::future;
use futures::io::{AsyncRead, AsyncWrite};
use futures::stream::{self, Stream};
#[cfg(unix)]
use nix::libc;
use socket2::{Domain, Protocol, Socket, Type};
use crate::reactor::{Reactor, Source};
use crate::task::Task;
#[cfg(unix)]
use nix::libc;
/// Async I/O.
///
/// This type converts a blocking I/O type into an async type, provided it is supported by
@ -874,12 +873,12 @@ impl Async<UnixStream> {
// Create a socket.
let socket = Socket::new(Domain::unix(), Type::stream(), None)?;
// Begin async connect and ignore the inevitable "not yet connected" error.
// Begin async connect and ignore the inevitable "in progress" error.
socket.set_nonblocking(true)?;
socket
.connect(&socket2::SockAddr::unix(path)?)
.or_else(|err| {
if err.kind() == io::ErrorKind::NotConnected {
if err.raw_os_error() == Some(libc::EINPROGRESS) {
Ok(())
} else {
Err(err)