blob: 943d70c9d7845a635641ad2c2037945c3c3e7cfa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
//! Run queue management
const types = @import("../types.zig");
var head: ?*types.Kata = null;
pub fn get_head() ?*types.Kata {
return head;
}
pub fn enqueue(kata: *types.Kata) void {
kata.state = .Alive;
if (head == null) {
head = kata;
kata.next = null;
return;
}
var prev: ?*types.Kata = null;
var current = head;
while (current) |curr| {
if (kata.vruntime < curr.vruntime) {
kata.next = curr;
if (prev) |p| {
p.next = kata;
} else {
head = kata;
}
return;
}
prev = curr;
current = curr.next;
}
if (prev) |p| {
p.next = kata;
kata.next = null;
}
}
pub fn dequeue(kata: *types.Kata) void {
if (head == null) return;
if (head == kata) {
head = kata.next;
kata.next = null;
return;
}
var prev = head;
while (prev) |p| {
if (p.next == kata) {
p.next = kata.next;
kata.next = null;
return;
}
prev = p.next;
}
}
pub fn is_queued(kata: *types.Kata) bool {
var current = head;
while (current) |k| {
if (k == kata) return true;
current = k.next;
}
return false;
}
|
