summaryrefslogtreecommitdiff
path: root/sys/src/lib9p
diff options
context:
space:
mode:
authoraiju <aiju@phicode.de>2011-08-19 16:24:44 +0200
committeraiju <aiju@phicode.de>2011-08-19 16:24:44 +0200
commit9574793fc7c30c20bd544ee025f44bdd7bb72fd5 (patch)
treebd503d2f303cd5aa4775edd29124ebc904c7ecad /sys/src/lib9p
parentf031d82662a6d4eef547b16e64e950584edf575c (diff)
lib9p reqqueue: remove setjmp shit
Diffstat (limited to 'sys/src/lib9p')
-rw-r--r--sys/src/lib9p/queue.c30
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;
-}