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
|
implement RegPoll;
include "sys.m";
sys : Sys;
include "draw.m";
include "registries.m";
registries: Registries;
Attributes, Service: import registries;
RegPoll: module {
init: fn(nil: ref Draw->Context, argv: list of string);
};
init(nil: ref Draw->Context, argv: list of string)
{
sys = load Sys Sys->PATH;
if (sys == nil)
badmod(Sys->PATH);
registries = load Registries Registries->PATH;
if (registries == nil)
badmod(Registries->PATH);
registries->init();
if (len argv != 3)
usage();
regaddr := hd tl argv;
action := hd tl tl argv;
if (action != "up" && action != "down")
usage();
sys->pctl(sys->FORKNS, nil);
sys->unmount(nil, "/mnt/registry");
svc := ref Service(hd tl argv, Attributes.new(("auth", "none") :: nil));
for (;;) {
a := svc.attach(nil, nil);
if (a != nil && sys->mount(a.fd, nil, "/mnt/registry", Sys->MREPL, nil) != -1) {
if (action == "up")
return;
else
break;
}
sys->sleep(30000);
}
for (;;) {
fd := sys->open("/mnt/registry/new", sys->OREAD);
sys->sleep(30000);
if (fd == nil)
return;
}
}
badmod(path: string)
{
sys->print("RegPoll: failed to load: %s\n",path);
exit;
}
usage()
{
sys->print("usage: regpoll regaddr up | down\n");
raise "fail:usage";
}
|
