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

Cosmetic changes

This commit is contained in:
Stjepan Glavina 2020-06-21 13:48:26 +02:00
parent a68e0ac95e
commit 68272435b8
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/reactor.rs
View File

@ -388,6 +388,7 @@ impl Source {
future::poll_fn(|cx| { future::poll_fn(|cx| {
let mut wakers = self.wakers.lock(); let mut wakers = self.wakers.lock();
// Check if the reactor has delivered a readability event.
if let Some(tick) = tick { if let Some(tick) = tick {
if wakers.tick_readable > tick { if wakers.tick_readable > tick {
return Poll::Ready(Ok(())); return Poll::Ready(Ok(()));
@ -409,7 +410,7 @@ impl Source {
wakers.readers.push(cx.waker().clone()); wakers.readers.push(cx.waker().clone());
} }
// Remember the current tick. // Remember the current reactor tick.
if tick.is_none() { if tick.is_none() {
tick = Some(Reactor::get().ticker.load(Ordering::SeqCst)); tick = Some(Reactor::get().ticker.load(Ordering::SeqCst));
} }
@ -426,6 +427,7 @@ impl Source {
future::poll_fn(|cx| { future::poll_fn(|cx| {
let mut wakers = self.wakers.lock(); let mut wakers = self.wakers.lock();
// Check if the reactor has delivered a writability event.
if let Some(tick) = tick { if let Some(tick) = tick {
if wakers.tick_writable > tick { if wakers.tick_writable > tick {
return Poll::Ready(Ok(())); return Poll::Ready(Ok(()));
@ -447,7 +449,7 @@ impl Source {
wakers.writers.push(cx.waker().clone()); wakers.writers.push(cx.waker().clone());
} }
// Remember the current tick. // Remember the current reactor tick.
if tick.is_none() { if tick.is_none() {
tick = Some(Reactor::get().ticker.load(Ordering::SeqCst)); tick = Some(Reactor::get().ticker.load(Ordering::SeqCst));
} }
@ -528,8 +530,8 @@ mod sys {
} }
pub fn iter(&self) -> impl Iterator<Item = Event> + '_ { pub fn iter(&self) -> impl Iterator<Item = Event> + '_ {
self.list[..self.len].iter().map(|ev| Event { self.list[..self.len].iter().map(|ev| Event {
readable: (ev.events() & read_flags()) > 0, readable: (ev.events() & read_flags()) != 0,
writable: (ev.events() & write_flags()) > 0, writable: (ev.events() & write_flags()) != 0,
key: ev.data() as usize, key: ev.data() as usize,
}) })
} }