/* Copyright (C) 2003 Russ Cox, Massachusetts Institute of Technology *//* See COPYRIGHT */ #include <u.h>#include <libc.h>#include <thread.h>#include <mux.h> enum{ STACK = 32768}; voidmuxprocs(Mux *mux){ proccreate(_muxrecvproc, mux, STACK); qlock(&mux->lk); while(!mux->readq) rsleep(&mux->rpcfork); qunlock(&mux->lk); proccreate(_muxsendproc, mux, STACK); qlock(&mux->lk); while(!mux->writeq) rsleep(&mux->rpcfork); qunlock(&mux->lk);}
/* Copyright (C) 2003 Russ Cox, Massachusetts Institute of Technology */
/* See COPYRIGHT */
#include <u.h>
#include <libc.h>
#include <thread.h>
#include <mux.h>
enum
{
STACK = 32768
};
void
muxprocs(Mux *mux)
{
proccreate(_muxrecvproc, mux, STACK);
qlock(&mux->lk);
while(!mux->readq)
rsleep(&mux->rpcfork);
qunlock(&mux->lk);
proccreate(_muxsendproc, mux, STACK);
qlock(&mux->lk);
while(!mux->writeq)
rsleep(&mux->rpcfork);
qunlock(&mux->lk);
}