aboutsummaryrefslogtreecommitdiffstats
path: root/litmus/rt_domain.c
diff options
context:
space:
mode:
authorJonathan Herman <hermanjl@cs.unc.edu>2011-09-27 20:15:32 -0400
committerJonathan Herman <hermanjl@cs.unc.edu>2011-09-27 20:36:04 -0400
commit23a00b911b968c6290251913ecc34171836b4d32 (patch)
treef6c8289054d2961902931e89bdc11ccc01bc3a73 /litmus/rt_domain.c
parentf21e1d0ef90c2e88ae6a563afc31ea601ed968c7 (diff)
parent609c45f71b7a2405230fd2f8436837d6389ec599 (diff)
Merged with ce domains
Diffstat (limited to 'litmus/rt_domain.c')
-rw-r--r--litmus/rt_domain.c16
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 */
324void __add_ready(rt_domain_t* rt, struct task_struct *new) 324void __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)
348void __add_release_on(rt_domain_t* rt, struct task_struct *task, 348void __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 */
368void __add_release(rt_domain_t* rt, struct task_struct *task) 368void __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}