diff options
| author | cinap_lenrek <cinap_lenrek@felloff.net> | 2015-10-15 13:22:48 +0200 |
|---|---|---|
| committer | cinap_lenrek <cinap_lenrek@felloff.net> | 2015-10-15 13:22:48 +0200 |
| commit | 2f99484b9dac562ce5faf8d9a652151a9a864b3e (patch) | |
| tree | 23ed983a14f4fd47300cf55f23d6da13d817591d /sys/src/lib9p | |
| parent | a034e629f7611166cae617b08b19667925fc4305 (diff) | |
| parent | 27d2955ccf58fb1c0631c497c094d793572f980f (diff) | |
merge
Diffstat (limited to 'sys/src/lib9p')
| -rw-r--r-- | sys/src/lib9p/queue.c | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/sys/src/lib9p/queue.c b/sys/src/lib9p/queue.c index 971e8a78d..478f40ddd 100644 --- a/sys/src/lib9p/queue.c +++ b/sys/src/lib9p/queue.c @@ -35,8 +35,14 @@ _reqqueueproc(void *v) memset(&r->qu, 0, sizeof(r->qu)); q->cur = r; qunlock(q); + if(f == nil) + break; f(r); } + + free(r); + free(q); + threadexits(nil); } Reqqueue * @@ -83,3 +89,14 @@ reqqueueflush(Reqqueue *q, Req *r) respond(r, "interrupted"); } } + +void +reqqueuefree(Reqqueue *q) +{ + Req *r; + + if(q == nil) + return; + r = emalloc9p(sizeof(Req)); + reqqueuepush(q, r, nil); +} |