Commit b461dfc4 authored by Christoph Hellwig's avatar Christoph Hellwig Committed by Jens Axboe
Browse files

blk-mq: add the blk_mq_alloc_disk APIs 



Add a new API to allocate a gendisk including the request_queue for use
with blk-mq based drivers.  This is to avoid boilerplate code in drivers.

Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarChaitanya Kulkarni <chaitanya.kulkarni@wdc.com>
Link: https://lore.kernel.org/r/20210602065345.355274-4-hch@lst.de


Signed-off-by: default avatarJens Axboe <axboe@kernel.dk>
parent 26a9750a

block/blk-mq.c

+19 −0
Original line number Diff line number Diff line
@@ -3137,6 +3137,25 @@ struct request_queue *blk_mq_init_queue(struct blk_mq_tag_set *set) 
}

EXPORT_SYMBOL(blk_mq_init_queue);



struct gendisk *__blk_mq_alloc_disk(struct blk_mq_tag_set *set, void *queuedata)

{

	struct request_queue *q;

	struct gendisk *disk;



	q = blk_mq_init_queue_data(set, queuedata);

	if (IS_ERR(q))

		return ERR_CAST(q);



	disk = __alloc_disk_node(0, set->numa_node);

	if (!disk) {

		blk_cleanup_queue(q);

		return ERR_PTR(-ENOMEM);

	}

	disk->queue = q;

	return disk;

}

EXPORT_SYMBOL(__blk_mq_alloc_disk);



/*

 * Helper for setting up a queue with mq ops, given queue depth, and

 * the passed in mq ops flags.

include/linux/blk-mq.h

+12 −0
Original line number Diff line number Diff line
@@ -426,6 +426,18 @@ enum { 
	((policy & ((1 << BLK_MQ_F_ALLOC_POLICY_BITS) - 1)) \

		<< BLK_MQ_F_ALLOC_POLICY_START_BIT)



#define blk_mq_alloc_disk(set, queuedata)				\

({									\

	static struct lock_class_key __key;				\

	struct gendisk *__disk = __blk_mq_alloc_disk(set, queuedata);	\

									\

	if (__disk)							\

		lockdep_init_map(&__disk->lockdep_map,			\

			"(bio completion)", &__key, 0);			\

	__disk;								\

})

struct gendisk *__blk_mq_alloc_disk(struct blk_mq_tag_set *set,

		void *queuedata);

struct request_queue *blk_mq_init_queue(struct blk_mq_tag_set *);

struct request_queue *blk_mq_init_queue_data(struct blk_mq_tag_set *set,

		void *queuedata);