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 *
respond(r, "interrupted");
}
}
+
+void
+reqqueuefree(Reqqueue *q)
+{
+ Req *r;
+
+ if(q == nil)
+ return;
+ r = emalloc9p(sizeof(Req));
+ reqqueuepush(q, r, nil);
+}