summaryrefslogtreecommitdiffstats
path: root/src/kernel/mq.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/kernel/mq.c')
-rw-r--r--src/kernel/mq.c15
1 files changed, 13 insertions, 2 deletions
diff --git a/src/kernel/mq.c b/src/kernel/mq.c
index d83f7e4..34a8a5b 100644
--- a/src/kernel/mq.c
+++ b/src/kernel/mq.c
@@ -25,9 +25,9 @@
#include <linux/blk-mq.h>
/**
- * dnbd3_busy_iter - iterator for blk_mq_tagset_busy_iter
+ * dnbd3_busy_iter - iterator to set a bit for busy reqeust
* @req: the request
- * @priv: the passed argument from blk_mq_tagset_busy_iter
+ * @priv: the passed argument busy
* @arg: unknown
*/
static void dnbd3_busy_iter(struct request *req, void *priv, bool arg)
@@ -70,6 +70,13 @@ unsigned long dnbd3_is_mq_busy(struct dnbd3_device *dev)
return busy;
}
+
+/**
+ * dnbd3_busy_iter - iterator to requeue inflight commands
+ * @req: the request
+ * @priv: the passed argument from blk_mq_tagset_busy_iter
+ * @arg: unknown
+ */
static void dnbd3_busy_iter_requeue(struct request *req, void *priv, bool arg)
{
struct dnbd3_sock *sock = priv;
@@ -83,6 +90,10 @@ static void dnbd3_busy_iter_requeue(struct request *req, void *priv, bool arg)
mutex_unlock(&cmd->lock);
}
+/**
+ * dndb3_reque_busy_requests - reque busy (inflight) requests
+ * @sock: the socket
+ */
void dndb3_reque_busy_requests(struct dnbd3_sock *sock)
{
struct blk_mq_tag_set *set = &sock->device->tag_set;