| #ifndef INT_BLK_MQ_H |
| #define INT_BLK_MQ_H |
| |
| struct blk_mq_tag_set; |
| |
| struct blk_mq_ctx { |
| struct { |
| spinlock_t lock; |
| struct list_head rq_list; |
| } ____cacheline_aligned_in_smp; |
| |
| unsigned int cpu; |
| unsigned int index_hw; |
| |
| unsigned int last_tag ____cacheline_aligned_in_smp; |
| |
| /* incremented at dispatch time */ |
| unsigned long rq_dispatched[2]; |
| unsigned long rq_merged; |
| |
| /* incremented at completion time */ |
| unsigned long ____cacheline_aligned_in_smp rq_completed[2]; |
| |
| struct request_queue *queue; |
| struct kobject kobj; |
| } ____cacheline_aligned_in_smp; |
| |
| void __blk_mq_complete_request(struct request *rq); |
| void blk_mq_run_hw_queue(struct blk_mq_hw_ctx *hctx, bool async); |
| void blk_mq_init_flush(struct request_queue *q); |
| void blk_mq_drain_queue(struct request_queue *q); |
| void blk_mq_free_queue(struct request_queue *q); |
| void blk_mq_clone_flush_request(struct request *flush_rq, |
| struct request *orig_rq); |
| |
| /* |
| * CPU hotplug helpers |
| */ |
| struct blk_mq_cpu_notifier; |
| void blk_mq_init_cpu_notifier(struct blk_mq_cpu_notifier *notifier, |
| void (*fn)(void *, unsigned long, unsigned int), |
| void *data); |
| void blk_mq_register_cpu_notifier(struct blk_mq_cpu_notifier *notifier); |
| void blk_mq_unregister_cpu_notifier(struct blk_mq_cpu_notifier *notifier); |
| void blk_mq_cpu_init(void); |
| void blk_mq_enable_hotplug(void); |
| void blk_mq_disable_hotplug(void); |
| |
| /* |
| * CPU -> queue mappings |
| */ |
| extern unsigned int *blk_mq_make_queue_map(struct blk_mq_tag_set *set); |
| extern int blk_mq_update_queue_map(unsigned int *map, unsigned int nr_queues); |
| |
| /* |
| * Basic implementation of sparser bitmap, allowing the user to spread |
| * the bits over more cachelines. |
| */ |
| struct blk_align_bitmap { |
| unsigned long word; |
| unsigned long depth; |
| } ____cacheline_aligned_in_smp; |
| |
| #endif |