revert the cpu mask changes

1 files changed, 8 insertions, 37 deletions

diff --git a/litmus/sched_mc.c b/litmus/sched_mc.c
index f4037bb1dfe2..53c24ac2172c 100644
--- a/litmus/sched_mc.c
+++ b/litmus/sched_mc.c
@@ -60,8 +60,6 @@ DEFINE_PER_CPU(struct cpu_entry, cpus);
 static int interrupt_cpu;
 #endif
 
-struct cpumask rt_mask;
-
 #define domain_data(dom)  (container_of(dom, struct domain_data, domain))
 #define is_global(dom)    (domain_data(dom)->heap)
 #define is_global_task(t) (is_global(get_task_domain(t)))
@@ -352,7 +350,7 @@ static void fix_global_levels(void)
         struct task_struct *t;
 
         STRACE("Fixing global levels\n");
-        for_each_rt_cpu(c) {
+        for_each_online_cpu(c) {
                 e = &per_cpu(cpus, c);
                 raw_spin_lock(&e->redir_lock);
                 list_for_each_safe(pos, safe, &e->redir) {
@@ -379,7 +377,6 @@ static void link_task_to_cpu(struct cpu_entry *entry, struct task_struct *task)
         TRACE_MC_TASK(task, "Linking to P%d\n", entry->cpu);
         BUG_ON(task && tsk_rt(task)->linked_on != entry->cpu);
         BUG_ON(task && is_ghost(task));
-        BUG_ON(CONFIG_FTRACE_CPU == entry->cpu);
 
         if (task){
                 set_rt_flags(task, RT_F_RUNNING);
@@ -772,15 +769,11 @@ static void mc_task_new(struct task_struct *t, int on_rq, int running)
         TRACE("New mixed criticality task %d\n", t->pid);
 
         /* Assign domain */
-        if (level < CRIT_LEVEL_C) {
+        if (level < CRIT_LEVEL_C)
                 entry = &per_cpu(cpus, get_partition(t));
-                t->rt_param._domain = entry->crit_entries[level].domain;
-        } else {
+        else
                 entry = &per_cpu(cpus, task_cpu(t));
-                t->rt_param._domain =
-                        per_cpu(cpus, 0).crit_entries[CRIT_LEVEL_C].domain;
-        }
-
+        t->rt_param._domain = entry->crit_entries[level].domain;
 
         /* Setup job params */
         release_at(t, litmus_clock());
@@ -788,13 +781,8 @@ static void mc_task_new(struct task_struct *t, int on_rq, int running)
         tsk_mc_data(t)->mc_job.is_ghost = 0;
         if (running) {
                 BUG_ON(entry->scheduled);
-                if (entry->cpu != CONFIG_FTRACE_CPU) {
-                        entry->scheduled = t;
-                        tsk_rt(t)->scheduled_on = entry->cpu;
-                } else {
-                        tsk_rt(t)->scheduled_on = NO_CPU;
-                        preempt_if_preemptable(NULL, entry->cpu);
-                }
+                entry->scheduled = t;
+                tsk_rt(t)->scheduled_on = entry->cpu;
         } else {
                 t->rt_param.scheduled_on = NO_CPU;
         }
@@ -904,10 +892,6 @@ static struct task_struct* mc_schedule(struct task_struct* prev)
         int i, out_of_time, sleep, preempt, exists, blocks, global, lower;
         struct task_struct *dtask = NULL, *ready_task = NULL, *next = NULL;
 
-        /* Give FTRACE a CPU to run on */
-        if (CONFIG_FTRACE_CPU == entry->cpu)
-                return NULL;
-
         local_irq_save(flags);
 
         /* Litmus gave up because it couldn't access the stack of the CPU
@@ -1091,7 +1075,7 @@ static long mc_activate_plugin(void)
 #endif
 #endif
 
-        for_each_rt_cpu(cpu) {
+        for_each_online_cpu(cpu) {
                 BUG_ON(NR_CPUS <= n);
                 dom = per_cpu(cpus, cpu).crit_entries[CRIT_LEVEL_A].domain;
                 dom_data = domain_data(dom);
@@ -1166,7 +1150,7 @@ static void init_global_domain(struct domain_data *dom_data, enum crit_level lev
         dom_data->heap = heap;
         bheap_init(heap);
 
-        for_each_rt_cpu(cpu) {
+        for_each_online_cpu(cpu) {
                 entry = &per_cpu(cpus, cpu);
                 node = &nodes[cpu];
                 ce = &entry->crit_entries[level];
@@ -1215,16 +1199,6 @@ static int __init init_mc(void)
         raw_spinlock_t *a_dom_lock, *b_dom_lock, *c_dom_lock; /* For lock debugger */
         struct ce_dom_data *ce_data;
 
-#if CONFIG_FTRACE_CPU != NO_CPU
-        cpumask_andnot(&rt_mask, cpu_online_mask, cpumask_of(CONFIG_FTRACE_CPU));
-        printk(KERN_INFO "LITMUS-MC: %lu %lu %lu\n", *cpumask_bits(&rt_mask),
-              *cpumask_bits(cpu_online_mask),
-              *cpumask_bits(cpumask_of(CONFIG_FTRACE_CPU)));
-        for_each_rt_cpu(cpu) {
-                printk(KERN_INFO "LITMUS-MC: Cpu: %d\n", cpu);
-        }
-#endif
-
         for_each_online_cpu(cpu) {
                 entry = &per_cpu(cpus, cpu);
 
@@ -1232,9 +1206,6 @@ static int __init init_mc(void)
                 entry->cpu = cpu;
                 entry->scheduled = NULL;
                 entry->linked = NULL;
-
-                if (cpu == CONFIG_FTRACE_CPU)
-                        continue;
                 raw_spin_lock_init(&entry->lock);
 
 #ifdef CONFIG_PLUGIN_MC_REDIRECT