diff options
author | aiju <aiju@phicode.de> | 2011-08-19 16:24:44 +0200 |
---|---|---|
committer | aiju <aiju@phicode.de> | 2011-08-19 16:24:44 +0200 |
commit | 9574793fc7c30c20bd544ee025f44bdd7bb72fd5 (patch) | |
tree | bd503d2f303cd5aa4775edd29124ebc904c7ecad /sys/src/lib9p | |
parent | f031d82662a6d4eef547b16e64e950584edf575c (diff) |
lib9p reqqueue: remove setjmp shit
Diffstat (limited to 'sys/src/lib9p')
-rw-r--r-- | sys/src/lib9p/queue.c | 30 |
1 files changed, 2 insertions, 28 deletions
diff --git a/sys/src/lib9p/queue.c b/sys/src/lib9p/queue.c index 307c385fc..4b4bde15f 100644 --- a/sys/src/lib9p/queue.c +++ b/sys/src/lib9p/queue.c @@ -5,18 +5,9 @@ #include <9p.h> static int -_reqqueuenote(void *uregs, char *note) +_reqqueuenote(void *, char *note) { - Reqqueue *q; - - if(strcmp(note, "flush") != 0) - return 0; - q = *threaddata(); - if(q != nil){ - q->cur = nil; - notejmp(uregs, q->flush, 1); - } - return 1; + return strcmp(note, "flush") == 0; } static void @@ -43,10 +34,6 @@ _reqqueueproc(void *v) memset(&r->qu, 0, sizeof(r->qu)); qunlock(&r->lk); q->cur = r; - if(setjmp(q->flush)){ - respond(r, "interrupted"); - continue; - } qunlock(q); f(r); } @@ -98,16 +85,3 @@ reqqueueflush(Reqqueue *q, Req *r) respond(r, "interrupted"); } } - -int -reqqueueflushed(void) -{ - Reqqueue *q; - - q = *threaddata(); - qlock(q); - if(setjmp(q->flush)) - return 1; - qunlock(q); - return 0; -} |