std: fix for blocked task resume
This commit is contained in:
parent
73ab6c60f3
commit
3169bb70d8
@ -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;
|
||||
|
Loading…
x
Reference in New Issue
Block a user