lib9p: add reqqueuefree

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);
+}