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
|
/* See LICENSE file for copyright and license details. */
#include "common.h"
USAGE("[file ...]")
int
main(int argc, char *argv[])
{
char buf[PIPE_BUF];
int *fds = alloca((size_t)argc * sizeof(*fds));
size_t i, n = 0, done;
ssize_t r, w, *ps;
UNOFLAGS(0);
signal(SIGPIPE, SIG_IGN);
fds[n++] = STDOUT_FILENO;
while (argc--)
fds[n++] = eopen(*argv++, O_WRONLY | O_CREAT | O_TRUNC, 0666);
ps = alloca(n * sizeof(*ps));
while (n) {
memset(ps, 0, n * sizeof(*ps));
r = read(STDIN_FILENO, buf, sizeof(buf));
if (r < 0)
eprintf("read <stdin>:");
if (!r)
break;
for (done = 0; done < n;) {
for (i = 0; i < n; i++) {
if (ps[i] == r)
continue;
w = write(fds[i], buf + ps[i], (size_t)(r - ps[i]));
if (w < 0) {
close(fds[i]);
n--;
memmove(fds + i, fds + i + 1, (n - i) * sizeof(*fds));
memmove(ps + i, ps + i + 1, (n - i) * sizeof(*ps));
}
ps[i] += w;
if (ps[i] == r)
done++;
}
}
}
return 0;
}
|
