Re: [9fans] just in case anyone has written this

[andrey mirtchovski <mirtchovski@gmail.com>]

the p9p version of xcpu used to do something similar, but the old svn
repository is gone now so i can't verify. i see an old version of rx.c
in 9grid:/usr/andrey/src/xcpu/rx.c which does something similar to
what you want with threads, channels and procs but doesn't combine the
input.

it doesn't look finished, so it may be useless. it creates a proc for
each remote host :(

it does something like this (from a perfunctory look, it's been a while):

---
# shared between all procs
create input chan
create output chan

for each node create a proc that:
    connects to node and set up a session
    creates proc for stdout
    creates proc for stderr
    waits on input chan for commands to send to the node

stdout and stderr procs do:
    read from remote host
    write to output chan
---

the aggregator part you want can be inserted between read the output
chan and whatever you need to output to, but that logic doesn't exist
in rx.c, i think :)