paranoid android

7 files changed, 120 insertions, 42 deletions

diff --git a/include/litmus/budget.h b/include/litmus/budget.h
index 559cfcdda61a..062df818de45 100644
--- a/include/litmus/budget.h
+++ b/include/litmus/budget.h
@@ -7,6 +7,9 @@ void update_enforcement_timer(struct task_struct* t);
 
 void prepare_for_next_server(struct task_struct* t,int forced);
 
-#define job_behind(t) (lt_before_eq((t)->rt_param.job_params.deadline, \
-                                    (t)->rt_param.job_params.release))
+#define job_behind(t)\
+        (lt_before((t)->rt_param.job_params.real_release, get_release(t)))
+
+void server_release(struct task_struct *t);
+void task_release(struct task_struct *t);
 #endif
diff --git a/include/litmus/rt_param.h b/include/litmus/rt_param.h
index 221edad83d77..f15b1ad5fa3c 100644
--- a/include/litmus/rt_param.h
+++ b/include/litmus/rt_param.h
@@ -83,6 +83,9 @@ struct rt_job {
         /* What is the current deadline? */
         lt_t    deadline;
 
+        lt_t    real_release;
+        lt_t    real_deadline;
+
         /* How much service has this job received so far? */
         lt_t    exec_time;
 
@@ -209,6 +212,8 @@ struct rt_param {
 
         /* Pointer to the page shared between userspace and kernel. */
         struct control_page * ctrl_page;
+
+        /* int go; */
 };
 
 /*      Possible RT flags       */
diff --git a/litmus/budget.c b/litmus/budget.c
index 75f4b5156947..7d94f7e61b27 100644
--- a/litmus/budget.c
+++ b/litmus/budget.c
@@ -5,6 +5,7 @@
 #include <litmus/litmus.h>
 #include <litmus/preempt.h>
 #include <litmus/budget.h>
+#include <litmus/sched_trace.h>
 
 struct enforcement_timer {
         /* The enforcement timer is used to accurately police
@@ -63,7 +64,7 @@ static void arm_enforcement_timer(struct enforcement_timer* et,
 
         /* Calling this when there is no budget left for the task
          * makes no sense, unless the task is non-preemptive. */
-        BUG_ON(budget_exhausted(t) && (!is_np(t)));
+        /* BUG_ON(budget_exhausted(t) && (!is_np(t))); */
 
         /* __hrtimer_start_range_ns() cancels the timer
          * anyway, so we don't have to check whether it is still armed */
@@ -109,20 +110,38 @@ static int __init init_budget_enforcement(void)
         return 0;
 }
 
+void task_release(struct task_struct *t)
+{
+        t->rt_param.job_params.real_release = t->rt_param.job_params.deadline;
+        t->rt_param.job_params.real_deadline += get_rt_period(t);
+        t->rt_param.job_params.job_no++;
+        TRACE_TASK(t, "Releasing task, rr=%llu rd=%llu\n",
+                   t->rt_param.job_params.real_release,
+                   t->rt_param.job_params.real_deadline);
+        sched_trace_task_release(t);
+}
+
+void server_release(struct task_struct *t)
+{
+        lt_t now = litmus_clock();
+        t->rt_param.job_params.exec_time = 0;
+        t->rt_param.job_params.release = t->rt_param.job_params.deadline;
+        t->rt_param.job_params.deadline +=  get_rt_period(t);
+        TRACE_TASK(t, "Releasing server, r=%llu d=%llu\n",
+                   t->rt_param.job_params.release,
+                   t->rt_param.job_params.deadline);
+        /* don't confuse linux */
+        t->rt.time_slice = 1;
+}
+
 void prepare_for_next_server(struct task_struct *t, int forced)
 {
-        if (!job_behind(t)) {
-                t->rt_param.job_params.release   = t->rt_param.job_params.deadline;
-                t->rt_param.job_params.deadline += get_rt_period(t);
-                t->rt_param.job_params.exec_time = 0;
-                /* update job sequence number */
-                t->rt_param.job_params.job_no++;
-        } else if (forced) {
-                t->rt_param.job_params.release = t->rt_param.job_params.deadline;
-                t->rt_param.job_params.exec_time = 0;
-        } else /* behind */{
-                t->rt_param.job_params.deadline += get_rt_period(t);
-                t->rt_param.job_params.job_no++;
+        if (forced || job_behind(t)) {
+                server_release(t);
+        }
+
+        if (!forced) {
+                task_release(t);
         }
 }
 
diff --git a/litmus/jobs.c b/litmus/jobs.c
index 669a3df5fcc1..10a42db1165e 100644
--- a/litmus/jobs.c
+++ b/litmus/jobs.c
@@ -12,7 +12,9 @@ void prepare_for_next_period(struct task_struct *t)
         /* prepare next release */
 
         t->rt_param.job_params.release   = t->rt_param.job_params.deadline;
+        t->rt_param.job_params.real_release =  t->rt_param.job_params.release;
         t->rt_param.job_params.deadline += get_rt_period(t);
+        t->rt_param.job_params.real_deadline = t->rt_param.job_params.deadline;
         t->rt_param.job_params.exec_time = 0;
         /* update job sequence number */
         t->rt_param.job_params.job_no++;
diff --git a/litmus/rt_domain.c b/litmus/rt_domain.c
index 09123eeadf2c..5264d2546a7f 100644
--- a/litmus/rt_domain.c
+++ b/litmus/rt_domain.c
@@ -254,7 +254,7 @@ static void setup_release(rt_domain_t *_rt)
         list_for_each_safe(pos, safe, &list) {
                 /* pick task of work list */
                 t = list_entry(pos, struct task_struct, rt_param.list);
-                sched_trace_task_release(t);
+                /* sched_trace_task_release(t); */
                 list_del_init(pos);
 
                 /* put into release heap while holding release_lock */
@@ -410,14 +410,21 @@ static void pd_requeue(domain_t *dom, struct task_struct *task)
         BUG_ON(is_queued(task));
         BUG_ON(get_task_domain(task) != dom);
 
+        if (is_queued(task)) {
+                VTRACE_TASK(task, "Queued, skipping\n");
+                return;
+        }
+
         if (is_released(task, litmus_clock())) {
                 __add_ready(domain, task);
-                VTRACE("rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n",
+                /* tsk_rt(task)->go = 1; */
+                VTRACE("going, rt: adding %s/%d (%llu, %llu) rel=%llu to ready queue at %llu\n",
                       task->comm, task->pid, get_exec_cost(task), get_rt_period(task),
                       get_release(task), litmus_clock());
         } else {
                 /* task has to wait for next release */
-                VTRACE_TASK(task, "add release(), rel=%llu\n", get_release(task));
+                VTRACE_TASK(task, "not going, add release(), rel=%llu\n", get_release(task));
+                /* tsk_rt(task)->go = 0; */
                 add_release(domain, task);
         }
 
@@ -429,7 +436,12 @@ static void pd_requeue(domain_t *dom, struct task_struct *task)
  */
 static struct task_struct* pd_take_ready(domain_t *dom)
 {
-        return __take_ready((rt_domain_t*)dom->data);
+        struct task_struct *t = __take_ready((rt_domain_t*)dom->data);
+        if (t) {
+                /* TRACE_TASK(t, "going\n"); */
+                /* tsk_rt(t)->go = 1; */
+        }
+        return t;
 }
 
 /* pd_peek_ready - returns the head of the rt_domain ready queue
@@ -438,14 +450,23 @@ static struct task_struct* pd_take_ready(domain_t *dom)
  */