/linux-6.14.4/rust/kernel/block/mq/ |
D | tag_set.rs | 44 let tag_set: bindings::blk_mq_tag_set = unsafe { core::mem::zeroed() }; in new() localVariable 45 let tag_set = core::mem::size_of::<RequestDataWrapper>() in new() localVariable 58 ..tag_set in new() 63 inner <- PinInit::<_, error::Error>::pin_chain(Opaque::new(tag_set?), |tag_set| { in new() 65 let tag_set = unsafe { Pin::get_unchecked_mut(tag_set) }; in new() localVariable 67 error::to_result( unsafe { bindings::blk_mq_alloc_tag_set(tag_set.get())}) in new()
|
/linux-6.14.4/drivers/s390/block/ |
D | dasd_genhd.c | 55 block->tag_set.ops = &dasd_mq_ops; in dasd_gendisk_alloc() 56 block->tag_set.cmd_size = sizeof(struct dasd_ccw_req); in dasd_gendisk_alloc() 57 block->tag_set.nr_hw_queues = nr_hw_queues; in dasd_gendisk_alloc() 58 block->tag_set.queue_depth = queue_depth; in dasd_gendisk_alloc() 59 block->tag_set.numa_node = NUMA_NO_NODE; in dasd_gendisk_alloc() 60 rc = blk_mq_alloc_tag_set(&block->tag_set); in dasd_gendisk_alloc() 64 gdp = blk_mq_alloc_disk(&block->tag_set, &lim, block); in dasd_gendisk_alloc() 66 blk_mq_free_tag_set(&block->tag_set); in dasd_gendisk_alloc() 124 blk_mq_free_tag_set(&block->tag_set); in dasd_gendisk_free()
|
D | scm_blk.c | 460 bdev->tag_set.ops = &scm_mq_ops; in scm_blk_dev_setup() 461 bdev->tag_set.cmd_size = sizeof(blk_status_t); in scm_blk_dev_setup() 462 bdev->tag_set.nr_hw_queues = nr_requests; in scm_blk_dev_setup() 463 bdev->tag_set.queue_depth = nr_requests_per_io * nr_requests; in scm_blk_dev_setup() 464 bdev->tag_set.numa_node = NUMA_NO_NODE; in scm_blk_dev_setup() 466 ret = blk_mq_alloc_tag_set(&bdev->tag_set); in scm_blk_dev_setup() 470 bdev->gendisk = blk_mq_alloc_disk(&bdev->tag_set, &lim, scmdev); in scm_blk_dev_setup() 502 blk_mq_free_tag_set(&bdev->tag_set); in scm_blk_dev_setup() 512 blk_mq_free_tag_set(&bdev->tag_set); in scm_blk_dev_cleanup()
|
/linux-6.14.4/drivers/md/ |
D | dm-rq.c | 543 md->tag_set = kzalloc_node(sizeof(struct blk_mq_tag_set), GFP_KERNEL, md->numa_node_id); in dm_mq_init_request_queue() 544 if (!md->tag_set) in dm_mq_init_request_queue() 547 md->tag_set->ops = &dm_mq_ops; in dm_mq_init_request_queue() 548 md->tag_set->queue_depth = dm_get_blk_mq_queue_depth(); in dm_mq_init_request_queue() 549 md->tag_set->numa_node = md->numa_node_id; in dm_mq_init_request_queue() 550 md->tag_set->flags = BLK_MQ_F_STACKING; in dm_mq_init_request_queue() 551 md->tag_set->nr_hw_queues = dm_get_blk_mq_nr_hw_queues(); in dm_mq_init_request_queue() 552 md->tag_set->driver_data = md; in dm_mq_init_request_queue() 554 md->tag_set->cmd_size = sizeof(struct dm_rq_target_io); in dm_mq_init_request_queue() 558 md->tag_set->cmd_size += immutable_tgt->per_io_data_size; in dm_mq_init_request_queue() [all …]
|
/linux-6.14.4/drivers/block/ |
D | z2ram.c | 310 static struct blk_mq_tag_set tag_set; variable 321 disk = blk_mq_alloc_disk(&tag_set, NULL, NULL); in z2ram_register_disk() 352 tag_set.ops = &z2_mq_ops; in z2_init() 353 tag_set.nr_hw_queues = 1; in z2_init() 354 tag_set.nr_maps = 1; in z2_init() 355 tag_set.queue_depth = 16; in z2_init() 356 tag_set.numa_node = NUMA_NO_NODE; in z2_init() 357 ret = blk_mq_alloc_tag_set(&tag_set); in z2_init() 370 blk_mq_free_tag_set(&tag_set); in z2_init() 386 blk_mq_free_tag_set(&tag_set); in z2_exit()
|
D | nbd.c | 117 struct blk_mq_tag_set tag_set; member 269 blk_mq_free_tag_set(&nbd->tag_set); in nbd_dev_remove() 480 (config->num_connections == 1 && nbd->tag_set.timeout)) { in nbd_xmit_timeout() 513 if (!nbd->tag_set.timeout) { in nbd_xmit_timeout() 883 if (hwq < nbd->tag_set.nr_hw_queues) in nbd_handle_reply() 884 req = blk_mq_tag_to_rq(nbd->tag_set.tags[hwq], in nbd_handle_reply() 1050 blk_mq_tagset_busy_iter(&nbd->tag_set, nbd_clear_req, NULL); in nbd_clear_que() 1332 if (nbd->tag_set.timeout) in nbd_reconnect_socket() 1333 sock->sk->sk_sndtimeo = nbd->tag_set.timeout; in nbd_reconnect_socket() 1452 nbd->tag_set.timeout = 0; in nbd_config_put() [all …]
|
D | virtio_blk.c | 71 struct blk_mq_tag_set tag_set; member 1479 memset(&vblk->tag_set, 0, sizeof(vblk->tag_set)); in virtblk_probe() 1480 vblk->tag_set.ops = &virtio_mq_ops; in virtblk_probe() 1481 vblk->tag_set.queue_depth = queue_depth; in virtblk_probe() 1482 vblk->tag_set.numa_node = NUMA_NO_NODE; in virtblk_probe() 1483 vblk->tag_set.cmd_size = in virtblk_probe() 1486 vblk->tag_set.driver_data = vblk; in virtblk_probe() 1487 vblk->tag_set.nr_hw_queues = vblk->num_vqs; in virtblk_probe() 1488 vblk->tag_set.nr_maps = 1; in virtblk_probe() 1490 vblk->tag_set.nr_maps = 3; in virtblk_probe() [all …]
|
D | ataflop.c | 305 struct blk_mq_tag_set tag_set; member 2001 disk = blk_mq_alloc_disk(&unit[drive].tag_set, &lim, NULL); in ataflop_alloc_disk() 2055 blk_mq_free_tag_set(&unit[i].tag_set); in atari_floppy_cleanup() 2073 blk_mq_free_tag_set(&fs->tag_set); in atari_cleanup_floppy_disk() 2086 memset(&unit[i].tag_set, 0, sizeof(unit[i].tag_set)); in atari_floppy_init() 2087 unit[i].tag_set.ops = &ataflop_mq_ops; in atari_floppy_init() 2088 unit[i].tag_set.nr_hw_queues = 1; in atari_floppy_init() 2089 unit[i].tag_set.nr_maps = 1; in atari_floppy_init() 2090 unit[i].tag_set.queue_depth = 2; in atari_floppy_init() 2091 unit[i].tag_set.numa_node = NUMA_NO_NODE; in atari_floppy_init() [all …]
|
D | ps3disk.c | 32 struct blk_mq_tag_set tag_set; member 437 error = blk_mq_alloc_sq_tag_set(&priv->tag_set, &ps3disk_mq_ops, 1, 0); in ps3disk_probe() 441 gendisk = blk_mq_alloc_disk(&priv->tag_set, &lim, dev); in ps3disk_probe() 474 blk_mq_free_tag_set(&priv->tag_set); in ps3disk_probe() 500 blk_mq_free_tag_set(&priv->tag_set); in ps3disk_remove()
|
D | xen-blkfront.c | 226 struct blk_mq_tag_set tag_set; member 1120 memset(&info->tag_set, 0, sizeof(info->tag_set)); in xlvbd_alloc_gendisk() 1121 info->tag_set.ops = &blkfront_mq_ops; in xlvbd_alloc_gendisk() 1122 info->tag_set.nr_hw_queues = info->nr_rings; in xlvbd_alloc_gendisk() 1130 info->tag_set.queue_depth = BLK_RING_SIZE(info) / 2; in xlvbd_alloc_gendisk() 1132 info->tag_set.queue_depth = BLK_RING_SIZE(info); in xlvbd_alloc_gendisk() 1133 info->tag_set.numa_node = NUMA_NO_NODE; in xlvbd_alloc_gendisk() 1134 info->tag_set.cmd_size = sizeof(struct blkif_req); in xlvbd_alloc_gendisk() 1135 info->tag_set.driver_data = info; in xlvbd_alloc_gendisk() 1137 err = blk_mq_alloc_tag_set(&info->tag_set); in xlvbd_alloc_gendisk() [all …]
|
/linux-6.14.4/drivers/mmc/core/ |
D | queue.c | 384 disk = blk_mq_alloc_disk(&mq->tag_set, &lim, mq); in mmc_alloc_disk() 432 memset(&mq->tag_set, 0, sizeof(mq->tag_set)); in mmc_init_queue() 433 mq->tag_set.ops = &mmc_mq_ops; in mmc_init_queue() 439 mq->tag_set.queue_depth = in mmc_init_queue() 442 mq->tag_set.queue_depth = MMC_QUEUE_DEPTH; in mmc_init_queue() 443 mq->tag_set.numa_node = NUMA_NO_NODE; in mmc_init_queue() 444 mq->tag_set.flags = BLK_MQ_F_BLOCKING; in mmc_init_queue() 445 mq->tag_set.nr_hw_queues = 1; in mmc_init_queue() 446 mq->tag_set.cmd_size = sizeof(struct mmc_queue_req); in mmc_init_queue() 447 mq->tag_set.driver_data = mq; in mmc_init_queue() [all …]
|
/linux-6.14.4/drivers/mtd/ubi/ |
D | block.c | 85 struct blk_mq_tag_set tag_set; member 383 dev->tag_set.ops = &ubiblock_mq_ops; in ubiblock_create() 384 dev->tag_set.queue_depth = 64; in ubiblock_create() 385 dev->tag_set.numa_node = NUMA_NO_NODE; in ubiblock_create() 386 dev->tag_set.flags = BLK_MQ_F_BLOCKING; in ubiblock_create() 387 dev->tag_set.cmd_size = sizeof(struct ubiblock_pdu); in ubiblock_create() 388 dev->tag_set.driver_data = dev; in ubiblock_create() 389 dev->tag_set.nr_hw_queues = 1; in ubiblock_create() 391 ret = blk_mq_alloc_tag_set(&dev->tag_set); in ubiblock_create() 400 gd = blk_mq_alloc_disk(&dev->tag_set, &lim, dev); in ubiblock_create() [all …]
|
/linux-6.14.4/block/ |
D | bsg-lib.c | 22 struct blk_mq_tag_set tag_set; member 279 container_of(q->tag_set, struct bsg_set, tag_set); in bsg_queue_rq() 324 container_of(q->tag_set, struct bsg_set, tag_set); in bsg_remove_queue() 329 blk_mq_free_tag_set(&bset->tag_set); in bsg_remove_queue() 338 container_of(rq->q->tag_set, struct bsg_set, tag_set); in bsg_timeout() 378 set = &bset->tag_set; in bsg_setup_queue()
|
D | blk-mq-sched.c | 383 if (blk_mq_is_shared_tags(q->tag_set->flags)) { in blk_mq_sched_alloc_map_and_rqs() 388 hctx->sched_tags = blk_mq_alloc_map_and_rqs(q->tag_set, hctx_idx, in blk_mq_sched_alloc_map_and_rqs() 422 struct blk_mq_tag_set *set = queue->tag_set; in blk_mq_init_sched_shared_tags() 442 unsigned int flags = q->tag_set->flags; in blk_mq_init_sched() 453 q->nr_requests = 2 * min_t(unsigned int, q->tag_set->queue_depth, in blk_mq_init_sched() 511 if (blk_mq_is_shared_tags(q->tag_set->flags)) { in blk_mq_sched_free_rqs() 512 blk_mq_free_rqs(q->tag_set, q->sched_shared_tags, in blk_mq_sched_free_rqs() 517 blk_mq_free_rqs(q->tag_set, in blk_mq_sched_free_rqs()
|
D | blk-mq-sysfs.c | 232 mutex_lock(&q->tag_set->tag_list_lock); in blk_mq_sysfs_register() 238 mutex_unlock(&q->tag_set->tag_list_lock); in blk_mq_sysfs_register() 246 mutex_unlock(&q->tag_set->tag_list_lock); in blk_mq_sysfs_register() 259 mutex_lock(&q->tag_set->tag_list_lock); in blk_mq_sysfs_unregister() 262 mutex_unlock(&q->tag_set->tag_list_lock); in blk_mq_sysfs_unregister()
|
D | blk-mq.h | 84 return xa_load(&q->hctx_table, q->tag_set->map[type].mq_map[cpu]); in blk_mq_map_queue_type() 433 if ((q)->tag_set->flags & BLK_MQ_F_BLOCKING) { \ 434 struct blk_mq_tag_set *__tag_set = (q)->tag_set; \ 454 q->tag_set->map[HCTX_TYPE_POLL].nr_queues; in blk_mq_can_poll()
|
D | blk-mq-tag.c | 272 struct blk_mq_tag_set *set = q->tag_set; in bt_iter() 508 if (blk_mq_is_shared_tags(q->tag_set->flags)) { in blk_mq_queue_tag_busy_iter() 509 struct blk_mq_tags *tags = q->tag_set->shared_tags; in blk_mq_queue_tag_busy_iter() 601 struct blk_mq_tag_set *set = hctx->queue->tag_set; in blk_mq_tag_update_depth() 649 q->nr_requests - q->tag_set->reserved_tags); in blk_mq_tag_update_sched_shared_tags()
|
/linux-6.14.4/drivers/net/ethernet/mellanox/mlx5/core/steering/hws/ |
D | definer.c | 133 (fc)->tag_set = &hws_definer_generic_set; \ 345 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 350 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 355 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 360 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 365 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 370 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 375 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 380 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_steering_ok_bits_handler() 400 fc->tag_set = &hws_definer_generic_set; in hws_definer_flex_parser_handler() [all …]
|
/linux-6.14.4/rust/kernel/block/ |
D | mq.rs | 94 mod tag_set; module 98 pub use tag_set::TagSet;
|
/linux-6.14.4/drivers/mtd/ |
D | mtd_blkdevs.c | 33 blk_mq_free_tag_set(dev->tag_set); in blktrans_dev_release() 34 kfree(dev->tag_set); in blktrans_dev_release() 327 new->tag_set = kzalloc(sizeof(*new->tag_set), GFP_KERNEL); in add_mtd_blktrans_dev() 328 if (!new->tag_set) in add_mtd_blktrans_dev() 331 ret = blk_mq_alloc_sq_tag_set(new->tag_set, &mtd_mq_ops, 2, in add_mtd_blktrans_dev() 343 gd = blk_mq_alloc_disk(new->tag_set, &lim, new); in add_mtd_blktrans_dev() 396 blk_mq_free_tag_set(new->tag_set); in add_mtd_blktrans_dev() 398 kfree(new->tag_set); in add_mtd_blktrans_dev()
|
/linux-6.14.4/drivers/block/null_blk/ |
D | main.c | 72 static struct blk_mq_tag_set tag_set; variable 407 set = dev->nullb->tag_set; in nullb_update_nr_hw_queues() 1721 if (nullb->tag_set == &nullb->__tag_set) in null_del_dev() 1722 blk_mq_free_tag_set(nullb->tag_set); in null_del_dev() 1787 if (tag_set.ops) in null_init_global_tag_set() 1790 tag_set.nr_hw_queues = g_submit_queues; in null_init_global_tag_set() 1791 tag_set.queue_depth = g_hw_queue_depth; in null_init_global_tag_set() 1792 tag_set.numa_node = g_home_node; in null_init_global_tag_set() 1794 tag_set.flags |= BLK_MQ_F_NO_SCHED_BY_DEFAULT; in null_init_global_tag_set() 1796 tag_set.flags |= BLK_MQ_F_TAG_HCTX_SHARED; in null_init_global_tag_set() [all …]
|
/linux-6.14.4/include/scsi/ |
D | scsi_tcq.h | 32 if (hwq < shost->tag_set.nr_hw_queues) { in scsi_host_find_tag() 33 req = blk_mq_tag_to_rq(shost->tag_set.tags[hwq], in scsi_host_find_tag()
|
/linux-6.14.4/drivers/block/rnbd/ |
D | rnbd-clt.c | 737 if (sess->tag_set.tags) in destroy_mq_tags() 738 blk_mq_free_tag_set(&sess->tag_set); in destroy_mq_tags() 1206 struct blk_mq_tag_set *tag_set = &sess->tag_set; in setup_mq_tags() local 1208 memset(tag_set, 0, sizeof(*tag_set)); in setup_mq_tags() 1209 tag_set->ops = &rnbd_mq_ops; in setup_mq_tags() 1210 tag_set->queue_depth = sess->queue_depth; in setup_mq_tags() 1211 tag_set->numa_node = NUMA_NO_NODE; in setup_mq_tags() 1212 tag_set->flags = BLK_MQ_F_TAG_QUEUE_SHARED; in setup_mq_tags() 1213 tag_set->cmd_size = sizeof(struct rnbd_iu) + RNBD_RDMA_SGL_SIZE; in setup_mq_tags() 1216 tag_set->nr_maps = sess->nr_poll_queues ? HCTX_MAX_TYPES : 2; in setup_mq_tags() [all …]
|
/linux-6.14.4/drivers/scsi/ |
D | scsi_lib.c | 1973 struct Scsi_Host *shost = container_of(set, struct Scsi_Host, tag_set); in scsi_map_queues() 2070 struct blk_mq_tag_set *tag_set = &shost->tag_set; in scsi_mq_setup_tags() local 2079 memset(tag_set, 0, sizeof(*tag_set)); in scsi_mq_setup_tags() 2081 tag_set->ops = &scsi_mq_ops; in scsi_mq_setup_tags() 2083 tag_set->ops = &scsi_mq_ops_no_commit; in scsi_mq_setup_tags() 2084 tag_set->nr_hw_queues = shost->nr_hw_queues ? : 1; in scsi_mq_setup_tags() 2085 tag_set->nr_maps = shost->nr_maps ? : 1; in scsi_mq_setup_tags() 2086 tag_set->queue_depth = shost->can_queue; in scsi_mq_setup_tags() 2087 tag_set->cmd_size = cmd_size; in scsi_mq_setup_tags() 2088 tag_set->numa_node = dev_to_node(shost->dma_dev); in scsi_mq_setup_tags() [all …]
|
/linux-6.14.4/arch/um/drivers/ |
D | ubd_kern.c | 159 struct blk_mq_tag_set tag_set; member 784 blk_mq_free_tag_set(&ubd_dev->tag_set); in ubd_device_release() 865 ubd_dev->tag_set.ops = &ubd_mq_ops; in ubd_add() 866 ubd_dev->tag_set.queue_depth = 64; in ubd_add() 867 ubd_dev->tag_set.numa_node = NUMA_NO_NODE; in ubd_add() 868 ubd_dev->tag_set.driver_data = ubd_dev; in ubd_add() 869 ubd_dev->tag_set.nr_hw_queues = 1; in ubd_add() 871 err = blk_mq_alloc_tag_set(&ubd_dev->tag_set); in ubd_add() 875 disk = blk_mq_alloc_disk(&ubd_dev->tag_set, &lim, ubd_dev); in ubd_add() 907 blk_mq_free_tag_set(&ubd_dev->tag_set); in ubd_add()
|