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
|
#include "process.h"
#include "api/error.h"
#include "api/process.h"
#include "hal/smp.h"
#include "proc/scheduler.h"
#include "sys/objdir.h"
#include <string.h>
struct rbtree_node *pcb_tree;
pid_t __next_pid = 1;
int
pcb_new(jove_owned_obj_t *pcb_obj, size_t size, jove_owned_obj_t *rootdir_obj)
{
struct pcb_header *pcb_header = obj_deref(pcb_obj);
memset(pcb_header, 0, size);
pcb_header->size = size;
pcb_header->pid = __next_pid++;
pcb_header->rootdir = obj_release(rootdir_obj);
pcb_header->tree_node.get_key = (void*)pcb_getpid;
pcb_tree = rbtree_insert(pcb_tree, &pcb_header->tree_node);
pcb_header->state = PCB_STATE_EMBRYO;
pcb_header->ksp = (void*)pcb_obj + size - sizeof(uintmax_t);
return _pcb_new_arch((pcb_t*)pcb_header);
}
int
pcb_send(pcb_t *pcb, pid_t target, jove_owned_obj_t *subject, size_t timeout)
{
struct pcb_header *pcb_header = (struct pcb_header*)pcb;
struct pcb_header *target_pcb = (struct pcb_header*)rbtree_search(pcb_tree, target);
if(target_pcb == 0) {
return -EBADPROC;
}
if(target_pcb->recv.obj == NULL &&
(target_pcb->recv.pid == pcb_getpid(pcb) || target_pcb->recv.pid == 0))
{
target_pcb->recv.obj = subject;
target_pcb->recv.pid = pcb_getpid(pcb);
return scheduler_yield(target);
}
if(timeout == 0) {
return -EFULL;
}
pcb_header->send.obj = subject;
pcb_header->send.pid = target;
scheduler_block_for_mail(pcb_header, timeout, target);
if(pcb_header->send.obj) return -ETIMEOUT;
return 0;
}
int
pcb_recv(pcb_t *pcb, pid_t target, jove_owned_obj_t *dest_obj, size_t timeout)
{
struct pcb_header *pcb_header = (struct pcb_header*)pcb;
struct pcb_header *target_pcb = (struct pcb_header*)rbtree_search(pcb_tree, target);
if(target_pcb == 0) {
return -EBADPROC;
}
if(pcb_header->recv.obj) {
goto recv_success;
return 0;
}
if(timeout == 0) {
return -EEMPTY;
}
pcb_header->recv.pid = target;
scheduler_block_for_mail(pcb_header, timeout, target);
if(!pcb_header->recv.obj) {
pcb_header->recv.pid = -1;
return -ETIMEOUT;
}
recv_success:
objdir_swapobj(pcb_header->recv.obj, dest_obj);
obj_release(pcb_header->recv.obj);
pcb_header->recv.obj = 0;
pcb_header->recv.pid = -1;
return 0;
}
pcb_t *pcb_frompid(pid_t pid)
{
return (pcb_t*)rbtree_search((struct rbtree_node*)pcb_tree, pid);
}
jove_owned_obj_t*
process_current(void)
{
return processor_getpcb(((processor_t*)processor_current()));
}
pid_t
pcb_getpid(pcb_t *pcb)
{
return ((struct pcb_header*)pcb)->pid;
}
jove_obj_t*
pcb_getrootdir(pcb_t *pcb)
{
return ((struct pcb_header*)pcb)->rootdir;
}
jove_owned_obj_t*
pcb_getpagedir(jove_owned_obj_t *rootdir_obj)
{
return objdir_getlocal(rootdir_obj, PCB_ROOTDIR_PAGEDIR_I);
}
jove_owned_obj_t*
pcb_getself(jove_owned_obj_t *rootdir_obj)
{
return objdir_getlocal(rootdir_obj, PCB_ROOTDIR_SELF_I);
}
enum pcb_state
pcb_getstate(pcb_t *pcb)
{
return ((struct pcb_header*)pcb)->state;
}
intmax_t
pcb_getstatecode(pcb_t *pcb)
{
return ((struct pcb_header*)pcb)->state_code;
}
void*
pcb_getksp(pcb_t *pcb)
{
return ((struct pcb_header*)pcb)->ksp;
}
void**
pcb_getksp_ref(pcb_t *pcb)
{
return &((struct pcb_header*)pcb)->ksp;
}
|
