diff options
| author | cinap_lenrek <cinap_lenrek@gmx.de> | 2013-08-05 22:31:37 +0200 |
|---|---|---|
| committer | cinap_lenrek <cinap_lenrek@gmx.de> | 2013-08-05 22:31:37 +0200 |
| commit | cdc0b89d816aab6322e04f715019a7f8da2f2b75 (patch) | |
| tree | 35761b65d8bc9643427398006b74ecefa3353598 /sys/src/cmd/cwfs/main.c | |
| parent | 75e34ca08a98029f980ee402a13117a1b86aaac4 (diff) | |
fix this megashit
Diffstat (limited to 'sys/src/cmd/cwfs/main.c')
| -rw-r--r-- | sys/src/cmd/cwfs/main.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/sys/src/cmd/cwfs/main.c b/sys/src/cmd/cwfs/main.c index 8cf0ebc79..8f6f2a8e5 100644 --- a/sys/src/cmd/cwfs/main.c +++ b/sys/src/cmd/cwfs/main.c @@ -314,6 +314,8 @@ main(int argc, char **argv) printsizes(); } + qlock(&reflock); + qunlock(&reflock); serveq = newqueue(1000, "9P service"); /* tunable */ raheadq = newqueue(1000, "readahead"); /* tunable */ @@ -449,6 +451,7 @@ serve(void *) Msgbuf *mb; for (;;) { + qlock(&reflock); /* read 9P request from a network input process */ mb = fs_recv(serveq, 0); assert(mb->magic == Mbmagic); @@ -457,6 +460,7 @@ serve(void *) if (cp == nil) panic("serve: nil mb->chan"); rlock(&cp->reflock); + qunlock(&reflock); rlock(&mainlock); |