Blob
1 /* Copyright (C) 2003 Russ Cox, Massachusetts Institute of Technology */2 /* See COPYRIGHT */4 #include <u.h>5 #include <libc.h>6 #include <thread.h>7 #include <mux.h>9 enum10 {11 STACK = 3276812 };14 void15 muxprocs(Mux *mux)16 {17 proccreate(_muxrecvproc, mux, STACK);18 qlock(&mux->lk);19 while(!mux->readq)20 rsleep(&mux->rpcfork);21 qunlock(&mux->lk);22 proccreate(_muxsendproc, mux, STACK);23 qlock(&mux->lk);24 while(!mux->writeq)25 rsleep(&mux->rpcfork);26 qunlock(&mux->lk);27 }