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
|
#include <gc/syscall.h>
#include <gc/mem.h>
#include <gc/server.h>
#include <gm/method.h>
#include <gm/call/manager.h>
#include <string.h>
char *loglevels[] = {"Critical", "Error", "Warning", "Notice", "Status", "Debug"};
int loglevel = LL_DEBUG;
struct service {
char* name;
int pid;
Object obj;
struct service *next;
};
struct service *services = 0;
//************************ FUNCTIONS THAT DO STUFF ********************
void logsvc(int pid, char* log, int level) {
if (level > loglevel || level < 0) return;
struct service *svc = services;
while (svc) {
if (svc->pid == pid) break;
svc = svc->next;
}
if (svc == 0) {
printk("[log:??] ");
} else {
printk("[log:"); printk(svc->name); printk("] ");
}
printk(loglevels[level]); printk(": ");
printk(log); printk("\n");
}
void registersvc(int pid, char* name, Object descriptor) {
struct service *svc = malloc(sizeof(struct service));
svc->name = strdup(name);
svc->pid = pid;
svc->obj = descriptor;
svc->next = services;
services = svc;
char msg[100] = "Service registered: ";
strcat(msg, svc->name);
logsvc(1, msg, LL_NOTICE);
}
//****************************** HANDLING METHODS ON MAIN OBJECT *****************
struct method_ret handle_nothing(struct method_data *d) {
if (d->blocking) logsvc(1, "Received a {nothing} request.", LL_DEBUG);
else logsvc(1, "Received a {nothing} message.", LL_DEBUG);
return mr_void();
}
struct method_ret handle_open(struct method_data *d) {
CHKSSTR(d, 0);
char *svc = d->parameters[0].p;
char *sep, *res;
sep = strchr(svc, ':');
if (sep != 0) *sep = '0';
struct service *s = services;
while (s) {
if (strcmp(s->name, svc) == 0) break;
s = s->next;
}
if (s == 0) return mr_err(-2);
if (sep == 0) {
return mr_obj(s->obj);
} else {
*sep = ':';
res = sep + 1;
// open service svc, ressource res
Object r = c_open(s->obj, 1, res);
if (r == -1) return mr_err(-3);
return mr_obj(r);
}
}
struct method_ret handle_registersvc(struct method_data *d) {
CHKSSTR(d, 0);
if (d->parameters[1].i == 0) return mr_err(-1);
registersvc(d->pid, d->parameters[0].p, d->parameters[1].i);
return mr_void();
}
struct method_ret handle_logsvc(struct method_data *d) {
CHKSSTR(d, 0);
logsvc(d->pid, d->parameters[0].p, d->parameters[1].i);
return mr_void();
}
int main() {
logsvc(1, "Manager module configuring...", LL_NOTICE);
registersvc(1, "manager", 0);
Server *mgr = srv_get(0);
srv_addHandler(mgr, M_NOTHING_VVVV, handle_nothing);
srv_addHandler(mgr, M_OPEN_OMVV, handle_open);
srv_addHandler(mgr, M_REGISTERSVC_VMOV, handle_registersvc);
srv_addHandler(mgr, M_LOGSVC_VMIV, handle_logsvc);
logsvc(1, "Manager module configured : starting request handling.", LL_STATUS);
srv_handle(mgr, HA_LOOP);
printk("[manager] Manager EPIC FAIL.\n");
return 0;
}
|
