843477d4cc
Add a queue offset to the tag map. This enables users to map iteratively, for each queue map type they support. Bump maximum number of supported maps to 2, we're now fully able to support more than 1 map. Reviewed-by: Hannes Reinecke <hare@suse.com> Reviewed-by: Keith Busch <keith.busch@intel.com> Reviewed-by: Sagi Grimberg <sagi@grimberg.me> Signed-off-by: Jens Axboe <axboe@kernel.dk>
54 lines
1.7 KiB
C
54 lines
1.7 KiB
C
/*
|
|
* Copyright (c) 2016 Christoph Hellwig.
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify it
|
|
* under the terms and conditions of the GNU General Public License,
|
|
* version 2, as published by the Free Software Foundation.
|
|
*
|
|
* This program is distributed in the hope it will be useful, but WITHOUT
|
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
* more details.
|
|
*/
|
|
#include <linux/device.h>
|
|
#include <linux/blk-mq.h>
|
|
#include <linux/blk-mq-virtio.h>
|
|
#include <linux/virtio_config.h>
|
|
#include <linux/module.h>
|
|
#include "blk-mq.h"
|
|
|
|
/**
|
|
* blk_mq_virtio_map_queues - provide a default queue mapping for virtio device
|
|
* @set: tagset to provide the mapping for
|
|
* @vdev: virtio device associated with @set.
|
|
* @first_vec: first interrupt vectors to use for queues (usually 0)
|
|
*
|
|
* This function assumes the virtio device @vdev has at least as many available
|
|
* interrupt vetors as @set has queues. It will then queuery the vector
|
|
* corresponding to each queue for it's affinity mask and built queue mapping
|
|
* that maps a queue to the CPUs that have irq affinity for the corresponding
|
|
* vector.
|
|
*/
|
|
int blk_mq_virtio_map_queues(struct blk_mq_queue_map *qmap,
|
|
struct virtio_device *vdev, int first_vec)
|
|
{
|
|
const struct cpumask *mask;
|
|
unsigned int queue, cpu;
|
|
|
|
if (!vdev->config->get_vq_affinity)
|
|
goto fallback;
|
|
|
|
for (queue = 0; queue < qmap->nr_queues; queue++) {
|
|
mask = vdev->config->get_vq_affinity(vdev, first_vec + queue);
|
|
if (!mask)
|
|
goto fallback;
|
|
|
|
for_each_cpu(cpu, mask)
|
|
qmap->mq_map[cpu] = qmap->queue_offset + queue;
|
|
}
|
|
|
|
return 0;
|
|
fallback:
|
|
return blk_mq_map_queues(qmap);
|
|
}
|
|
EXPORT_SYMBOL_GPL(blk_mq_virtio_map_queues);
|