ref: cae6aebb8f31e359fc872d4364962935bae703b7
dir: /rc/pin/
#!/bin/rc
rfork en
flagfmt = 'n:noattach, w:write, m:mtpt mtpt'
args = 'name [command]'
eval `''{aux/getflags $*} || exec aux/usage
srv = pin-$user
name = $1
if(~ $#name 0)
exec aux/usage
cmd = $*(2-)
if(~ $#cmd 0){
nocmd = 1
cmd = (rc -i)
}
if(~ $#mtpt 0)
mtpt = /n/pin
# Check if already mounted
if(! ~ `{walk -n0 -eq $mtpt} a000000000000000.0.80){
if(test -e /srv/$srv)
mount -c /srv/$srv $mtpt
if not
mq -s $srv -m $mtpt
}
mq = $mtpt/$name
if(~ $#write 1){
if(~ $nocmd 1)
exec cat >>$mq/0
if not
exec echo $cmd >>$mq/0
}
fn detach {
echo creating $mq >[1=2]
mkdir -p $mq
echo replay on >$mq/ctl
touch $mq/^(0 1 2 note)
$cmd <$mq/0 >>$mq/1 >>[2]$mq/2 &
cat $mq/note >/proc/$apid/notepg &
}
fn attach {
echo attaching $mq >[1=2]
rfork e
fn sigint {
echo -n interrupt >>$mq/note
status = interrupted
}
mq-cat $mq 0 1 2 &
cat </fd/0 >>$mq/0 &
wait $apid
while(~ $status interrupted)
wait $apid
}
if(! test -d $mq)
detach
if(~ $#noattach 0)
attach