#include <kern/thread.h>
+static void
+thread_recompute_priority(
+ thread_t thread);
+
kern_return_t
thread_policy_set(
thread_act_t act,
{
kern_return_t result = KERN_SUCCESS;
thread_t thread;
- task_t task;
spl_t s;
if (act == THR_ACT_NULL)
return (KERN_INVALID_ARGUMENT);
- act_lock(act);
- task = act->task;
- act_unlock(act);
-
- task_lock(task);
-
thread = act_lock_thread(act);
if (!act->active) {
act_unlock_thread(act);
- task_unlock(task);
return (KERN_TERMINATED);
}
- if (thread == THREAD_NULL) {
- act_unlock_thread(act);
- task_unlock(task);
-
- return (KERN_NOT_SUPPORTED);
- }
-
-#define thread_priority_set(thread, pri) \
-MACRO_BEGIN \
- if ((thread)->depress_priority >= 0) \
- (thread)->depress_priority = (pri); \
- else { \
- (thread)->priority = (pri); \
- compute_priority((thread), TRUE); \
- \
- if ((thread) == current_thread()) \
- ast_on(AST_BLOCK); \
- } \
-MACRO_END
+ assert(thread != THREAD_NULL);
switch (flavor) {
- case THREAD_STANDARD_POLICY:
+ case THREAD_EXTENDED_POLICY:
{
- integer_t priority;
+ boolean_t timeshare = TRUE;
+
+ if (count >= THREAD_EXTENDED_POLICY_COUNT) {
+ thread_extended_policy_t info;
+
+ info = (thread_extended_policy_t)policy_info;
+ timeshare = info->timeshare;
+ }
s = splsched();
thread_lock(thread);
- thread->sched_mode &=~ TH_MODE_REALTIME;
+ if (!(thread->sched_mode & TH_MODE_FAILSAFE)) {
+ thread->sched_mode &= ~TH_MODE_REALTIME;
- thread->policy = POLICY_TIMESHARE;
-
- if (thread->importance > MAXPRI)
- priority = MAXPRI;
- else
- if (thread->importance < -MAXPRI)
- priority = -MAXPRI;
- else
- priority = thread->importance;
-
- priority += task->priority;
+ if (timeshare)
+ thread->sched_mode |= TH_MODE_TIMESHARE;
+ else
+ thread->sched_mode &= ~TH_MODE_TIMESHARE;
- if (priority > thread->max_priority)
- priority = thread->max_priority;
- else
- if (priority < MINPRI)
- priority = MINPRI;
+ thread_recompute_priority(thread);
+ }
+ else {
+ thread->safe_mode &= ~TH_MODE_REALTIME;
- thread_priority_set(thread, priority);
+ if (timeshare)
+ thread->safe_mode |= TH_MODE_TIMESHARE;
+ else
+ thread->safe_mode &= ~TH_MODE_TIMESHARE;
+ }
thread_unlock(thread);
splx(s);
}
info = (thread_time_constraint_policy_t)policy_info;
+ if ( info->computation > max_rt_quantum ||
+ info->computation < min_rt_quantum ) {
+ result = KERN_INVALID_ARGUMENT;
+ break;
+ }
s = splsched();
thread_lock(thread);
- thread->sched_mode |= TH_MODE_REALTIME;
-
thread->realtime.period = info->period;
thread->realtime.computation = info->computation;
thread->realtime.constraint = info->constraint;
thread->realtime.preemptible = info->preemptible;
- thread->policy = POLICY_RR;
-
- thread_priority_set(thread, BASEPRI_REALTIME);
+ if (!(thread->sched_mode & TH_MODE_FAILSAFE)) {
+ thread->sched_mode &= ~TH_MODE_TIMESHARE;
+ thread->sched_mode |= TH_MODE_REALTIME;
+ thread_recompute_priority(thread);
+ }
+ else {
+ thread->safe_mode &= ~TH_MODE_TIMESHARE;
+ thread->safe_mode |= TH_MODE_REALTIME;
+ }
thread_unlock(thread);
splx(s);
thread->importance = info->importance;
- if (!(thread->sched_mode & TH_MODE_REALTIME)) {
- integer_t priority;
-
- if (thread->importance > MAXPRI)
- priority = MAXPRI;
- else
- if (thread->importance < -MAXPRI)
- priority = -MAXPRI;
- else
- priority = thread->importance;
-
- priority += task->priority;
-
- if (priority > thread->max_priority)
- priority = thread->max_priority;
- else
- if (priority < MINPRI)
- priority = MINPRI;
-
- thread_priority_set(thread, priority);
- }
+ thread_recompute_priority(thread);
thread_unlock(thread);
splx(s);
act_unlock_thread(act);
- task_unlock(task);
-
return (result);
}
+static void
+thread_recompute_priority(
+ thread_t thread)
+{
+ integer_t priority;
+
+ if (thread->sched_mode & TH_MODE_REALTIME)
+ priority = BASEPRI_REALTIME;
+ else {
+ if (thread->importance > MAXPRI)
+ priority = MAXPRI;
+ else
+ if (thread->importance < -MAXPRI)
+ priority = -MAXPRI;
+ else
+ priority = thread->importance;
+
+ priority += thread->task_priority;
+
+ if (priority > thread->max_priority)
+ priority = thread->max_priority;
+ else
+ if (priority < MINPRI)
+ priority = MINPRI;
+ }
+
+ if (thread->depress_priority >= 0)
+ thread->depress_priority = priority;
+ else {
+ thread->priority = priority;
+ compute_priority(thread, TRUE);
+
+ if (thread == current_thread())
+ ast_on(AST_BLOCK);
+ }
+}
+
+void
+thread_task_priority(
+ thread_t thread,
+ integer_t priority,
+ integer_t max_priority)
+{
+ spl_t s;
+
+ assert(thread != THREAD_NULL);
+
+ s = splsched();
+ thread_lock(thread);
+
+ thread->task_priority = priority;
+ thread->max_priority = max_priority;
+
+ thread_recompute_priority(thread);
+
+ thread_unlock(thread);
+ splx(s);
+}
+
kern_return_t
thread_policy_get(
thread_act_t act,
return (KERN_TERMINATED);
}
- if (thread == THREAD_NULL) {
- act_unlock_thread(act);
-
- return (KERN_NOT_SUPPORTED);
- }
+ assert(thread != THREAD_NULL);
switch (flavor) {
- case THREAD_STANDARD_POLICY:
- s = splsched();
- thread_lock(thread);
+ case THREAD_EXTENDED_POLICY:
+ {
+ boolean_t timeshare = TRUE;
- if (thread->sched_mode & TH_MODE_REALTIME)
- *get_default = TRUE;
+ if (!(*get_default)) {
+ s = splsched();
+ thread_lock(thread);
+
+ if ( !(thread->sched_mode & TH_MODE_REALTIME) &&
+ !(thread->safe_mode & TH_MODE_REALTIME) ) {
+ if (!(thread->sched_mode & TH_MODE_FAILSAFE))
+ timeshare = (thread->sched_mode & TH_MODE_TIMESHARE) != 0;
+ else
+ timeshare = (thread->safe_mode & TH_MODE_TIMESHARE) != 0;
+ }
+ else
+ *get_default = TRUE;
+
+ thread_unlock(thread);
+ splx(s);
+ }
+
+ if (*count >= THREAD_EXTENDED_POLICY_COUNT) {
+ thread_extended_policy_t info;
+
+ info = (thread_extended_policy_t)policy_info;
+ info->timeshare = timeshare;
+ }
- thread_unlock(thread);
- splx(s);
break;
+ }
case THREAD_TIME_CONSTRAINT_POLICY:
{
info = (thread_time_constraint_policy_t)policy_info;
- s = splsched();
- thread_lock(thread);
+ if (!(*get_default)) {
+ s = splsched();
+ thread_lock(thread);
- if ((thread->sched_mode & TH_MODE_REALTIME) && !(*get_default)) {
- info->period = thread->realtime.period;
- info->computation = thread->realtime.computation;
- info->constraint = thread->realtime.constraint;
- info->preemptible = thread->realtime.preemptible;
- }
- else {
- extern natural_t min_quantum_abstime;
+ if ( (thread->sched_mode & TH_MODE_REALTIME) ||
+ (thread->safe_mode & TH_MODE_REALTIME) ) {
+ info->period = thread->realtime.period;
+ info->computation = thread->realtime.computation;
+ info->constraint = thread->realtime.constraint;
+ info->preemptible = thread->realtime.preemptible;
+ }
+ else
+ *get_default = TRUE;
- *get_default = TRUE;
+ thread_unlock(thread);
+ splx(s);
+ }
+ if (*get_default) {
info->period = 0;
- info->computation = min_quantum_abstime / 2;
- info->constraint = min_quantum_abstime;
+ info->computation = std_quantum / 2;
+ info->constraint = std_quantum;
info->preemptible = TRUE;
}
- thread_unlock(thread);
- splx(s);
-
break;
}
info = (thread_precedence_policy_t)policy_info;
- if (*get_default)
- info->importance = 0;
- else {
+ if (!(*get_default)) {
s = splsched();
thread_lock(thread);
thread_unlock(thread);
splx(s);
}
+ else
+ info->importance = 0;
break;
}
projects / apple / xnu.git / blobdiff