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
|
#include "syslib.h"
#include <assert.h>
#include <machine/archtypes.h>
#include <minix/timers.h>
#include <minix/sched.h>
#include <string.h>
/*===========================================================================*
* sched_inherit *
*===========================================================================*/
int sched_inherit(endpoint_t scheduler_e,
endpoint_t schedulee_e, endpoint_t parent_e, unsigned maxprio,
endpoint_t *newscheduler_e)
{
int rv;
message m;
assert(_ENDPOINT_P(scheduler_e) >= 0);
assert(_ENDPOINT_P(schedulee_e) >= 0);
assert(_ENDPOINT_P(parent_e) >= 0);
assert(maxprio < NR_SCHED_QUEUES);
assert(newscheduler_e);
memset(&m, 0, sizeof(m));
m.m_lsys_sched_scheduling_start.endpoint = schedulee_e;
m.m_lsys_sched_scheduling_start.parent = parent_e;
m.m_lsys_sched_scheduling_start.maxprio = maxprio;
/* Send the request to the scheduler */
if ((rv = _taskcall(scheduler_e, SCHEDULING_INHERIT, &m))) {
return rv;
}
/* Store the process' scheduler. Note that this might not be the
* scheduler we sent the SCHEDULING_INHERIT message to. That scheduler
* might have forwarded the scheduling message on to another scheduler
* before returning the message.
*/
*newscheduler_e = m.m_sched_lsys_scheduling_start.scheduler;
return (OK);
}
/*===========================================================================*
* sched_start *
*===========================================================================*/
int sched_start(endpoint_t scheduler_e,
endpoint_t schedulee_e,
endpoint_t parent_e,
int maxprio,
int quantum,
int cpu,
endpoint_t *newscheduler_e)
{
int rv;
message m;
/* No scheduler given? We are done. */
if(scheduler_e == NONE) {
return OK;
}
assert(_ENDPOINT_P(schedulee_e) >= 0);
assert(_ENDPOINT_P(parent_e) >= 0);
assert(maxprio >= 0);
assert(maxprio < NR_SCHED_QUEUES);
assert(quantum > 0);
assert(newscheduler_e);
/* The KERNEL must schedule this process. */
if(scheduler_e == KERNEL) {
if ((rv = sys_schedctl(SCHEDCTL_FLAG_KERNEL,
schedulee_e, maxprio, quantum, cpu)) != OK) {
return rv;
}
*newscheduler_e = scheduler_e;
return OK;
}
/* A user-space scheduler must schedule this process. */
memset(&m, 0, sizeof(m));
m.m_lsys_sched_scheduling_start.endpoint = schedulee_e;
m.m_lsys_sched_scheduling_start.parent = parent_e;
m.m_lsys_sched_scheduling_start.maxprio = maxprio;
m.m_lsys_sched_scheduling_start.quantum = quantum;
/* Send the request to the scheduler */
if ((rv = _taskcall(scheduler_e, SCHEDULING_START, &m))) {
return rv;
}
/* Store the process' scheduler. Note that this might not be the
* scheduler we sent the SCHEDULING_START message to. That scheduler
* might have forwarded the scheduling message on to another scheduler
* before returning the message.
*/
*newscheduler_e = m.m_sched_lsys_scheduling_start.scheduler;
return (OK);
}
|
