scheduler: call timeAdvanced
This commit is contained in:
@@ -226,10 +226,12 @@ fn findBlockedTaskWithLowestWakeupTime(self: *Scheduler) ?*Task {
|
|||||||
|
|
||||||
fn advanceTimeAndUnblockTasks(self: *Scheduler, new_time: u64) void {
|
fn advanceTimeAndUnblockTasks(self: *Scheduler, new_time: u64) void {
|
||||||
std.debug.assert(self.current_time < new_time);
|
std.debug.assert(self.current_time < new_time);
|
||||||
|
const old_time = self.current_time;
|
||||||
self.current_time = new_time;
|
self.current_time = new_time;
|
||||||
for (self.tasks.items) |task| {
|
for (self.tasks.items) |task| {
|
||||||
task.node.local_time = @max(task.node.local_time, new_time);
|
task.node.local_time = @max(task.node.local_time, new_time);
|
||||||
}
|
}
|
||||||
|
self.trace.timeAdvanced(old_time, new_time);
|
||||||
for (self.tasks.items) |*task| {
|
for (self.tasks.items) |*task| {
|
||||||
if (task.state == .blocked) {
|
if (task.state == .blocked) {
|
||||||
if (task.wakeup_time) |wakeup_time| {
|
if (task.wakeup_time) |wakeup_time| {
|
||||||
|
|||||||
Reference in New Issue
Block a user