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.

2 files changed, 6 insertions, 1 deletions

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);