use fcntl to set the O_NONBLOCK flag

Cargo.toml

@@ -9,7 +9,7 @@ edition = "2021"
 ahash = "0.8.3"
 futures-lite = "1.13.0"
 iou = "0.3.3"
-nix = { version = "0.27.1", features = ["sched"] }
+nix = { version = "0.27.1", features = ["sched", "fs"] }
 
 polling = "2.8.0"
 scoped-tls = "1.0.1"

src/executor/local_executor_test.rs

@@ -24,6 +24,7 @@ fn simple_spawn() {
 
 #[test]
 fn local_executor_builder_placement() {
+    // The LocalExecutor will now only run on Cpu 0
     let builder = LocalExecutorBuilder::new(Placement::Fixed(0));
     let local_ex = builder.build();
     let res = local_ex.run(async {

src/net/async_networking.rs

@@ -9,7 +9,6 @@ impl Async<TcpListener> {
     pub fn bind<A: Into<SocketAddr>>(addr: A) -> io::Result<Async<TcpListener>> {
         let addr = addr.into();
         let listener = TcpListener::bind(addr)?;
-        listener.set_nonblocking(true).unwrap();
         Ok(Async::new(listener)?)
     }
 

src/reactor.rs

@@ -1,5 +1,7 @@
 use std::{io, os::fd::RawFd};
 
+use nix::fcntl::{self, fcntl, FcntlArg, OFlag};
+
 use crate::{
     executor::executor,
     sys::{self, source::Source, SourceType},
@@ -29,6 +31,7 @@ impl Reactor {
     }
 
     pub fn insert_pollable_io(&self, raw: RawFd) -> Source {
+        fcntl(raw, FcntlArg::F_SETFL(OFlag::O_NONBLOCK)).unwrap();
         self.new_source(raw, SourceType::PollableFd)
     }