diff options
| author | rsc <devnull@localhost> | 2003-12-06 18:08:52 +0000 |
|---|---|---|
| committer | rsc <devnull@localhost> | 2003-12-06 18:08:52 +0000 |
| commit | d3df308747ee4d1fcc063a348dcf1146b390bda7 (patch) | |
| tree | a204b027256ec29b110caaa86100cbd701808b5b /src/libmux/thread.c | |
| parent | e97ceade5e1bba5787e39429384336fa37797906 (diff) | |
| download | plan9port-d3df308747ee4d1fcc063a348dcf1146b390bda7.tar.gz plan9port-d3df308747ee4d1fcc063a348dcf1146b390bda7.tar.bz2 plan9port-d3df308747ee4d1fcc063a348dcf1146b390bda7.zip | |
File system stuff.
Diffstat (limited to 'src/libmux/thread.c')
| -rw-r--r-- | src/libmux/thread.c | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/src/libmux/thread.c b/src/libmux/thread.c new file mode 100644 index 00000000..1c643e06 --- /dev/null +++ b/src/libmux/thread.c @@ -0,0 +1,27 @@ +/* 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 +muxthreads(Mux *mux) +{ + proccreate(_muxrecvproc, mux, STACK); + qlock(&mux->lk); + while(!mux->writeq) + rsleep(&mux->rpcfork); + qunlock(&mux->lk); + proccreate(_muxsendproc, mux, STACK); + qlock(&mux->lk); + while(!mux->writeq) + rsleep(&mux->rpcfork); + qunlock(&mux->lk); +} |