diff options
author | Andrea Bastoni <bastoni@cs.unc.edu> | 2009-12-21 12:23:57 -0500 |
---|---|---|
committer | Andrea Bastoni <bastoni@cs.unc.edu> | 2010-05-29 17:20:00 -0400 |
commit | ee09f78d8faa0b988088d93142e6f5f8a6e75394 (patch) | |
tree | bc1e0b5db121be3de47d967973310d610ad943a2 /litmus | |
parent | 0b28a3122d6917784701377e15a863489aee1c6c (diff) |
Refactor binomial heap names: heap -> bheap
- Binomial heap "heap" names conflicted with priority heap
of cgroup in kernel
- This patch change binomial heap "heap" names in "bheap"
Diffstat (limited to 'litmus')
-rw-r--r-- | litmus/Makefile | 2 | ||||
-rw-r--r-- | litmus/bheap.c (renamed from litmus/heap.c) | 128 | ||||
-rw-r--r-- | litmus/edf_common.c | 4 | ||||
-rw-r--r-- | litmus/litmus.c | 26 | ||||
-rw-r--r-- | litmus/rt_domain.c | 22 | ||||
-rw-r--r-- | litmus/sched_gsn_edf.c | 38 |
6 files changed, 110 insertions, 110 deletions
diff --git a/litmus/Makefile b/litmus/Makefile index b15e65ee7f37..70c9684c3b98 100644 --- a/litmus/Makefile +++ b/litmus/Makefile | |||
@@ -10,7 +10,7 @@ obj-y = sched_plugin.o litmus.o \ | |||
10 | fdso.o \ | 10 | fdso.o \ |
11 | srp.o \ | 11 | srp.o \ |
12 | fmlp.o \ | 12 | fmlp.o \ |
13 | heap.o \ | 13 | bheap.o \ |
14 | sched_gsn_edf.o | 14 | sched_gsn_edf.o |
15 | 15 | ||
16 | obj-$(CONFIG_FEATHER_TRACE) += ft_event.o ftdev.o | 16 | obj-$(CONFIG_FEATHER_TRACE) += ft_event.o ftdev.o |
diff --git a/litmus/heap.c b/litmus/bheap.c index 112d14da46c3..528af97f18a6 100644 --- a/litmus/heap.c +++ b/litmus/bheap.c | |||
@@ -1,15 +1,15 @@ | |||
1 | #include "linux/kernel.h" | 1 | #include "linux/kernel.h" |
2 | #include "litmus/heap.h" | 2 | #include "litmus/bheap.h" |
3 | 3 | ||
4 | void heap_init(struct heap* heap) | 4 | void bheap_init(struct bheap* heap) |
5 | { | 5 | { |
6 | heap->head = NULL; | 6 | heap->head = NULL; |
7 | heap->min = NULL; | 7 | heap->min = NULL; |
8 | } | 8 | } |
9 | 9 | ||
10 | void heap_node_init(struct heap_node** _h, void* value) | 10 | void bheap_node_init(struct bheap_node** _h, void* value) |
11 | { | 11 | { |
12 | struct heap_node* h = *_h; | 12 | struct bheap_node* h = *_h; |
13 | h->parent = NULL; | 13 | h->parent = NULL; |
14 | h->next = NULL; | 14 | h->next = NULL; |
15 | h->child = NULL; | 15 | h->child = NULL; |
@@ -20,8 +20,8 @@ void heap_node_init(struct heap_node** _h, void* value) | |||
20 | 20 | ||
21 | 21 | ||
22 | /* make child a subtree of root */ | 22 | /* make child a subtree of root */ |
23 | static void __heap_link(struct heap_node* root, | 23 | static void __bheap_link(struct bheap_node* root, |
24 | struct heap_node* child) | 24 | struct bheap_node* child) |
25 | { | 25 | { |
26 | child->parent = root; | 26 | child->parent = root; |
27 | child->next = root->child; | 27 | child->next = root->child; |
@@ -30,11 +30,11 @@ static void __heap_link(struct heap_node* root, | |||
30 | } | 30 | } |
31 | 31 | ||
32 | /* merge root lists */ | 32 | /* merge root lists */ |
33 | static struct heap_node* __heap_merge(struct heap_node* a, | 33 | static struct bheap_node* __bheap_merge(struct bheap_node* a, |
34 | struct heap_node* b) | 34 | struct bheap_node* b) |
35 | { | 35 | { |
36 | struct heap_node* head = NULL; | 36 | struct bheap_node* head = NULL; |
37 | struct heap_node** pos = &head; | 37 | struct bheap_node** pos = &head; |
38 | 38 | ||
39 | while (a && b) { | 39 | while (a && b) { |
40 | if (a->degree < b->degree) { | 40 | if (a->degree < b->degree) { |
@@ -54,10 +54,10 @@ static struct heap_node* __heap_merge(struct heap_node* a, | |||
54 | } | 54 | } |
55 | 55 | ||
56 | /* reverse a linked list of nodes. also clears parent pointer */ | 56 | /* reverse a linked list of nodes. also clears parent pointer */ |
57 | static struct heap_node* __heap_reverse(struct heap_node* h) | 57 | static struct bheap_node* __bheap_reverse(struct bheap_node* h) |
58 | { | 58 | { |
59 | struct heap_node* tail = NULL; | 59 | struct bheap_node* tail = NULL; |
60 | struct heap_node* next; | 60 | struct bheap_node* next; |
61 | 61 | ||
62 | if (!h) | 62 | if (!h) |
63 | return h; | 63 | return h; |
@@ -74,10 +74,10 @@ static struct heap_node* __heap_reverse(struct heap_node* h) | |||
74 | return h; | 74 | return h; |
75 | } | 75 | } |
76 | 76 | ||
77 | static void __heap_min(heap_prio_t higher_prio, struct heap* heap, | 77 | static void __bheap_min(bheap_prio_t higher_prio, struct bheap* heap, |
78 | struct heap_node** prev, struct heap_node** node) | 78 | struct bheap_node** prev, struct bheap_node** node) |
79 | { | 79 | { |
80 | struct heap_node *_prev, *cur; | 80 | struct bheap_node *_prev, *cur; |
81 | *prev = NULL; | 81 | *prev = NULL; |
82 | 82 | ||
83 | if (!heap->head) { | 83 | if (!heap->head) { |
@@ -98,11 +98,11 @@ static void __heap_min(heap_prio_t higher_prio, struct heap* heap, | |||
98 | } | 98 | } |
99 | } | 99 | } |
100 | 100 | ||
101 | static void __heap_union(heap_prio_t higher_prio, struct heap* heap, | 101 | static void __bheap_union(bheap_prio_t higher_prio, struct bheap* heap, |
102 | struct heap_node* h2) | 102 | struct bheap_node* h2) |
103 | { | 103 | { |
104 | struct heap_node* h1; | 104 | struct bheap_node* h1; |
105 | struct heap_node *prev, *x, *next; | 105 | struct bheap_node *prev, *x, *next; |
106 | if (!h2) | 106 | if (!h2) |
107 | return; | 107 | return; |
108 | h1 = heap->head; | 108 | h1 = heap->head; |
@@ -110,7 +110,7 @@ static void __heap_union(heap_prio_t higher_prio, struct heap* heap, | |||
110 | heap->head = h2; | 110 | heap->head = h2; |
111 | return; | 111 | return; |
112 | } | 112 | } |
113 | h1 = __heap_merge(h1, h2); | 113 | h1 = __bheap_merge(h1, h2); |
114 | prev = NULL; | 114 | prev = NULL; |
115 | x = h1; | 115 | x = h1; |
116 | next = x->next; | 116 | next = x->next; |
@@ -123,14 +123,14 @@ static void __heap_union(heap_prio_t higher_prio, struct heap* heap, | |||
123 | } else if (higher_prio(x, next)) { | 123 | } else if (higher_prio(x, next)) { |
124 | /* x becomes the root of next */ | 124 | /* x becomes the root of next */ |
125 | x->next = next->next; | 125 | x->next = next->next; |
126 | __heap_link(x, next); | 126 | __bheap_link(x, next); |
127 | } else { | 127 | } else { |
128 | /* next becomes the root of x */ | 128 | /* next becomes the root of x */ |
129 | if (prev) | 129 | if (prev) |
130 | prev->next = next; | 130 | prev->next = next; |
131 | else | 131 | else |
132 | h1 = next; | 132 | h1 = next; |
133 | __heap_link(next, x); | 133 | __bheap_link(next, x); |
134 | x = next; | 134 | x = next; |
135 | } | 135 | } |
136 | next = x->next; | 136 | next = x->next; |
@@ -138,26 +138,26 @@ static void __heap_union(heap_prio_t higher_prio, struct heap* heap, | |||
138 | heap->head = h1; | 138 | heap->head = h1; |
139 | } | 139 | } |
140 | 140 | ||
141 | static struct heap_node* __heap_extract_min(heap_prio_t higher_prio, | 141 | static struct bheap_node* __bheap_extract_min(bheap_prio_t higher_prio, |
142 | struct heap* heap) | 142 | struct bheap* heap) |
143 | { | 143 | { |
144 | struct heap_node *prev, *node; | 144 | struct bheap_node *prev, *node; |
145 | __heap_min(higher_prio, heap, &prev, &node); | 145 | __bheap_min(higher_prio, heap, &prev, &node); |
146 | if (!node) | 146 | if (!node) |
147 | return NULL; | 147 | return NULL; |
148 | if (prev) | 148 | if (prev) |
149 | prev->next = node->next; | 149 | prev->next = node->next; |
150 | else | 150 | else |
151 | heap->head = node->next; | 151 | heap->head = node->next; |
152 | __heap_union(higher_prio, heap, __heap_reverse(node->child)); | 152 | __bheap_union(higher_prio, heap, __bheap_reverse(node->child)); |
153 | return node; | 153 | return node; |
154 | } | 154 | } |
155 | 155 | ||
156 | /* insert (and reinitialize) a node into the heap */ | 156 | /* insert (and reinitialize) a node into the heap */ |
157 | void heap_insert(heap_prio_t higher_prio, struct heap* heap, | 157 | void bheap_insert(bheap_prio_t higher_prio, struct bheap* heap, |
158 | struct heap_node* node) | 158 | struct bheap_node* node) |
159 | { | 159 | { |
160 | struct heap_node *min; | 160 | struct bheap_node *min; |
161 | node->child = NULL; | 161 | node->child = NULL; |
162 | node->parent = NULL; | 162 | node->parent = NULL; |
163 | node->next = NULL; | 163 | node->next = NULL; |
@@ -169,48 +169,48 @@ void heap_insert(heap_prio_t higher_prio, struct heap* heap, | |||
169 | min->parent = NULL; | 169 | min->parent = NULL; |
170 | min->next = NULL; | 170 | min->next = NULL; |
171 | min->degree = 0; | 171 | min->degree = 0; |
172 | __heap_union(higher_prio, heap, min); | 172 | __bheap_union(higher_prio, heap, min); |
173 | heap->min = node; | 173 | heap->min = node; |
174 | } else | 174 | } else |
175 | __heap_union(higher_prio, heap, node); | 175 | __bheap_union(higher_prio, heap, node); |
176 | } | 176 | } |
177 | 177 | ||
178 | void heap_uncache_min(heap_prio_t higher_prio, struct heap* heap) | 178 | void bheap_uncache_min(bheap_prio_t higher_prio, struct bheap* heap) |
179 | { | 179 | { |
180 | struct heap_node* min; | 180 | struct bheap_node* min; |
181 | if (heap->min) { | 181 | if (heap->min) { |
182 | min = heap->min; | 182 | min = heap->min; |
183 | heap->min = NULL; | 183 | heap->min = NULL; |
184 | heap_insert(higher_prio, heap, min); | 184 | bheap_insert(higher_prio, heap, min); |
185 | } | 185 | } |
186 | } | 186 | } |
187 | 187 | ||
188 | /* merge addition into target */ | 188 | /* merge addition into target */ |
189 | void heap_union(heap_prio_t higher_prio, | 189 | void bheap_union(bheap_prio_t higher_prio, |
190 | struct heap* target, struct heap* addition) | 190 | struct bheap* target, struct bheap* addition) |
191 | { | 191 | { |
192 | /* first insert any cached minima, if necessary */ | 192 | /* first insert any cached minima, if necessary */ |
193 | heap_uncache_min(higher_prio, target); | 193 | bheap_uncache_min(higher_prio, target); |
194 | heap_uncache_min(higher_prio, addition); | 194 | bheap_uncache_min(higher_prio, addition); |
195 | __heap_union(higher_prio, target, addition->head); | 195 | __bheap_union(higher_prio, target, addition->head); |
196 | /* this is a destructive merge */ | 196 | /* this is a destructive merge */ |
197 | addition->head = NULL; | 197 | addition->head = NULL; |
198 | } | 198 | } |
199 | 199 | ||
200 | struct heap_node* heap_peek(heap_prio_t higher_prio, | 200 | struct bheap_node* bheap_peek(bheap_prio_t higher_prio, |
201 | struct heap* heap) | 201 | struct bheap* heap) |
202 | { | 202 | { |
203 | if (!heap->min) | 203 | if (!heap->min) |
204 | heap->min = __heap_extract_min(higher_prio, heap); | 204 | heap->min = __bheap_extract_min(higher_prio, heap); |
205 | return heap->min; | 205 | return heap->min; |
206 | } | 206 | } |
207 | 207 | ||
208 | struct heap_node* heap_take(heap_prio_t higher_prio, | 208 | struct bheap_node* bheap_take(bheap_prio_t higher_prio, |
209 | struct heap* heap) | 209 | struct bheap* heap) |
210 | { | 210 | { |
211 | struct heap_node *node; | 211 | struct bheap_node *node; |
212 | if (!heap->min) | 212 | if (!heap->min) |
213 | heap->min = __heap_extract_min(higher_prio, heap); | 213 | heap->min = __bheap_extract_min(higher_prio, heap); |
214 | node = heap->min; | 214 | node = heap->min; |
215 | heap->min = NULL; | 215 | heap->min = NULL; |
216 | if (node) | 216 | if (node) |
@@ -218,10 +218,10 @@ struct heap_node* heap_take(heap_prio_t higher_prio, | |||
218 | return node; | 218 | return node; |
219 | } | 219 | } |
220 | 220 | ||
221 | int heap_decrease(heap_prio_t higher_prio, struct heap_node* node) | 221 | int bheap_decrease(bheap_prio_t higher_prio, struct bheap_node* node) |
222 | { | 222 | { |
223 | struct heap_node *parent; | 223 | struct bheap_node *parent; |
224 | struct heap_node** tmp_ref; | 224 | struct bheap_node** tmp_ref; |
225 | void* tmp; | 225 | void* tmp; |
226 | 226 | ||
227 | /* bubble up */ | 227 | /* bubble up */ |
@@ -245,11 +245,11 @@ int heap_decrease(heap_prio_t higher_prio, struct heap_node* node) | |||
245 | return parent != NULL; | 245 | return parent != NULL; |
246 | } | 246 | } |
247 | 247 | ||
248 | void heap_delete(heap_prio_t higher_prio, struct heap* heap, | 248 | void bheap_delete(bheap_prio_t higher_prio, struct bheap* heap, |
249 | struct heap_node* node) | 249 | struct bheap_node* node) |
250 | { | 250 | { |
251 | struct heap_node *parent, *prev, *pos; | 251 | struct bheap_node *parent, *prev, *pos; |
252 | struct heap_node** tmp_ref; | 252 | struct bheap_node** tmp_ref; |
253 | void* tmp; | 253 | void* tmp; |
254 | 254 | ||
255 | if (heap->min != node) { | 255 | if (heap->min != node) { |
@@ -283,32 +283,32 @@ void heap_delete(heap_prio_t higher_prio, struct heap* heap, | |||
283 | prev->next = node->next; | 283 | prev->next = node->next; |
284 | else | 284 | else |
285 | heap->head = node->next; | 285 | heap->head = node->next; |
286 | __heap_union(higher_prio, heap, __heap_reverse(node->child)); | 286 | __bheap_union(higher_prio, heap, __bheap_reverse(node->child)); |
287 | } else | 287 | } else |
288 | heap->min = NULL; | 288 | heap->min = NULL; |
289 | node->degree = NOT_IN_HEAP; | 289 | node->degree = NOT_IN_HEAP; |
290 | } | 290 | } |
291 | 291 | ||
292 | /* allocate a heap node for value and insert into the heap */ | 292 | /* allocate a heap node for value and insert into the heap */ |
293 | int heap_add(heap_prio_t higher_prio, struct heap* heap, | 293 | int bheap_add(bheap_prio_t higher_prio, struct bheap* heap, |
294 | void* value, int gfp_flags) | 294 | void* value, int gfp_flags) |
295 | { | 295 | { |
296 | struct heap_node* hn = heap_node_alloc(gfp_flags); | 296 | struct bheap_node* hn = bheap_node_alloc(gfp_flags); |
297 | if (likely(hn)) { | 297 | if (likely(hn)) { |
298 | heap_node_init(&hn, value); | 298 | bheap_node_init(&hn, value); |
299 | heap_insert(higher_prio, heap, hn); | 299 | bheap_insert(higher_prio, heap, hn); |
300 | } | 300 | } |
301 | return hn != NULL; | 301 | return hn != NULL; |
302 | } | 302 | } |
303 | 303 | ||
304 | void* heap_take_del(heap_prio_t higher_prio, | 304 | void* bheap_take_del(bheap_prio_t higher_prio, |
305 | struct heap* heap) | 305 | struct bheap* heap) |
306 | { | 306 | { |
307 | struct heap_node* hn = heap_take(higher_prio, heap); | 307 | struct bheap_node* hn = bheap_take(higher_prio, heap); |
308 | void* ret = NULL; | 308 | void* ret = NULL; |
309 | if (hn) { | 309 | if (hn) { |
310 | ret = hn->value; | 310 | ret = hn->value; |
311 | heap_node_free(hn); | 311 | bheap_node_free(hn); |
312 | } | 312 | } |
313 | return ret; | 313 | return ret; |
314 | } | 314 | } |
diff --git a/litmus/edf_common.c b/litmus/edf_common.c index 97e37761cedc..06daec66c984 100644 --- a/litmus/edf_common.c +++ b/litmus/edf_common.c | |||
@@ -68,9 +68,9 @@ int edf_higher_prio(struct task_struct* first, | |||
68 | !second->rt_param.inh_task)))); | 68 | !second->rt_param.inh_task)))); |
69 | } | 69 | } |
70 | 70 | ||
71 | int edf_ready_order(struct heap_node* a, struct heap_node* b) | 71 | int edf_ready_order(struct bheap_node* a, struct bheap_node* b) |
72 | { | 72 | { |
73 | return edf_higher_prio(heap2task(a), heap2task(b)); | 73 | return edf_higher_prio(bheap2task(a), bheap2task(b)); |
74 | } | 74 | } |
75 | 75 | ||
76 | void edf_domain_init(rt_domain_t* rt, check_resched_needed_t resched, | 76 | void edf_domain_init(rt_domain_t* rt, check_resched_needed_t resched, |
diff --git a/litmus/litmus.c b/litmus/litmus.c index de751a14d77c..2dea340aea1d 100644 --- a/litmus/litmus.c +++ b/litmus/litmus.c | |||
@@ -15,7 +15,7 @@ | |||
15 | #include <linux/sched.h> | 15 | #include <linux/sched.h> |
16 | #include <litmus/sched_plugin.h> | 16 | #include <litmus/sched_plugin.h> |
17 | 17 | ||
18 | #include <litmus/heap.h> | 18 | #include <litmus/bheap.h> |
19 | 19 | ||
20 | #include <litmus/trace.h> | 20 | #include <litmus/trace.h> |
21 | 21 | ||
@@ -31,17 +31,17 @@ atomic_t __log_seq_no = ATOMIC_INIT(0); | |||
31 | /* current master CPU for handling timer IRQs */ | 31 | /* current master CPU for handling timer IRQs */ |
32 | atomic_t release_master_cpu = ATOMIC_INIT(NO_CPU); | 32 | atomic_t release_master_cpu = ATOMIC_INIT(NO_CPU); |
33 | 33 | ||
34 | static struct kmem_cache * heap_node_cache; | 34 | static struct kmem_cache * bheap_node_cache; |
35 | extern struct kmem_cache * release_heap_cache; | 35 | extern struct kmem_cache * release_heap_cache; |
36 | 36 | ||
37 | struct heap_node* heap_node_alloc(int gfp_flags) | 37 | struct bheap_node* bheap_node_alloc(int gfp_flags) |
38 | { | 38 | { |
39 | return kmem_cache_alloc(heap_node_cache, gfp_flags); | 39 | return kmem_cache_alloc(bheap_node_cache, gfp_flags); |
40 | } | 40 | } |
41 | 41 | ||
42 | void heap_node_free(struct heap_node* hn) | 42 | void bheap_node_free(struct bheap_node* hn) |
43 | { | 43 | { |
44 | kmem_cache_free(heap_node_cache, hn); | 44 | kmem_cache_free(bheap_node_cache, hn); |
45 | } | 45 | } |
46 | 46 | ||
47 | struct release_heap* release_heap_alloc(int gfp_flags); | 47 | struct release_heap* release_heap_alloc(int gfp_flags); |
@@ -323,19 +323,19 @@ long litmus_admit_task(struct task_struct* tsk) | |||
323 | spin_lock_irqsave(&task_transition_lock, flags); | 323 | spin_lock_irqsave(&task_transition_lock, flags); |
324 | 324 | ||
325 | /* allocate heap node for this task */ | 325 | /* allocate heap node for this task */ |
326 | tsk_rt(tsk)->heap_node = heap_node_alloc(GFP_ATOMIC); | 326 | tsk_rt(tsk)->heap_node = bheap_node_alloc(GFP_ATOMIC); |
327 | tsk_rt(tsk)->rel_heap = release_heap_alloc(GFP_ATOMIC); | 327 | tsk_rt(tsk)->rel_heap = release_heap_alloc(GFP_ATOMIC); |
328 | 328 | ||
329 | if (!tsk_rt(tsk)->heap_node || !tsk_rt(tsk)->rel_heap) { | 329 | if (!tsk_rt(tsk)->heap_node || !tsk_rt(tsk)->rel_heap) { |
330 | printk(KERN_WARNING "litmus: no more heap node memory!?\n"); | 330 | printk(KERN_WARNING "litmus: no more heap node memory!?\n"); |
331 | 331 | ||
332 | heap_node_free(tsk_rt(tsk)->heap_node); | 332 | bheap_node_free(tsk_rt(tsk)->heap_node); |
333 | release_heap_free(tsk_rt(tsk)->rel_heap); | 333 | release_heap_free(tsk_rt(tsk)->rel_heap); |
334 | 334 | ||
335 | retval = -ENOMEM; | 335 | retval = -ENOMEM; |
336 | goto out_unlock; | 336 | goto out_unlock; |
337 | } else { | 337 | } else { |
338 | heap_node_init(&tsk_rt(tsk)->heap_node, tsk); | 338 | bheap_node_init(&tsk_rt(tsk)->heap_node, tsk); |
339 | } | 339 | } |
340 | 340 | ||
341 | retval = litmus->admit_task(tsk); | 341 | retval = litmus->admit_task(tsk); |
@@ -359,8 +359,8 @@ void litmus_exit_task(struct task_struct* tsk) | |||
359 | 359 | ||
360 | litmus->task_exit(tsk); | 360 | litmus->task_exit(tsk); |
361 | 361 | ||
362 | BUG_ON(heap_node_in_heap(tsk_rt(tsk)->heap_node)); | 362 | BUG_ON(bheap_node_in_heap(tsk_rt(tsk)->heap_node)); |
363 | heap_node_free(tsk_rt(tsk)->heap_node); | 363 | bheap_node_free(tsk_rt(tsk)->heap_node); |
364 | release_heap_free(tsk_rt(tsk)->rel_heap); | 364 | release_heap_free(tsk_rt(tsk)->rel_heap); |
365 | 365 | ||
366 | atomic_dec(&rt_task_count); | 366 | atomic_dec(&rt_task_count); |
@@ -648,7 +648,7 @@ static int __init _init_litmus(void) | |||
648 | 648 | ||
649 | register_sched_plugin(&linux_sched_plugin); | 649 | register_sched_plugin(&linux_sched_plugin); |
650 | 650 | ||
651 | heap_node_cache = KMEM_CACHE(heap_node, SLAB_PANIC); | 651 | bheap_node_cache = KMEM_CACHE(bheap_node, SLAB_PANIC); |
652 | release_heap_cache = KMEM_CACHE(release_heap, SLAB_PANIC); | 652 | release_heap_cache = KMEM_CACHE(release_heap, SLAB_PANIC); |
653 | 653 | ||
654 | #ifdef CONFIG_MAGIC_SYSRQ | 654 | #ifdef CONFIG_MAGIC_SYSRQ |
@@ -667,7 +667,7 @@ static int __init _init_litmus(void) | |||
667 | static void _exit_litmus(void) | 667 | static void _exit_litmus(void) |
668 | { | 668 | { |
669 | exit_litmus_proc(); | 669 | exit_litmus_proc(); |
670 | kmem_cache_destroy(heap_node_cache); | 670 | kmem_cache_destroy(bheap_node_cache); |
671 | kmem_cache_destroy(release_heap_cache); | 671 | kmem_cache_destroy(release_heap_cache); |
672 | } | 672 | } |
673 | 673 | ||
diff --git a/litmus/rt_domain.c b/litmus/rt_domain.c index 62c9fdcd22be..0ed6d5cbbfc5 100644 --- a/litmus/rt_domain.c +++ b/litmus/rt_domain.c | |||
@@ -19,20 +19,20 @@ | |||
19 | 19 | ||
20 | #include <litmus/trace.h> | 20 | #include <litmus/trace.h> |
21 | 21 | ||
22 | #include <litmus/heap.h> | 22 | #include <litmus/bheap.h> |
23 | 23 | ||
24 | static int dummy_resched(rt_domain_t *rt) | 24 | static int dummy_resched(rt_domain_t *rt) |
25 | { | 25 | { |
26 | return 0; | 26 | return 0; |
27 | } | 27 | } |
28 | 28 | ||
29 | static int dummy_order(struct heap_node* a, struct heap_node* b) | 29 | static int dummy_order(struct bheap_node* a, struct bheap_node* b) |
30 | { | 30 | { |
31 | return 0; | 31 | return 0; |
32 | } | 32 | } |
33 | 33 | ||
34 | /* default implementation: use default lock */ | 34 | /* default implementation: use default lock */ |
35 | static void default_release_jobs(rt_domain_t* rt, struct heap* tasks) | 35 | static void default_release_jobs(rt_domain_t* rt, struct bheap* tasks) |
36 | { | 36 | { |
37 | merge_ready(rt, tasks); | 37 | merge_ready(rt, tasks); |
38 | } | 38 | } |
@@ -157,7 +157,7 @@ static void reinit_release_heap(struct task_struct* t) | |||
157 | BUG_ON(hrtimer_cancel(&rh->timer)); | 157 | BUG_ON(hrtimer_cancel(&rh->timer)); |
158 | 158 | ||
159 | /* initialize */ | 159 | /* initialize */ |
160 | heap_init(&rh->heap); | 160 | bheap_init(&rh->heap); |
161 | atomic_set(&rh->info.state, HRTIMER_START_ON_INACTIVE); | 161 | atomic_set(&rh->info.state, HRTIMER_START_ON_INACTIVE); |
162 | } | 162 | } |
163 | /* arm_release_timer() - start local release timer or trigger | 163 | /* arm_release_timer() - start local release timer or trigger |
@@ -204,7 +204,7 @@ static void arm_release_timer(rt_domain_t *_rt) | |||
204 | 204 | ||
205 | rh = get_release_heap(rt, t, 1); | 205 | rh = get_release_heap(rt, t, 1); |
206 | } | 206 | } |
207 | heap_insert(rt->order, &rh->heap, tsk_rt(t)->heap_node); | 207 | bheap_insert(rt->order, &rh->heap, tsk_rt(t)->heap_node); |
208 | TRACE_TASK(t, "arm_release_timer(): added to release heap\n"); | 208 | TRACE_TASK(t, "arm_release_timer(): added to release heap\n"); |
209 | 209 | ||
210 | spin_unlock(&rt->release_lock); | 210 | spin_unlock(&rt->release_lock); |
@@ -236,7 +236,7 @@ static void arm_release_timer(rt_domain_t *_rt) | |||
236 | } | 236 | } |
237 | 237 | ||
238 | void rt_domain_init(rt_domain_t *rt, | 238 | void rt_domain_init(rt_domain_t *rt, |
239 | heap_prio_t order, | 239 | bheap_prio_t order, |
240 | check_resched_needed_t check, | 240 | check_resched_needed_t check, |
241 | release_jobs_t release | 241 | release_jobs_t release |
242 | ) | 242 | ) |
@@ -253,7 +253,7 @@ void rt_domain_init(rt_domain_t *rt, | |||
253 | 253 | ||
254 | rt->release_master = NO_CPU; | 254 | rt->release_master = NO_CPU; |
255 | 255 | ||
256 | heap_init(&rt->ready_queue); | 256 | bheap_init(&rt->ready_queue); |
257 | INIT_LIST_HEAD(&rt->tobe_released); | 257 | INIT_LIST_HEAD(&rt->tobe_released); |
258 | for (i = 0; i < RELEASE_QUEUE_SLOTS; i++) | 258 | for (i = 0; i < RELEASE_QUEUE_SLOTS; i++) |
259 | INIT_LIST_HEAD(&rt->release_queue.slot[i]); | 259 | INIT_LIST_HEAD(&rt->release_queue.slot[i]); |
@@ -276,18 +276,18 @@ void __add_ready(rt_domain_t* rt, struct task_struct *new) | |||
276 | new->comm, new->pid, get_exec_cost(new), get_rt_period(new), | 276 | new->comm, new->pid, get_exec_cost(new), get_rt_period(new), |
277 | get_release(new), litmus_clock()); | 277 | get_release(new), litmus_clock()); |
278 | 278 | ||
279 | BUG_ON(heap_node_in_heap(tsk_rt(new)->heap_node)); | 279 | BUG_ON(bheap_node_in_heap(tsk_rt(new)->heap_node)); |
280 | 280 | ||
281 | heap_insert(rt->order, &rt->ready_queue, tsk_rt(new)->heap_node); | 281 | bheap_insert(rt->order, &rt->ready_queue, tsk_rt(new)->heap_node); |
282 | rt->check_resched(rt); | 282 | rt->check_resched(rt); |
283 | } | 283 | } |
284 | 284 | ||
285 | /* merge_ready - Add a sorted set of tasks to the rt ready queue. They must be runnable. | 285 | /* merge_ready - Add a sorted set of tasks to the rt ready queue. They must be runnable. |
286 | * @tasks - the newly released tasks | 286 | * @tasks - the newly released tasks |
287 | */ | 287 | */ |
288 | void __merge_ready(rt_domain_t* rt, struct heap* tasks) | 288 | void __merge_ready(rt_domain_t* rt, struct bheap* tasks) |
289 | { | 289 | { |
290 | heap_union(rt->order, &rt->ready_queue, tasks); | 290 | bheap_union(rt->order, &rt->ready_queue, tasks); |
291 | rt->check_resched(rt); | 291 | rt->check_resched(rt); |
292 | } | 292 | } |
293 | 293 | ||
diff --git a/litmus/sched_gsn_edf.c b/litmus/sched_gsn_edf.c index a223e69f2efb..9f256be86cf7 100644 --- a/litmus/sched_gsn_edf.c +++ b/litmus/sched_gsn_edf.c | |||
@@ -18,7 +18,7 @@ | |||
18 | #include <litmus/edf_common.h> | 18 | #include <litmus/edf_common.h> |
19 | #include <litmus/sched_trace.h> | 19 | #include <litmus/sched_trace.h> |
20 | 20 | ||
21 | #include <litmus/heap.h> | 21 | #include <litmus/bheap.h> |
22 | 22 | ||
23 | #include <linux/module.h> | 23 | #include <linux/module.h> |
24 | 24 | ||
@@ -96,7 +96,7 @@ typedef struct { | |||
96 | struct task_struct* linked; /* only RT tasks */ | 96 | struct task_struct* linked; /* only RT tasks */ |
97 | struct task_struct* scheduled; /* only RT tasks */ | 97 | struct task_struct* scheduled; /* only RT tasks */ |
98 | atomic_t will_schedule; /* prevent unneeded IPIs */ | 98 | atomic_t will_schedule; /* prevent unneeded IPIs */ |
99 | struct heap_node* hn; | 99 | struct bheap_node* hn; |
100 | } cpu_entry_t; | 100 | } cpu_entry_t; |
101 | DEFINE_PER_CPU(cpu_entry_t, gsnedf_cpu_entries); | 101 | DEFINE_PER_CPU(cpu_entry_t, gsnedf_cpu_entries); |
102 | 102 | ||
@@ -111,14 +111,14 @@ cpu_entry_t* gsnedf_cpus[NR_CPUS]; | |||
111 | 111 | ||
112 | 112 | ||
113 | /* the cpus queue themselves according to priority in here */ | 113 | /* the cpus queue themselves according to priority in here */ |
114 | static struct heap_node gsnedf_heap_node[NR_CPUS]; | 114 | static struct bheap_node gsnedf_heap_node[NR_CPUS]; |
115 | static struct heap gsnedf_cpu_heap; | 115 | static struct bheap gsnedf_cpu_heap; |
116 | 116 | ||
117 | static rt_domain_t gsnedf; | 117 | static rt_domain_t gsnedf; |
118 | #define gsnedf_lock (gsnedf.ready_lock) | 118 | #define gsnedf_lock (gsnedf.ready_lock) |
119 | 119 | ||
120 | 120 | ||
121 | static int cpu_lower_prio(struct heap_node *_a, struct heap_node *_b) | 121 | static int cpu_lower_prio(struct bheap_node *_a, struct bheap_node *_b) |
122 | { | 122 | { |
123 | cpu_entry_t *a, *b; | 123 | cpu_entry_t *a, *b; |
124 | a = _a->value; | 124 | a = _a->value; |
@@ -134,16 +134,16 @@ static int cpu_lower_prio(struct heap_node *_a, struct heap_node *_b) | |||
134 | */ | 134 | */ |
135 | static void update_cpu_position(cpu_entry_t *entry) | 135 | static void update_cpu_position(cpu_entry_t *entry) |
136 | { | 136 | { |
137 | if (likely(heap_node_in_heap(entry->hn))) | 137 | if (likely(bheap_node_in_heap(entry->hn))) |
138 | heap_delete(cpu_lower_prio, &gsnedf_cpu_heap, entry->hn); | 138 | bheap_delete(cpu_lower_prio, &gsnedf_cpu_heap, entry->hn); |
139 | heap_insert(cpu_lower_prio, &gsnedf_cpu_heap, entry->hn); | 139 | bheap_insert(cpu_lower_prio, &gsnedf_cpu_heap, entry->hn); |
140 | } | 140 | } |
141 | 141 | ||
142 | /* caller must hold gsnedf lock */ | 142 | /* caller must hold gsnedf lock */ |
143 | static cpu_entry_t* lowest_prio_cpu(void) | 143 | static cpu_entry_t* lowest_prio_cpu(void) |
144 | { | 144 | { |
145 | struct heap_node* hn; | 145 | struct bheap_node* hn; |
146 | hn = heap_peek(cpu_lower_prio, &gsnedf_cpu_heap); | 146 | hn = bheap_peek(cpu_lower_prio, &gsnedf_cpu_heap); |
147 | return hn->value; | 147 | return hn->value; |
148 | } | 148 | } |
149 | 149 | ||
@@ -304,7 +304,7 @@ static noinline void gsnedf_job_arrival(struct task_struct* task) | |||
304 | check_for_preemptions(); | 304 | check_for_preemptions(); |
305 | } | 305 | } |
306 | 306 | ||
307 | static void gsnedf_release_jobs(rt_domain_t* rt, struct heap* tasks) | 307 | static void gsnedf_release_jobs(rt_domain_t* rt, struct bheap* tasks) |
308 | { | 308 | { |
309 | unsigned long flags; | 309 | unsigned long flags; |
310 | 310 | ||
@@ -628,9 +628,9 @@ static void update_queue_position(struct task_struct *holder) | |||
628 | * We can't use heap_decrease() here since | 628 | * We can't use heap_decrease() here since |
629 | * the cpu_heap is ordered in reverse direction, so | 629 | * the cpu_heap is ordered in reverse direction, so |
630 | * it is actually an increase. */ | 630 | * it is actually an increase. */ |
631 | heap_delete(cpu_lower_prio, &gsnedf_cpu_heap, | 631 | bheap_delete(cpu_lower_prio, &gsnedf_cpu_heap, |
632 | gsnedf_cpus[tsk_rt(holder)->linked_on]->hn); | 632 | gsnedf_cpus[tsk_rt(holder)->linked_on]->hn); |
633 | heap_insert(cpu_lower_prio, &gsnedf_cpu_heap, | 633 | bheap_insert(cpu_lower_prio, &gsnedf_cpu_heap, |
634 | gsnedf_cpus[tsk_rt(holder)->linked_on]->hn); | 634 | gsnedf_cpus[tsk_rt(holder)->linked_on]->hn); |
635 | } else { | 635 | } else { |
636 | /* holder may be queued: first stop queue changes */ | 636 | /* holder may be queued: first stop queue changes */ |
@@ -642,7 +642,7 @@ static void update_queue_position(struct task_struct *holder) | |||
642 | * of holder in some heap. Note that this | 642 | * of holder in some heap. Note that this |
643 | * may be a release heap. */ | 643 | * may be a release heap. */ |
644 | check_preempt = | 644 | check_preempt = |
645 | !heap_decrease(edf_ready_order, | 645 | !bheap_decrease(edf_ready_order, |
646 | tsk_rt(holder)->heap_node); | 646 | tsk_rt(holder)->heap_node); |
647 | } else { | 647 | } else { |
648 | /* Nothing to do: if it is not queued and not linked | 648 | /* Nothing to do: if it is not queued and not linked |
@@ -664,7 +664,7 @@ static void update_queue_position(struct task_struct *holder) | |||
664 | /* heap_decrease() hit the top level of the heap: make | 664 | /* heap_decrease() hit the top level of the heap: make |
665 | * sure preemption checks get the right task, not the | 665 | * sure preemption checks get the right task, not the |
666 | * potentially stale cache. */ | 666 | * potentially stale cache. */ |
667 | heap_uncache_min(edf_ready_order, | 667 | bheap_uncache_min(edf_ready_order, |
668 | &gsnedf.ready_queue); | 668 | &gsnedf.ready_queue); |
669 | check_for_preemptions(); | 669 | check_for_preemptions(); |
670 | } | 670 | } |
@@ -770,12 +770,12 @@ static long gsnedf_activate_plugin(void) | |||
770 | int cpu; | 770 | int cpu; |
771 | cpu_entry_t *entry; | 771 | cpu_entry_t *entry; |
772 | 772 | ||
773 | heap_init(&gsnedf_cpu_heap); | 773 | bheap_init(&gsnedf_cpu_heap); |
774 | gsnedf.release_master = atomic_read(&release_master_cpu); | 774 | gsnedf.release_master = atomic_read(&release_master_cpu); |
775 | 775 | ||
776 | for_each_online_cpu(cpu) { | 776 | for_each_online_cpu(cpu) { |
777 | entry = &per_cpu(gsnedf_cpu_entries, cpu); | 777 | entry = &per_cpu(gsnedf_cpu_entries, cpu); |
778 | heap_node_init(&entry->hn, entry); | 778 | bheap_node_init(&entry->hn, entry); |
779 | atomic_set(&entry->will_schedule, 0); | 779 | atomic_set(&entry->will_schedule, 0); |
780 | entry->linked = NULL; | 780 | entry->linked = NULL; |
781 | entry->scheduled = NULL; | 781 | entry->scheduled = NULL; |
@@ -816,7 +816,7 @@ static int __init init_gsn_edf(void) | |||
816 | int cpu; | 816 | int cpu; |
817 | cpu_entry_t *entry; | 817 | cpu_entry_t *entry; |
818 | 818 | ||
819 | heap_init(&gsnedf_cpu_heap); | 819 | bheap_init(&gsnedf_cpu_heap); |
820 | /* initialize CPU state */ | 820 | /* initialize CPU state */ |
821 | for (cpu = 0; cpu < NR_CPUS; cpu++) { | 821 | for (cpu = 0; cpu < NR_CPUS; cpu++) { |
822 | entry = &per_cpu(gsnedf_cpu_entries, cpu); | 822 | entry = &per_cpu(gsnedf_cpu_entries, cpu); |
@@ -824,7 +824,7 @@ static int __init init_gsn_edf(void) | |||
824 | atomic_set(&entry->will_schedule, 0); | 824 | atomic_set(&entry->will_schedule, 0); |
825 | entry->cpu = cpu; | 825 | entry->cpu = cpu; |
826 | entry->hn = &gsnedf_heap_node[cpu]; | 826 | entry->hn = &gsnedf_heap_node[cpu]; |
827 | heap_node_init(&entry->hn, entry); | 827 | bheap_node_init(&entry->hn, entry); |
828 | } | 828 | } |
829 | edf_domain_init(&gsnedf, NULL, gsnedf_release_jobs); | 829 | edf_domain_init(&gsnedf, NULL, gsnedf_release_jobs); |
830 | return register_sched_plugin(&gsn_edf_plugin); | 830 | return register_sched_plugin(&gsn_edf_plugin); |