From 27d2955ccf58fb1c0631c497c094d793572f980f Mon Sep 17 00:00:00 2001
From: aiju <aiju@phicode.de>
Date: Mon, 12 Oct 2015 10:41:40 +0200
Subject: lib9p: add reqqueuefree

---
 sys/src/lib9p/queue.c | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

(limited to 'sys/src/lib9p/queue.c')

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);
+}
-- 
cgit v1.2.3