diff options
| author | Jeff Olson <olson.jeffery@gmail.com> | 2013-07-22 15:28:32 -0700 |
|---|---|---|
| committer | Jeff Olson <olson.jeffery@gmail.com> | 2013-07-22 15:28:32 -0700 |
| commit | 3169bb70d8bef4fea776916f900bf9e407e6469c (patch) | |
| tree | c87c0ccef690bc03a45cf871eea680993f6f6d0c /src/libstd/rt | |
| parent | 73ab6c60f37263871a5e69f3eeaad72f0d804a02 (diff) | |
| download | rust-3169bb70d8bef4fea776916f900bf9e407e6469c.tar.gz rust-3169bb70d8bef4fea776916f900bf9e407e6469c.zip | |
std: fix for blocked task resume
Diffstat (limited to 'src/libstd/rt')
| -rw-r--r-- | src/libstd/rt/uv/uvio.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/libstd/rt/uv/uvio.rs b/src/libstd/rt/uv/uvio.rs index 4ecfa463284..9c386b4bed1 100644 --- a/src/libstd/rt/uv/uvio.rs +++ b/src/libstd/rt/uv/uvio.rs @@ -582,7 +582,7 @@ impl Drop for UvTimer { let task_cell = Cell::new(task); do self.close { let scheduler = Local::take::<Scheduler>(); - scheduler.resume_task_immediately(task_cell.take()); + scheduler.resume_blocked_task_immediately(task_cell.take()); } } } @@ -600,7 +600,7 @@ impl RtioTimer for UvTimer { do watcher.start(msecs, 0) |_, status| { assert!(status.is_none()); let scheduler = Local::take::<Scheduler>(); - scheduler.resume_task_immediately(task_cell.take()); + scheduler.resume_blocked_task_immediately(task_cell.take()); } } let mut w = **self; |