blob: 7e7d268537fab1684473cb9a5128f86d1cfad1a3 (
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
implement ChanFill;
#
# Iobuf fill routine to serve a file2chan.
#
include "sys.m";
include "bufio.m";
myfill: BufioFill;
bufio: Bufio;
fid: int;
wc: Sys->Rwrite;
fio: ref Sys->FileIO;
Iobuf: import bufio;
init(data: array of byte, f: int, c: Sys->Rwrite, r: ref Sys->FileIO, b: Bufio): ref Iobuf
{
if (myfill == nil)
myfill = load BufioFill SELF;
bufio = b;
i := bufio->sopen(string data);
fid = f;
wc = c;
fio = r;
i.setfill(myfill);
wc <-= (len data, nil);
return i;
}
fill(b: ref Iobuf): int
{
for (;;) {
alt {
(nil, data, f, c) := <-fio.write =>
if (f != fid) {
if (c != nil)
c <-= (0, "file busy");
continue;
}
if (c == nil)
return Bufio->EOF;
c <-= (len data, nil);
i := len data;
if (i == 0)
continue;
b.buffer[b.size:] = data;
b.size += i;
b.filpos += big i;
return i;
* =>
return Bufio->EOF;
}
}
}
|
