2 files changed, 17 insertions, 3 deletions

diff --git a/src/litmus.c b/src/litmus.c
index b339e62..33e1a6d 100644
--- a/src/litmus.c
+++ b/src/litmus.c
@@ -29,8 +29,6 @@ task_class_t str2class(const char* str)
                 return -1;
 }
 
-#define NS_PER_MS 1000000
-
 /* only for best-effort execution: migrate to target_cpu */
 int be_migrate_to(int target_cpu)
 {
@@ -45,7 +43,7 @@ int sporadic_task(lt_t e, lt_t p, lt_t phase,
                   int cpu, task_class_t cls,
                   budget_policy_t budget_policy, int set_cpu_set)
 {
-        return sporadic_task_ns(e * NS_PER_MS, p * NS_PER_MS, phase * NS_PER_MS,
+        return sporadic_task_ns(e * __NS_PER_MS, p * __NS_PER_MS, phase * __NS_PER_MS,
                                 cpu, cls, budget_policy, set_cpu_set);
 }
 
@@ -69,6 +67,7 @@ int sporadic_task_ns(lt_t e, lt_t p, lt_t phase,
         return set_rt_task_param(gettid(), &param);
 }
 
+/* Sporadic task helper function for Semi-Partitioned algorithms. */
 int sporadic_task_ns_edffm(lt_t e, lt_t p, lt_t phase, int cpu,
                 lt_t *frac1, lt_t *frac2, int cpu1, int cpu2,
                 task_class_t cls, budget_policy_t budget_policy,
@@ -124,6 +123,16 @@ int sporadic_task_ns_npsf(lt_t e, lt_t p, lt_t phase,
         return set_rt_task_param(gettid(), &param);
 }
 
+int sporadic_task_ns_semi(struct rt_task *param)
+{
+        int ret;
+
+        ret = be_migrate_to(param->cpu);
+        check("migrate to cpu");
+
+        return set_rt_task_param(gettid(), param);
+}
+
 int init_kernel_iface(void);
 
 int init_litmus(void)
diff --git a/src/task.c b/src/task.c
index 2db9c98..daf95ca 100644
--- a/src/task.c
+++ b/src/task.c
@@ -108,6 +108,11 @@ int create_rt_task(rt_fn_t rt_prog, void *arg, int cpu, int wcet, int period) {
         return __create_rt_task(rt_prog, arg, cpu, wcet, period, RT_CLASS_HARD);
 }
 
+int create_rt_task_semi(rt_fn_t rt_prog, void *arg, struct rt_task *params)
+{
+        return __launch_rt_task(rt_prog, arg,
+                        (rt_setup_fn_t) set_rt_task_param, params);
+}
 
 #define SCHED_NORMAL 0
 #define SCHED_LITMUS 6