diff options
Diffstat (limited to 'litmus')
-rw-r--r-- | litmus/litmus.c | 7 | ||||
-rw-r--r-- | litmus/sched_cedf.c | 6 | ||||
-rw-r--r-- | litmus/sched_gsn_edf.c | 6 | ||||
-rw-r--r-- | litmus/sched_psn_edf.c | 6 |
4 files changed, 19 insertions, 6 deletions
diff --git a/litmus/litmus.c b/litmus/litmus.c index 99714d06eed5..86ad5b375934 100644 --- a/litmus/litmus.c +++ b/litmus/litmus.c | |||
@@ -112,6 +112,13 @@ asmlinkage long sys_set_rt_task_param(pid_t pid, struct rt_task __user * param) | |||
112 | "because wcet > period\n", pid); | 112 | "because wcet > period\n", pid); |
113 | goto out_unlock; | 113 | goto out_unlock; |
114 | } | 114 | } |
115 | if (tp.budget_policy != NO_ENFORCEMENT && | ||
116 | tp.budget_policy != QUANTUM_ENFORCEMENT) | ||
117 | { | ||
118 | printk(KERN_INFO "litmus: real-time task %d rejected " | ||
119 | "because unsupported budget enforcement policy specified\n", pid); | ||
120 | goto out_unlock; | ||
121 | } | ||
115 | 122 | ||
116 | target->rt_param.task_params = tp; | 123 | target->rt_param.task_params = tp; |
117 | 124 | ||
diff --git a/litmus/sched_cedf.c b/litmus/sched_cedf.c index 118fbd14fe25..82c9682eefbd 100644 --- a/litmus/sched_cedf.c +++ b/litmus/sched_cedf.c | |||
@@ -321,7 +321,7 @@ static noinline void job_completion(struct task_struct *t, int forced) | |||
321 | */ | 321 | */ |
322 | static void cedf_tick(struct task_struct* t) | 322 | static void cedf_tick(struct task_struct* t) |
323 | { | 323 | { |
324 | if (is_realtime(t) && budget_exhausted(t)) { | 324 | if (is_realtime(t) && budget_enforced(t) && budget_exhausted(t)) { |
325 | if (!is_np(t)) { | 325 | if (!is_np(t)) { |
326 | /* np tasks will be preempted when they become | 326 | /* np tasks will be preempted when they become |
327 | * preemptable again | 327 | * preemptable again |
@@ -379,7 +379,9 @@ static struct task_struct* cedf_schedule(struct task_struct * prev) | |||
379 | /* (0) Determine state */ | 379 | /* (0) Determine state */ |
380 | exists = entry->scheduled != NULL; | 380 | exists = entry->scheduled != NULL; |
381 | blocks = exists && !is_running(entry->scheduled); | 381 | blocks = exists && !is_running(entry->scheduled); |
382 | out_of_time = exists && budget_exhausted(entry->scheduled); | 382 | out_of_time = exists && |
383 | budget_enforced(entry->scheduled) && | ||
384 | budget_exhausted(entry->scheduled); | ||
383 | np = exists && is_np(entry->scheduled); | 385 | np = exists && is_np(entry->scheduled); |
384 | sleep = exists && get_rt_flags(entry->scheduled) == RT_F_SLEEP; | 386 | sleep = exists && get_rt_flags(entry->scheduled) == RT_F_SLEEP; |
385 | preempt = entry->scheduled != entry->linked; | 387 | preempt = entry->scheduled != entry->linked; |
diff --git a/litmus/sched_gsn_edf.c b/litmus/sched_gsn_edf.c index 7424c183d8b2..c0c63eba70ce 100644 --- a/litmus/sched_gsn_edf.c +++ b/litmus/sched_gsn_edf.c | |||
@@ -336,7 +336,7 @@ static noinline void job_completion(struct task_struct *t, int forced) | |||
336 | */ | 336 | */ |
337 | static void gsnedf_tick(struct task_struct* t) | 337 | static void gsnedf_tick(struct task_struct* t) |
338 | { | 338 | { |
339 | if (is_realtime(t) && budget_exhausted(t)) { | 339 | if (is_realtime(t) && budget_enforced(t) && budget_exhausted(t)) { |
340 | if (!is_np(t)) { | 340 | if (!is_np(t)) { |
341 | /* np tasks will be preempted when they become | 341 | /* np tasks will be preempted when they become |
342 | * preemptable again | 342 | * preemptable again |
@@ -399,7 +399,9 @@ static struct task_struct* gsnedf_schedule(struct task_struct * prev) | |||
399 | /* (0) Determine state */ | 399 | /* (0) Determine state */ |
400 | exists = entry->scheduled != NULL; | 400 | exists = entry->scheduled != NULL; |
401 | blocks = exists && !is_running(entry->scheduled); | 401 | blocks = exists && !is_running(entry->scheduled); |
402 | out_of_time = exists && budget_exhausted(entry->scheduled); | 402 | out_of_time = exists && |
403 | budget_enforced(entry->scheduled) && | ||
404 | budget_exhausted(entry->scheduled); | ||
403 | np = exists && is_np(entry->scheduled); | 405 | np = exists && is_np(entry->scheduled); |
404 | sleep = exists && get_rt_flags(entry->scheduled) == RT_F_SLEEP; | 406 | sleep = exists && get_rt_flags(entry->scheduled) == RT_F_SLEEP; |
405 | preempt = entry->scheduled != entry->linked; | 407 | preempt = entry->scheduled != entry->linked; |
diff --git a/litmus/sched_psn_edf.c b/litmus/sched_psn_edf.c index 7a548bf5162e..e50b27391d21 100644 --- a/litmus/sched_psn_edf.c +++ b/litmus/sched_psn_edf.c | |||
@@ -107,7 +107,7 @@ static void psnedf_tick(struct task_struct *t) | |||
107 | */ | 107 | */ |
108 | BUG_ON(is_realtime(t) && t != pedf->scheduled); | 108 | BUG_ON(is_realtime(t) && t != pedf->scheduled); |
109 | 109 | ||
110 | if (is_realtime(t) && budget_exhausted(t)) { | 110 | if (is_realtime(t) && budget_enforced(t) && budget_exhausted(t)) { |
111 | if (!is_np(t)) { | 111 | if (!is_np(t)) { |
112 | set_tsk_need_resched(t); | 112 | set_tsk_need_resched(t); |
113 | TRACE("psnedf_scheduler_tick: " | 113 | TRACE("psnedf_scheduler_tick: " |
@@ -143,7 +143,9 @@ static struct task_struct* psnedf_schedule(struct task_struct * prev) | |||
143 | /* (0) Determine state */ | 143 | /* (0) Determine state */ |
144 | exists = pedf->scheduled != NULL; | 144 | exists = pedf->scheduled != NULL; |
145 | blocks = exists && !is_running(pedf->scheduled); | 145 | blocks = exists && !is_running(pedf->scheduled); |
146 | out_of_time = exists && budget_exhausted(pedf->scheduled); | 146 | out_of_time = exists && |
147 | budget_enforced(pedf->scheduled) && | ||
148 | budget_exhausted(pedf->scheduled); | ||
147 | np = exists && is_np(pedf->scheduled); | 149 | np = exists && is_np(pedf->scheduled); |
148 | sleep = exists && get_rt_flags(pedf->scheduled) == RT_F_SLEEP; | 150 | sleep = exists && get_rt_flags(pedf->scheduled) == RT_F_SLEEP; |
149 | preempt = edf_preemption_needed(edf, prev); | 151 | preempt = edf_preemption_needed(edf, prev); |