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
|
#include "rtapp_args.h"
void
usage (const char* msg)
{
printf("usage: rt-app [options] -t <period>:<exec>[:$POLICY[:deadline[:prio]]] -t ...\n\n");
printf("-h, --help\t:\tshow this help\n");
printf("-f, --fifo\t:\tset default policy for threads to SCHED_FIFO\n");
printf("-r, --rr\t:\tset default policy fior threads to SCHED_RR\n");
printf("-s, --spacing\t:\tmsec to wait beetween thread starts\n");
printf("-l, --logdir\t:\tsave logs to different directory\n");
printf("-b, --baselog\t:\tbasename for logs (implies -l . if not set)\n");
printf("-G, --gnuplot\t:\tgenerate gnuplot script (needs -l)\n");
printf("-D, --duration\t:\ttime (in seconds) before stopping threads\n");
#ifdef HAVE_LIBQRESLIB
printf("-q, --qos\t:\tcreate AQuoSA reservation\n");
printf("-g, --frag\t:\tfragment for the reservation\n\n");
printf("POLICY: f=SCHED_FIFO, r=SCHED_RR, o=SCHED_OTHER, q=AQuoSA\n");
printf("when using AQuoSA scheduling, priority is used as"
" percent increment \nfor budget over exec time\n");
#else
printf("\nPOLICY: f=SCHED_FIFO, r=SCHED_RR, o=SCHED_OTHER\n");
#endif
if (msg != NULL)
printf("\n%s\n", msg);
exit(0);
}
void
parse_thread_args(char *arg, struct thread_data *tdata, policy_t def_policy)
{
char *str = strdup(arg);
char *token;
long period, exec, deadline;
char tmp[256];
int i = 0;
token = strtok(str, ":");
tdata->sched_prio = DEFAULT_THREAD_PRIORITY;
tdata->sched_policy = def_policy;
while ( token != NULL)
{
switch(i) {
case 0:
period = strtol(token, NULL, 10);
if (period <= 0 )
usage("Cannot set negative period.");
tdata->period = usec_to_timespec(period);
i++;
break;
case 1:
exec = strtol(token,NULL, 10);
//TODO: add support for max_et somehow
if (exec > period)
usage("Exec time cannot be greater than"
" period.");
if (exec <= 0 )
usage("Cannot set negative exec time");
tdata->min_et = usec_to_timespec(exec);
tdata->max_et = usec_to_timespec(exec);
i++;
break;
case 2:
#ifdef HAVE_LIBQRESLIB
if (strcmp(token,"q") == 0)
tdata->sched_policy = aquosa;
else
#endif
if (strcmp(token,"f") == 0)
tdata->sched_policy = fifo;
else if (strcmp(token,"r") == 0)
tdata->sched_policy = rr ;
else if (strcmp(token,"o") == 0)
tdata->sched_policy = other;
else {
snprintf(tmp, 256,
"Invalid scheduling policy %s in %s",
token, arg);
usage(tmp);
}
i++;
break;
case 3:
deadline = strtol(token, NULL, 10);
if (deadline < exec)
usage ("Deadline cannot be less than "
"execution time");
if (deadline > period)
usage ("Deadline cannot be greater than "
"period");
if (deadline <= 0 )
usage ("Cannot set negative deadline");
tdata->deadline = usec_to_timespec(deadline);
i++;
break;
case 4:
tdata->sched_prio = strtol(token, NULL, 10);
// do not check, will fail in pthread_setschedparam
i++;
break;
}
token = strtok(NULL, ":");
}
if ( i < 2 ) {
printf("Period and exec time are mandatory\n");
exit(EXIT_FAILURE);
}
if ( i < 3 )
tdata->sched_policy = other;
if ( i < 4 )
tdata->sched_prio = DEFAULT_THREAD_PRIORITY;
if ( i < 5 )
tdata->deadline = usec_to_timespec(period);
// descriptive name for policy
switch(tdata->sched_policy)
{
case rr:
sprintf(tdata->sched_policy_descr, "SCHED_RR");
break;
case fifo:
sprintf(tdata->sched_policy_descr, "SCHED_FIFO");
break;
case other:
sprintf(tdata->sched_policy_descr, "SCHED_OTHER");
break;
#ifdef HAVE_LIBQRESLIB
case aquosa:
sprintf(tdata->sched_policy_descr, "AQuoSA");
break;
#endif
}
free(str);
}
|
