blob: ab1c679a53906c85d1ef9d32d70854c3e5772f7e (
plain)
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
|
Messages: module
{
PATH: con "/dis/collab/lib/messages.dis";
Msg: adt {
from: cyclic ref User;
data: array of byte;
next: cyclic ref Msg;
};
Msglist: adt {
tail: ref Msg;
readers: list of (ref User, ref Readreq);
new: fn(): ref Msglist;
flushfid: fn(nil: self ref Msglist, fid: int);
flushtag: fn(nil: self ref Msglist, tag: int);
wait: fn(nil: self ref Msglist, u: ref User, r: ref Readreq);
write: fn(nil: self ref Msglist, m: ref Msg): list of (ref User, ref Readreq);
queue: fn(nil: self ref Msglist): ref Msg;
};
Readreq: adt {
tag: int;
fid: int;
count: int;
offset: big;
};
User: adt {
id: int;
fid: int;
name: string;
queue: cyclic ref Msg;
new: fn(fid: int, name: string): ref User;
initqueue: fn(nil: self ref User, msgs: ref Msglist);
read: fn(nil: self ref User): ref Msg;
};
init: fn();
};
|
