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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <limits.h>
#include <signal.h>
#include "litmus.h"
#include "common.h"
const char *usage_msg =
"Usage: rt_launch OPTIONS wcet period program [arg1 arg2 ...]\n"
" -w wait for synchronous release\n"
" -v verbose (prints PID)\n"
" -p CPU physical partition or cluster to assign to\n"
" -r VCPU virtual CPU to attach to (irrelevant to most plugins)\n"
" -d DEADLINE relative deadline, implicit by default (in ms)\n"
" -o OFFSET offset (also known as phase), zero by default (in ms)\n"
" -q PRIORITY priority to use (ignored by EDF plugins, highest=1, lowest=511)\n"
" -c be|srt|hrt task class (best-effort, soft real-time, hard real-time)\n"
" -e turn off budget enforcement (DANGEROUS: can result in lockup)\n"
" wcet, period reservation parameters (in ms)\n"
" program path to the binary to be launched\n"
"\n";
void usage(char *error) {
fprintf(stderr, "%s\n%s", error, usage_msg);
exit(1);
}
#define OPTSTR "wp:q:c:er:b:o:d:vh"
int main(int argc, char** argv)
{
int ret, opt;
lt_t wcet;
lt_t period;
lt_t offset;
lt_t deadline;
double wcet_ms, period_ms, offset_ms, deadline_ms;
unsigned int priority;
int migrate;
int cluster;
int reservation;
int wait;
int want_enforcement;
int verbose;
task_class_t class;
struct rt_task param;
/* Reasonable defaults */
verbose = 0;
offset_ms = 0;
deadline_ms = 0;
priority = LITMUS_LOWEST_PRIORITY;
want_enforcement = 1; /* safety: default to enforcement */
wait = 0; /* don't wait for task system release */
class = RT_CLASS_SOFT; /* ignored by most plugins */
migrate = 0; /* assume global unless -p is specified */
cluster = -1; /* where to migrate to, invalid by default */
reservation = -1; /* set if task should attach to virtual CPU */
while ((opt = getopt(argc, argv, OPTSTR)) != -1) {
switch (opt) {
case 'w':
wait = 1;
break;
case 'p':
cluster = atoi(optarg);
migrate = 1;
break;
case 'q':
priority = atoi(optarg);
if (!litmus_is_valid_fixed_prio(priority))
usage("Invalid priority.");
break;
case 'c':
class = str2class(optarg);
if (class == -1)
usage("Unknown task class.");
break;
case 'e':
want_enforcement = 0;
break;
case 'r':
reservation = atoi(optarg);
break;
case 'o':
offset_ms = atof(optarg);
break;
case 'd':
deadline_ms = atof(optarg);
if (!deadline_ms || deadline_ms < 0) {
usage("The relative deadline must be a positive"
" number.");
}
break;
case 'v':
verbose = 1;
break;
case 'h':
usage("");
break;
case ':':
usage("Argument missing.");
break;
case '?':
default:
usage("Bad argument.");
break;
}
}
signal(SIGUSR1, SIG_IGN);
if (argc - optind < 3)
usage("Arguments missing.");
wcet_ms = atof(argv[optind + 0]);
period_ms = atof(argv[optind + 1]);
wcet = ms2ns(wcet_ms);
period = ms2ns(period_ms);
offset = ms2ns(offset_ms);
deadline = ms2ns(deadline_ms);
if (wcet <= 0)
usage("The worst-case execution time must be a "
"positive number.");
if (period <= 0)
usage("The period must be a positive number.");
if (wcet > period) {
usage("The worst-case execution time must not "
"exceed the period.");
}
if (migrate) {
ret = be_migrate_to_domain(cluster);
if (ret < 0)
bail_out("could not migrate to target partition or cluster.");
}
init_rt_task_param(¶m);
param.exec_cost = wcet;
param.period = period;
param.phase = offset;
param.relative_deadline = deadline;
param.priority = priority;
param.cls = class;
param.budget_policy = (want_enforcement) ?
PRECISE_ENFORCEMENT : NO_ENFORCEMENT;
if (migrate) {
if (reservation >= 0)
param.cpu = reservation;
else
param.cpu = domain_to_first_cpu(cluster);
}
ret = set_rt_task_param(gettid(), ¶m);
if (ret < 0)
bail_out("could not setup rt task params");
init_litmus();
ret = task_mode(LITMUS_RT_TASK);
if (ret != 0)
bail_out("could not become RT task");
if (verbose)
printf("%d\n", gettid());
if (wait) {
ret = wait_for_ts_release();
if (ret != 0)
bail_out("wait_for_ts_release()");
}
execvp(argv[optind + 2], argv + optind + 2);
perror("execv failed");
return 1;
}
|
