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
|
#include <sys/msg.h>
#include <sys/syscall.h>
#include <sys/vfs.h>
#include <string.h>
using namespace Systemcalls;
msg_q_t msg_q_create()
{
return (msg_q_t) _syscall0(MSGQ_CREATE);
}
int msg_q_destroy(msg_q_t q)
{
return (int64_t)_syscall1(MSGQ_DESTROY, q);
}
int msg_q_register(msg_q_t q, const char* name)
{
if (0 == strcmp(VFS_ROOT, name))
{
return (int64_t)_syscall1(MSGQ_REGISTER_ROOT, q);
}
else
{
msg_q_t vfsQ = (msg_q_t)_syscall0(MSGQ_RESOLVE_ROOT);
msg_t* msg = msg_allocate();
msg->type = VFS_MSG_REGISTER_MSGQ;
msg->extra_data = (void*) name;
int rc = msg_sendrecv(vfsQ, msg);
msg_free(msg);
return rc;
}
}
msg_q_t msg_q_resolve(const char* name)
{
if (0 == strcmp(VFS_ROOT, name))
{
return (msg_q_t)_syscall0(MSGQ_RESOLVE_ROOT);
}
else
{
msg_q_t vfsQ = (msg_q_t)_syscall0(MSGQ_RESOLVE_ROOT);
msg_t* msg = msg_allocate();
msg->type = VFS_MSG_RESOLVE_MSGQ;
msg->extra_data = (void*) name;
msg_sendrecv(vfsQ, msg);
msg_q_t rc = (msg_q_t) msg->data[0];
msg_free(msg);
return rc;
}
}
int msg_send(msg_q_t q, msg_t* msg)
{
return (int64_t)_syscall2(MSG_SEND, q, msg);
}
int msg_sendrecv(msg_q_t q, msg_t* msg)
{
return (int64_t)_syscall2(MSG_SENDRECV, q, msg);
}
int msg_respond(msg_q_t q, msg_t* msg)
{
return (int64_t)_syscall2(MSG_RESPOND, q, msg);
}
msg_t* msg_wait(msg_q_t q)
{
return (msg_t*)_syscall1(MSG_WAIT, q);
}
|
