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

Fix compile of minihttp on stable

Browse Source
This commit is contained in:
Alex Crichton
2016-08-05 09:25:40 -07:00
parent e7f4313cf4
commit 5d0fdf26a9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/event_loop.rs
+3 -3
View File
@@ -212,7 +212,7 @@ impl Loop {
// it, and we also or-in atomically any events that have // it, and we also or-in atomically any events that have
// happened (currently read/write events). // happened (currently read/write events).
let mut waiter = None; let mut waiter = None;
if let Some(sched) = self.dispatch.get_mut().get_mut(token) { if let Some(sched) = self.dispatch.borrow_mut().get_mut(token) {
waiter = sched.waiter.take(); waiter = sched.waiter.take();
if event.kind().is_readable() { if event.kind().is_readable() {
sched.source.readiness.fetch_or(1, Ordering::Relaxed); sched.source.readiness.fetch_or(1, Ordering::Relaxed);
@@ -237,9 +237,9 @@ impl Loop {
} }
fn consume_timeouts(&mut self, now: Instant) { fn consume_timeouts(&mut self, now: Instant) {
while let Some(idx) = self.timer_wheel.get_mut().poll(now) { while let Some(idx) = self.timer_wheel.borrow_mut().poll(now) {
trace!("firing timeout: {}", idx); trace!("firing timeout: {}", idx);
let handle = self.timeouts.get_mut()[idx].1.fire(); let handle = self.timeouts.borrow_mut()[idx].1.fire();
if let Some(handle) = handle { if let Some(handle) = handle {
self.notify_handle(handle); self.notify_handle(handle);
} }