mirror of
https://github.com/torvalds/linux.git
synced 2025-08-15 14:11:42 +02:00
blk-mq: add number of queue calc helper
Add two variants of helper functions that calculate the correct number of queues to use. Two variants are needed because some drivers base their maximum number of queues on the possible CPU mask, while others use the online CPU mask. Reviewed-by: Christoph Hellwig <hch@lst.de> Reviewed-by: Hannes Reinecke <hare@suse.de> Reviewed-by: Ming Lei <ming.lei@redhat.com> Signed-off-by: Daniel Wagner <wagi@kernel.org> Reviewed-by: Chaitanya Kulkarni <kch@nvidia.com> Link: https://lore.kernel.org/r/20250617-isolcpus-queue-counters-v1-2-13923686b54b@kernel.org Signed-off-by: Jens Axboe <axboe@kernel.dk>
This commit is contained in:
parent
b6139a6abf
commit
3f27c1de5d
2 changed files with 42 additions and 0 deletions
|
@ -12,10 +12,50 @@
|
|||
#include <linux/cpu.h>
|
||||
#include <linux/group_cpus.h>
|
||||
#include <linux/device/bus.h>
|
||||
#include <linux/sched/isolation.h>
|
||||
|
||||
#include "blk.h"
|
||||
#include "blk-mq.h"
|
||||
|
||||
static unsigned int blk_mq_num_queues(const struct cpumask *mask,
|
||||
unsigned int max_queues)
|
||||
{
|
||||
unsigned int num;
|
||||
|
||||
num = cpumask_weight(mask);
|
||||
return min_not_zero(num, max_queues);
|
||||
}
|
||||
|
||||
/**
|
||||
* blk_mq_num_possible_queues - Calc nr of queues for multiqueue devices
|
||||
* @max_queues: The maximum number of queues the hardware/driver
|
||||
* supports. If max_queues is 0, the argument is
|
||||
* ignored.
|
||||
*
|
||||
* Calculates the number of queues to be used for a multiqueue
|
||||
* device based on the number of possible CPUs.
|
||||
*/
|
||||
unsigned int blk_mq_num_possible_queues(unsigned int max_queues)
|
||||
{
|
||||
return blk_mq_num_queues(cpu_possible_mask, max_queues);
|
||||
}
|
||||
EXPORT_SYMBOL_GPL(blk_mq_num_possible_queues);
|
||||
|
||||
/**
|
||||
* blk_mq_num_online_queues - Calc nr of queues for multiqueue devices
|
||||
* @max_queues: The maximum number of queues the hardware/driver
|
||||
* supports. If max_queues is 0, the argument is
|
||||
* ignored.
|
||||
*
|
||||
* Calculates the number of queues to be used for a multiqueue
|
||||
* device based on the number of online CPUs.
|
||||
*/
|
||||
unsigned int blk_mq_num_online_queues(unsigned int max_queues)
|
||||
{
|
||||
return blk_mq_num_queues(cpu_online_mask, max_queues);
|
||||
}
|
||||
EXPORT_SYMBOL_GPL(blk_mq_num_online_queues);
|
||||
|
||||
void blk_mq_map_queues(struct blk_mq_queue_map *qmap)
|
||||
{
|
||||
const struct cpumask *masks;
|
||||
|
|
|
@ -947,6 +947,8 @@ int blk_mq_freeze_queue_wait_timeout(struct request_queue *q,
|
|||
void blk_mq_unfreeze_queue_non_owner(struct request_queue *q);
|
||||
void blk_freeze_queue_start_non_owner(struct request_queue *q);
|
||||
|
||||
unsigned int blk_mq_num_possible_queues(unsigned int max_queues);
|
||||
unsigned int blk_mq_num_online_queues(unsigned int max_queues);
|
||||
void blk_mq_map_queues(struct blk_mq_queue_map *qmap);
|
||||
void blk_mq_map_hw_queues(struct blk_mq_queue_map *qmap,
|
||||
struct device *dev, unsigned int offset);
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue