blarg

4 files changed, 99 insertions, 24 deletions

diff --git a/include/litmus/rt_param.h b/include/litmus/rt_param.h
index 89ac0dda7d3d..21430623a940 100644
--- a/include/litmus/rt_param.h
+++ b/include/litmus/rt_param.h
@@ -157,6 +157,11 @@ struct rt_param {
          */
          struct task_struct*    inh_task;
 
+        
+         struct task_struct*    hp_group;
+         unsigned int                   is_slave:1;
+
+
 #ifdef CONFIG_NP_SECTION
         /* For the FMLP under PSN-EDF, it is required to make the task
          * non-preemptive from kernel space. In order not to interfere with
diff --git a/include/litmus/unistd_32.h b/include/litmus/unistd_32.h
index 94264c27d9ac..bcb8f1183b4f 100644
--- a/include/litmus/unistd_32.h
+++ b/include/litmus/unistd_32.h
@@ -18,4 +18,6 @@
 #define __NR_release_ts         __LSC(10)
 #define __NR_null_call          __LSC(11)
 
-#define NR_litmus_syscalls 12
+#define __NR_slave_non_rt_threads       _LSC(12)
+
+#define NR_litmus_syscalls 13
diff --git a/include/litmus/unistd_64.h b/include/litmus/unistd_64.h
index d5ced0d2642c..5f56d5947343 100644
--- a/include/litmus/unistd_64.h
+++ b/include/litmus/unistd_64.h
@@ -30,4 +30,7 @@ __SYSCALL(__NR_release_ts, sys_release_ts)
 #define __NR_null_call                          __LSC(11)
 __SYSCALL(__NR_null_call, sys_null_call)
 
-#define NR_litmus_syscalls 12
+#define __NR_slave_non_rt_threads       __LSC(12)
+__SYSCALL(__NR_slave_non_rt_threads, sys_slave_non_rt_threads)
+
+#define NR_litmus_syscalls 13
diff --git a/litmus/litmus.c b/litmus/litmus.c
index 81384327e850..2300281b6b30 100644
--- a/litmus/litmus.c
+++ b/litmus/litmus.c
@@ -290,6 +290,60 @@ asmlinkage long sys_null_call(cycles_t __user *ts)
         return ret;
 }
 
+
+
+
+
+
+
+
+
+
+long __litmus_admit_task(struct task_struct* tsk);
+
+asmlinkage long sys_slave_non_rt_threads(void)
+{
+        long retval = 0;
+        struct task_struct *leader = current->group_leader;
+        struct task_struct *t;
+        struct task_struct *hp = NULL;
+
+        read_lock_irq(&tasklist_lock);
+
+        is_realtime(target)
+
+        t = leader;
+        do {
+                TRACE_CUR("threads in %s/%d: %s/%d:\n", leader->comm, leader->pid, t->comm, t->pid);
+
+                if (tsk_rt(t)->heap_node == NULL) {
+                        retval = __litmus_admit_task(t);
+
+                        if (retval != 0) break;
+
+                        /* hasn't been admitted into rt. make it a slave. */
+                        tsk_rt(t)->slave = 1;
+                }
+                else if (is_realtime(t))
+                        if (litmus->compare(t, hp)) {
+                                hp = t;
+                        }
+                }
+
+                t = next_thread(t);
+        } while(t != leader);
+
+        if (hp) {
+                /* set up inheritance */
+                
+        }
+
+        read_unlock_irq(&tasklist_lock);
+
+        return 0;
+}
+
+
 /* p is a real-time task. Re-init its state as a best-effort task. */
 static void reinit_litmus_state(struct task_struct* p, int restore)
 {
@@ -318,32 +372,11 @@ static void reinit_litmus_state(struct task_struct* p, int restore)
         }
 }
 
-long litmus_admit_task(struct task_struct* tsk)
+long __litmus_admit_task(struct task_struct* tsk)
 {
         long retval = 0;
         unsigned long flags;
 
-        BUG_ON(is_realtime(tsk));
-
-        if (get_rt_relative_deadline(tsk) == 0 ||
-            get_exec_cost(tsk) >
-                        min(get_rt_relative_deadline(tsk), get_rt_period(tsk)) ) {
-                TRACE_TASK(tsk,
-                        "litmus admit: invalid task parameters "
-                        "(e = %lu, p = %lu, d = %lu)\n",
-                        get_exec_cost(tsk), get_rt_period(tsk),
-                        get_rt_relative_deadline(tsk));
-                retval = -EINVAL;
-                goto out;
-        }
-
-        if (!cpu_online(get_partition(tsk))) {
-                TRACE_TASK(tsk, "litmus admit: cpu %d is not online\n",
-                           get_partition(tsk));
-                retval = -EINVAL;
-                goto out;
-        }
-
         INIT_LIST_HEAD(&tsk_rt(tsk)->list);
 
         /* avoid scheduler plugin changing underneath us */
@@ -375,6 +408,38 @@ long litmus_admit_task(struct task_struct* tsk)
 
 out_unlock:
         raw_spin_unlock_irqrestore(&task_transition_lock, flags);
+
+        return retval;
+}
+
+long litmus_admit_task(struct task_struct* tsk)
+{
+        long retval = 0;
+        unsigned long flags;
+
+        BUG_ON(is_realtime(tsk));
+
+        if (get_rt_relative_deadline(tsk) == 0 ||
+            get_exec_cost(tsk) >
+                        min(get_rt_relative_deadline(tsk), get_rt_period(tsk)) ) {
+                TRACE_TASK(tsk,
+                        "litmus admit: invalid task parameters "
+                        "(e = %lu, p = %lu, d = %lu)\n",
+                        get_exec_cost(tsk), get_rt_period(tsk),
+                        get_rt_relative_deadline(tsk));
+                retval = -EINVAL;
+                goto out;
+        }
+
+        if (!cpu_online(get_partition(tsk))) {
+                TRACE_TASK(tsk, "litmus admit: cpu %d is not online\n",
+                           get_partition(tsk));
+                retval = -EINVAL;
+                goto out;
+        }
+
+        retval = __litmus_admit_task(tsk);
+
 out:
         return retval;
 }