introduce release_at callback to LITMUS plugin interface

PFAIR needs to do things a bit differently. This callback
will allow plugins to  handle synchronous releases differently.

3 files changed, 9 insertions, 1 deletions

diff --git a/include/litmus/sched_plugin.h b/include/litmus/sched_plugin.h
index 872a7cbff3..5b4b430a5b 100644
--- a/include/litmus/sched_plugin.h
+++ b/include/litmus/sched_plugin.h
@@ -81,6 +81,8 @@ typedef long (*complete_job_t) (void);
 
 typedef long (*admit_task_t)(struct task_struct* tsk);
 
+typedef void (*release_at_t)(struct task_struct *t, lt_t start);
+
 struct sched_plugin {
         struct list_head        list;
         /*      basic info              */
@@ -95,6 +97,7 @@ struct sched_plugin {
 
         /*      syscall backend         */
         complete_job_t          complete_job;
+        release_at_t            release_at;
 
         /*      task state changes      */
         admit_task_t            admit_task;
diff --git a/litmus/sched_plugin.c b/litmus/sched_plugin.c
index f7eb116ee4..dbf709ee5e 100644
--- a/litmus/sched_plugin.c
+++ b/litmus/sched_plugin.c
@@ -10,6 +10,7 @@
 #include <litmus/litmus.h>
 #include <litmus/sched_plugin.h>
 
+#include <litmus/jobs.h>
 
 /*************************************************************
  *                   Dummy plugin functions                  *
@@ -129,6 +130,9 @@ int register_sched_plugin(struct sched_plugin* plugin)
         CHECK(pi_block);
         CHECK(admit_task);
 
+        if (!plugin->release_at)
+                plugin->release_at = release_at;
+
         spin_lock(&sched_plugins_lock);
         list_add(&plugin->list, &sched_plugins);
         spin_unlock(&sched_plugins_lock);
diff --git a/litmus/sync.c b/litmus/sync.c
index 7c6ff2f03f..c16f1dd2ab 100644
--- a/litmus/sync.c
+++ b/litmus/sync.c
@@ -11,6 +11,7 @@
 #include <linux/completion.h>
 
 #include <litmus/litmus.h>
+#include <litmus/sched_plugin.h>
 #include <litmus/jobs.h>
 
 static DECLARE_COMPLETION(ts_release);
@@ -47,7 +48,7 @@ static long do_release_ts(lt_t start)
                                                      struct __wait_queue,
                                                      task_list)->private;
                 task_count++;
-                release_at(t, start + t->rt_param.task_params.phase);
+                litmus->release_at(t, start + t->rt_param.task_params.phase);
         }
 
         spin_unlock_irqrestore(&ts_release.wait.lock, flags);