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
|
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <limits.h>
#include <signal.h>
#include "litmus.h"
#include "common.h"
typedef struct {
int wait;
char * exec_path;
char ** argv;
} startup_info_t;
int launch(void *task_info_p) {
startup_info_t *info = (startup_info_t*) task_info_p;
int ret;
if (info->wait) {
ret = wait_for_ts_release();
if (ret != 0)
perror("wait_for_ts_release()");
}
ret = execvp(info->exec_path, info->argv);
perror("execv failed");
return ret;
}
void usage(char *error) {
fprintf(stderr, "%s\nUsage: rt_launch [-w][-v][-p partition/cluster [-z cluster size]][-q prio][-c hrt | srt | be] wcet period program [arg1 arg2 ...]\n"
"\t-w\tSynchronous release\n"
"\t-v\tVerbose\n"
"\t-p\tpartition or cluster\n"
"\t-z\tsize of cluster (default = 1 for partitioned)\n"
"\t-c\tClass\n"
"\twcet, period in ms\n"
"\tprogram to be launched\n",
error);
exit(1);
}
#define OPTSTR "p:z:c:vwq:"
int main(int argc, char** argv)
{
int ret;
lt_t wcet;
lt_t period;
int migrate = 0;
int cluster = 0;
int cluster_size = 1;
int opt;
int verbose = 0;
int wait = 0;
startup_info_t info;
task_class_t class = RT_CLASS_HARD;
unsigned int priority = LITMUS_LOWEST_PRIORITY;
while ((opt = getopt(argc, argv, OPTSTR)) != -1) {
switch (opt) {
case 'w':
wait = 1;
break;
case 'v':
verbose = 1;
break;
case 'p':
cluster = atoi(optarg);
migrate = 1;
break;
case 'z':
cluster_size = atoi(optarg);
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 ':':
usage("Argument missing.");
break;
case '?':
default:
usage("Bad argument.");
break;
}
}
signal(SIGUSR1, SIG_IGN);
if (argc - optind < 3)
usage("Arguments missing.");
wcet = ms2ns(atoi(argv[optind + 0]));
period = ms2ns(atoi(argv[optind + 1]));
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.");
}
info.exec_path = argv[optind + 2];
info.argv = argv + optind + 2;
info.wait = wait;
if (migrate) {
ret = be_migrate_to_cluster(cluster, cluster_size);
if (ret < 0)
bail_out("could not migrate to target partition or cluster");
}
ret = __create_rt_task(launch, &info, cluster, cluster_size, wcet, period,
priority, class);
if (ret < 0)
bail_out("could not create rt child process");
else if (verbose)
printf("%d\n", ret);
return 0;
}
|
