diff options
author | Jonathan Herman <hermanjl@cs.unc.edu> | 2011-09-27 20:15:32 -0400 |
---|---|---|
committer | Jonathan Herman <hermanjl@cs.unc.edu> | 2011-09-27 20:36:04 -0400 |
commit | 23a00b911b968c6290251913ecc34171836b4d32 (patch) | |
tree | f6c8289054d2961902931e89bdc11ccc01bc3a73 /litmus/rt_domain.c | |
parent | f21e1d0ef90c2e88ae6a563afc31ea601ed968c7 (diff) | |
parent | 609c45f71b7a2405230fd2f8436837d6389ec599 (diff) |
Merged with ce domains
Diffstat (limited to 'litmus/rt_domain.c')
-rw-r--r-- | litmus/rt_domain.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/litmus/rt_domain.c b/litmus/rt_domain.c index 50a6abfd767..db92e849f08 100644 --- a/litmus/rt_domain.c +++ b/litmus/rt_domain.c | |||
@@ -104,8 +104,8 @@ void release_heap_free(struct release_heap* rh) | |||
104 | { | 104 | { |
105 | /* make sure timer is no longer in use */ | 105 | /* make sure timer is no longer in use */ |
106 | #ifdef CONFIG_MERGE_TIMERS | 106 | #ifdef CONFIG_MERGE_TIMERS |
107 | if (rh->dom) | 107 | /* if (rh->dom) */ |
108 | cancel_event(&rh->event); | 108 | /* cancel_event(&rh->event); */ |
109 | #else | 109 | #else |
110 | hrtimer_cancel(&rh->timer); | 110 | hrtimer_cancel(&rh->timer); |
111 | #endif | 111 | #endif |
@@ -166,7 +166,7 @@ static void reinit_release_heap(rt_domain_t *rt, struct task_struct* t) | |||
166 | 166 | ||
167 | #ifdef CONFIG_MERGE_TIMERS | 167 | #ifdef CONFIG_MERGE_TIMERS |
168 | rh->event.prio = rt->prio; | 168 | rh->event.prio = rt->prio; |
169 | cancel_event(&rh->event); | 169 | cancel_event(rt->event_group, &rh->event); |
170 | #else | 170 | #else |
171 | /* Make sure it is safe to use. The timer callback could still | 171 | /* Make sure it is safe to use. The timer callback could still |
172 | * be executing on another CPU; hrtimer_cancel() will wait | 172 | * be executing on another CPU; hrtimer_cancel() will wait |
@@ -323,7 +323,7 @@ void rt_domain_init(rt_domain_t *rt, | |||
323 | */ | 323 | */ |
324 | void __add_ready(rt_domain_t* rt, struct task_struct *new) | 324 | void __add_ready(rt_domain_t* rt, struct task_struct *new) |
325 | { | 325 | { |
326 | TRACE("rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n", | 326 | VTRACE("rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n", |
327 | new->comm, new->pid, get_exec_cost(new), get_rt_period(new), | 327 | new->comm, new->pid, get_exec_cost(new), get_rt_period(new), |
328 | get_release(new), litmus_clock()); | 328 | get_release(new), litmus_clock()); |
329 | 329 | ||
@@ -348,7 +348,7 @@ void __merge_ready(rt_domain_t* rt, struct bheap* tasks) | |||
348 | void __add_release_on(rt_domain_t* rt, struct task_struct *task, | 348 | void __add_release_on(rt_domain_t* rt, struct task_struct *task, |
349 | int target_cpu) | 349 | int target_cpu) |
350 | { | 350 | { |
351 | TRACE_TASK(task, "add_release_on(), rel=%llu, target=%d\n", | 351 | VTRACE_TASK(task, "add_release_on(), rel=%llu, target=%d\n", |
352 | get_release(task), target_cpu); | 352 | get_release(task), target_cpu); |
353 | list_add(&tsk_rt(task)->list, &rt->tobe_released); | 353 | list_add(&tsk_rt(task)->list, &rt->tobe_released); |
354 | task->rt_param.domain = rt; | 354 | task->rt_param.domain = rt; |
@@ -367,7 +367,7 @@ void __add_release_on(rt_domain_t* rt, struct task_struct *task, | |||
367 | */ | 367 | */ |
368 | void __add_release(rt_domain_t* rt, struct task_struct *task) | 368 | void __add_release(rt_domain_t* rt, struct task_struct *task) |
369 | { | 369 | { |
370 | TRACE_TASK(task, "add_release(), rel=%llu\n", get_release(task)); | 370 | VTRACE_TASK(task, "add_release(), rel=%llu\n", get_release(task)); |
371 | list_add(&tsk_rt(task)->list, &rt->tobe_released); | 371 | list_add(&tsk_rt(task)->list, &rt->tobe_released); |
372 | task->rt_param.domain = rt; | 372 | task->rt_param.domain = rt; |
373 | 373 | ||
@@ -398,12 +398,12 @@ static void pd_requeue(domain_t *dom, struct task_struct *task) | |||
398 | 398 | ||
399 | if (is_released(task, litmus_clock())) { | 399 | if (is_released(task, litmus_clock())) { |
400 | __add_ready(domain, task); | 400 | __add_ready(domain, task); |
401 | TRACE("rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n", | 401 | VTRACE("rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n", |
402 | task->comm, task->pid, get_exec_cost(task), get_rt_period(task), | 402 | task->comm, task->pid, get_exec_cost(task), get_rt_period(task), |
403 | get_release(task), litmus_clock()); | 403 | get_release(task), litmus_clock()); |
404 | } else { | 404 | } else { |
405 | /* task has to wait for next release */ | 405 | /* task has to wait for next release */ |
406 | TRACE_TASK(task, "add release(), rel=%llu\n", get_release(task)); | 406 | VTRACE_TASK(task, "add release(), rel=%llu\n", get_release(task)); |
407 | add_release(domain, task); | 407 | add_release(domain, task); |
408 | } | 408 | } |
409 | } | 409 | } |