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
|
/*
* litmus/mc2_common.c
*
* Common functions for MC2 plugin.
*/
#include <linux/percpu.h>
#include <linux/sched.h>
#include <linux/list.h>
#include <linux/slab.h>
#include <asm/uaccess.h>
#include <litmus/litmus.h>
#include <litmus/sched_plugin.h>
#include <litmus/sched_trace.h>
#include <litmus/mc2_common.h>
long mc2_task_client_init(struct task_client *tc, struct mc2_task *mc2_param, struct task_struct *tsk, struct reservation *res)
{
task_client_init(tc, tsk, res);
if ((mc2_param->crit < CRIT_LEVEL_A) ||
(mc2_param->crit > CRIT_LEVEL_C))
return -EINVAL;
TRACE_TASK(tsk, "mc2_task_client_init: crit_level = %d\n", mc2_param->crit);
return 0;
}
asmlinkage long sys_set_mc2_task_param(pid_t pid, struct mc2_task __user * param)
{
struct task_struct *target;
int retval = -EINVAL;
struct mc2_task *mp = kzalloc(sizeof(*mp), GFP_KERNEL);
if (!mp)
return -ENOMEM;
printk("Setting up mc^2 task parameters for process %d.\n", pid);
if (pid < 0 || param == 0) {
goto out;
}
if (copy_from_user(mp, param, sizeof(*mp))) {
retval = -EFAULT;
goto out;
}
/* Task search and manipulation must be protected */
read_lock_irq(&tasklist_lock);
if (!(target = find_task_by_vpid(pid))) {
retval = -ESRCH;
goto out_unlock;
}
if (is_realtime(target)) {
/* The task is already a real-time task.
* We cannot not allow parameter changes at this point.
*/
retval = -EBUSY;
goto out_unlock;
}
if (mp->crit < CRIT_LEVEL_A || mp->crit >= NUM_CRIT_LEVELS) {
printk(KERN_INFO "litmus: real-time task %d rejected "
"because of invalid criticality level\n", pid);
goto out_unlock;
}
//target->rt_param.plugin_state = mp;
target->rt_param.mc2_data = mp;
retval = 0;
out_unlock:
read_unlock_irq(&tasklist_lock);
out:
return retval;
}
|
