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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>
#include <sched.h>
#include "litmus.h"
#include "internal.h"
static void tperrorx(char* msg)
{
fprintf(stderr,
"Task %d: %s: %m",
gettid(), msg);
exit(-1);
}
/* common launch routine */
int __launch_rt_task(rt_fn_t rt_prog, void *rt_arg, rt_setup_fn_t setup,
void* setup_arg)
{
int ret;
int rt_task = fork();
if (rt_task == 0) {
/* we are the real-time task
* launch task and die when it is done
*/
rt_task = gettid();
ret = setup(rt_task, setup_arg);
if (ret < 0)
tperrorx("could not setup task parameters");
ret = task_mode(LITMUS_RT_TASK);
if (ret < 0)
tperrorx("could not become real-time task");
exit(rt_prog(rt_arg));
}
return rt_task;
}
int __create_rt_task(rt_fn_t rt_prog, void *arg, int cluster, int cluster_size,
lt_t wcet, lt_t period, unsigned int priority, task_class_t class)
{
struct rt_task params;
params.cpu = cluster_to_first_cpu(cluster, cluster_size);
params.period = period;
params.exec_cost = wcet;
params.cls = class;
params.phase = 0;
params.priority = priority;
/* enforce budget for tasks that might not use sleep_next_period() */
params.budget_policy = QUANTUM_ENFORCEMENT;
return __launch_rt_task(rt_prog, arg,
(rt_setup_fn_t) set_rt_task_param, ¶ms);
}
int create_rt_task(rt_fn_t rt_prog, void *arg, int cluster, int cluster_size,
lt_t wcet, lt_t period, unsigned int prio)
{
return __create_rt_task(rt_prog, arg, cluster, cluster_size, wcet, period,
prio, RT_CLASS_HARD);
}
#define SCHED_NORMAL 0
int task_mode(int mode)
{
struct sched_param param;
int me = gettid();
int policy = sched_getscheduler(gettid());
int old_mode = policy == SCHED_LITMUS ? LITMUS_RT_TASK : BACKGROUND_TASK;
param.sched_priority = 0;
if (old_mode == LITMUS_RT_TASK && mode == BACKGROUND_TASK) {
/* transition to normal task */
return sched_setscheduler(me, SCHED_NORMAL, ¶m);
} else if (old_mode == BACKGROUND_TASK && mode == LITMUS_RT_TASK) {
/* transition to RT task */
return sched_setscheduler(me, SCHED_LITMUS, ¶m);
} else {
errno = -EINVAL;
return -1;
}
}
|
