cwfs: rollback last change
the ref qlock is required to keep requests in order for flushes, sorry.
This commit is contained in:
parent
e3d9591283
commit
308bbffc33
2 changed files with 0 additions and 5 deletions
|
@ -56,7 +56,6 @@ Timet boottime;
|
||||||
Queue* serveq;
|
Queue* serveq;
|
||||||
Queue* raheadq;
|
Queue* raheadq;
|
||||||
Rabuf* rabuffree;
|
Rabuf* rabuffree;
|
||||||
QLock reflock;
|
|
||||||
Lock rabuflock;
|
Lock rabuflock;
|
||||||
Tlock tlocks[NTLOCK];
|
Tlock tlocks[NTLOCK];
|
||||||
Lock tlocklock;
|
Lock tlocklock;
|
||||||
|
|
|
@ -314,8 +314,6 @@ main(int argc, char **argv)
|
||||||
printsizes();
|
printsizes();
|
||||||
}
|
}
|
||||||
|
|
||||||
qlock(&reflock);
|
|
||||||
qunlock(&reflock);
|
|
||||||
serveq = newqueue(1000, "9P service"); /* tunable */
|
serveq = newqueue(1000, "9P service"); /* tunable */
|
||||||
raheadq = newqueue(1000, "readahead"); /* tunable */
|
raheadq = newqueue(1000, "readahead"); /* tunable */
|
||||||
|
|
||||||
|
@ -451,7 +449,6 @@ serve(void *)
|
||||||
Msgbuf *mb;
|
Msgbuf *mb;
|
||||||
|
|
||||||
for (;;) {
|
for (;;) {
|
||||||
qlock(&reflock);
|
|
||||||
/* read 9P request from a network input process */
|
/* read 9P request from a network input process */
|
||||||
mb = fs_recv(serveq, 0);
|
mb = fs_recv(serveq, 0);
|
||||||
assert(mb->magic == Mbmagic);
|
assert(mb->magic == Mbmagic);
|
||||||
|
@ -460,7 +457,6 @@ serve(void *)
|
||||||
if (cp == nil)
|
if (cp == nil)
|
||||||
panic("serve: nil mb->chan");
|
panic("serve: nil mb->chan");
|
||||||
rlock(&cp->reflock);
|
rlock(&cp->reflock);
|
||||||
qunlock(&reflock);
|
|
||||||
|
|
||||||
rlock(&mainlock);
|
rlock(&mainlock);
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue