qio: Add callbacks for unblocking queues
[akaros.git] / kern / include / ns.h
index 533d2b0..4531883 100644 (file)
@@ -813,6 +813,9 @@ void qreopen(struct queue *);
 void qsetlimit(struct queue *, int);
 int qwindow(struct queue *);
 int qwrite(struct queue *, void *, int);
+typedef void (*qio_wake_cb_t)(struct queue *q, void *data, int filter);
+void qio_set_wake_cb(struct queue *q, qio_wake_cb_t func, void *data);
+
 void randominit(void);
 uint32_t randomread(void *, uint32_t);
 void *realloc(void *, uint32_t);