Merge pull request #413 from duarten/feature/reactor-split

Move the Reactor to its own module

glommio/src/channels/shared_channel.rs

@@ -7,7 +7,7 @@
 use crate::{
     channels::spsc_queue::{make, BufferHalf, Consumer, Producer},
     enclose,
-    parking::Reactor,
+    reactor::Reactor,
     sys::{self, SleepNotifier},
     GlommioError,
     Local,

glommio/src/executor/mod.rs

@@ -57,6 +57,7 @@ use scoped_tls::scoped_thread_local;
 use crate::{
     error::BuilderErrorKind,
     parking,
+    reactor,
     sys,
     task::{self, waker_fn::dummy_waker},
     GlommioError,
@@ -852,7 +853,7 @@ pub struct LocalExecutor {
     queues: Rc<RefCell<ExecutorQueues>>,
     parker: parking::Parker,
     id: usize,
-    reactor: Rc<parking::Reactor>,
+    reactor: Rc<reactor::Reactor>,
 }
 
 impl LocalExecutor {
@@ -899,7 +900,7 @@ impl LocalExecutor {
             queues: Rc::new(RefCell::new(queues)),
             parker: p,
             id: notifier.id(),
-            reactor: Rc::new(parking::Reactor::new(notifier, io_memory)),
+            reactor: Rc::new(reactor::Reactor::new(notifier, io_memory)),
         })
     }
 
@@ -1389,7 +1390,7 @@ impl<T> Task<T> {
     }
 
     #[inline]
-    pub(crate) fn get_reactor() -> Rc<parking::Reactor> {
+    pub(crate) fn get_reactor() -> Rc<reactor::Reactor> {
         LOCAL_EX.with(|local_ex| local_ex.get_reactor())
     }
 

glommio/src/io/buffered_file_stream.rs

@@ -5,7 +5,7 @@
 
 use crate::{
     io::{BufferedFile, ScheduledSource},
-    parking::Reactor,
+    reactor::Reactor,
     sys::{IoBuffer, Source},
     Local,
 };

glommio/src/io/glommio_file.rs

@@ -4,7 +4,7 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2020 Datadog, Inc.
 //
 
-use crate::{io::sched::FileScheduler, parking::Reactor, sys, GlommioError, Local};
+use crate::{io::sched::FileScheduler, reactor::Reactor, sys, GlommioError, Local};
 use log::debug;
 use std::{
     cell::{Ref, RefCell},

glommio/src/lib.rs

@@ -298,7 +298,7 @@ extern crate lazy_static;
 #[macro_use(defer)]
 extern crate scopeguard;
 
-use crate::parking::Reactor;
+use crate::reactor::Reactor;
 use std::{fmt::Debug, time::Duration};
 
 /// Call `Waker::wake()` and log to `error` if panicked.
@@ -319,6 +319,7 @@ mod free_list;
 #[allow(clippy::upper_case_acronyms)]
 mod iou;
 mod parking;
+mod reactor;
 mod sys;
 pub mod task;
 

glommio/src/net/stream.rs

@@ -4,7 +4,7 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2020 Datadog, Inc.
 //
 use crate::{
-    parking::Reactor,
+    reactor::Reactor,
     sys::{self, DmaBuffer, Source, SourceType},
     ByteSliceMutExt,
     Local,

glommio/src/net/tcp_socket.rs

@@ -4,7 +4,7 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2020 Datadog, Inc.
 //
 use super::stream::GlommioStream;
-use crate::{net::yolo_accept, parking::Reactor, GlommioError, Local};
+use crate::{net::yolo_accept, reactor::Reactor, GlommioError, Local};
 use futures_lite::{
     future::poll_fn,
     io::{AsyncBufRead, AsyncRead, AsyncWrite},

glommio/src/net/unix.rs

@@ -4,7 +4,7 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2020 Datadog, Inc.
 //
 use super::{datagram::GlommioDatagram, stream::GlommioStream};
-use crate::{parking::Reactor, Local};
+use crate::{reactor::Reactor, Local};
 use futures_lite::{
     future::poll_fn,
     io::{AsyncBufRead, AsyncRead, AsyncWrite},

glommio/src/nop.rs

@@ -5,7 +5,7 @@ use std::{
     rc::{Rc, Weak},
 };
 
-use crate::{parking::Reactor, Local};
+use crate::{reactor::Reactor, Local};
 
 /// Submit no-op operations to io_uring.
 ///