blob: 763b31c0e9f643b5e233fae58d78203986cd6e4c (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
#ifndef _LITMUS_BUDGET_H_
#define _LITMUS_BUDGET_H_
/* Update the per-processor enforcement timer (arm/reproram/cancel) for
* the next task. */
void update_enforcement_timer(struct task_struct* t);
/* Send SIG_BUDGET to a real-time task. */
void send_sigbudget(struct task_struct* t);
inline static int budget_exhausted(struct task_struct* t)
{
return get_exec_time(t) >= get_exec_cost(t);
}
inline static lt_t budget_remaining(struct task_struct* t)
{
if (!budget_exhausted(t))
return get_exec_cost(t) - get_exec_time(t);
else
/* avoid overflow */
return 0;
}
#define budget_enforced(t) (\
tsk_rt(t)->task_params.budget_policy != NO_ENFORCEMENT)
#define budget_precisely_tracked(t) (\
tsk_rt(t)->task_params.budget_policy == PRECISE_ENFORCEMENT || \
tsk_rt(t)->task_params.budget_signal_policy == PRECISE_SIGNALS)
#define budget_signalled(t) (\
tsk_rt(t)->task_params.budget_signal_policy != NO_SIGNALS)
#define budget_precisely_signalled(t) (\
tsk_rt(t)->task_params.budget_policy == PRECISE_SIGNALS)
#define sigbudget_sent(t) (\
test_bit(RT_JOB_SIG_BUDGET_SENT, &tsk_rt(t)->job_params.flags))
static inline int requeue_preempted_job(struct task_struct* t)
{
/* Add task to ready queue only if not subject to budget enforcement or
* if the job has budget remaining. t may be NULL.
*/
return t && (!budget_exhausted(t) || !budget_enforced(t));
}
#endif
|
