~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/include/linux/blk-mq.h

Version: ~ [ linux-5.3-rc1 ] ~ [ linux-5.2.2 ] ~ [ linux-5.1.19 ] ~ [ linux-5.0.21 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.60 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.134 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.186 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.186 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.19.8 ] ~ [ linux-3.18.140 ] ~ [ linux-3.17.8 ] ~ [ linux-3.16.70 ] ~ [ linux-3.15.10 ] ~ [ linux-3.14.79 ] ~ [ linux-3.13.11 ] ~ [ linux-3.12.74 ] ~ [ linux-3.11.10 ] ~ [ linux-3.10.108 ] ~ [ linux-3.9.11 ] ~ [ linux-3.8.13 ] ~ [ linux-3.7.10 ] ~ [ linux-3.6.11 ] ~ [ linux-3.5.7 ] ~ [ linux-3.4.113 ] ~ [ linux-3.3.8 ] ~ [ linux-3.2.102 ] ~ [ linux-3.1.10 ] ~ [ linux-3.0.101 ] ~ [ linux-2.6.39.4 ] ~ [ linux-2.6.38.8 ] ~ [ linux-2.6.37.6 ] ~ [ linux-2.6.36.4 ] ~ [ linux-2.6.35.14 ] ~ [ linux-2.6.34.15 ] ~ [ linux-2.6.33.20 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.5 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 #ifndef BLK_MQ_H
  2 #define BLK_MQ_H
  3 
  4 #include <linux/blkdev.h>
  5 
  6 struct blk_mq_tags;
  7 struct blk_flush_queue;
  8 
  9 struct blk_mq_cpu_notifier {
 10         struct list_head list;
 11         void *data;
 12         int (*notify)(void *data, unsigned long action, unsigned int cpu);
 13 };
 14 
 15 struct blk_mq_ctxmap {
 16         unsigned int size;
 17         unsigned int bits_per_word;
 18         struct blk_align_bitmap *map;
 19 };
 20 
 21 struct blk_mq_hw_ctx {
 22         struct {
 23                 spinlock_t              lock;
 24                 struct list_head        dispatch;
 25         } ____cacheline_aligned_in_smp;
 26 
 27         unsigned long           state;          /* BLK_MQ_S_* flags */
 28         struct delayed_work     run_work;
 29         struct delayed_work     delay_work;
 30         cpumask_var_t           cpumask;
 31         int                     next_cpu;
 32         int                     next_cpu_batch;
 33 
 34         unsigned long           flags;          /* BLK_MQ_F_* flags */
 35 
 36         struct request_queue    *queue;
 37         struct blk_flush_queue  *fq;
 38 
 39         void                    *driver_data;
 40 
 41         struct blk_mq_ctxmap    ctx_map;
 42 
 43         unsigned int            nr_ctx;
 44         struct blk_mq_ctx       **ctxs;
 45 
 46         atomic_t                wait_index;
 47 
 48         struct blk_mq_tags      *tags;
 49 
 50         unsigned long           queued;
 51         unsigned long           run;
 52 #define BLK_MQ_MAX_DISPATCH_ORDER       10
 53         unsigned long           dispatched[BLK_MQ_MAX_DISPATCH_ORDER];
 54 
 55         unsigned int            numa_node;
 56         unsigned int            queue_num;
 57 
 58         atomic_t                nr_active;
 59 
 60         struct blk_mq_cpu_notifier      cpu_notifier;
 61         struct kobject          kobj;
 62 };
 63 
 64 struct blk_mq_tag_set {
 65         struct blk_mq_ops       *ops;
 66         unsigned int            nr_hw_queues;
 67         unsigned int            queue_depth;    /* max hw supported */
 68         unsigned int            reserved_tags;
 69         unsigned int            cmd_size;       /* per-request extra data */
 70         int                     numa_node;
 71         unsigned int            timeout;
 72         unsigned int            flags;          /* BLK_MQ_F_* */
 73         void                    *driver_data;
 74 
 75         struct blk_mq_tags      **tags;
 76 
 77         struct mutex            tag_list_lock;
 78         struct list_head        tag_list;
 79 };
 80 
 81 struct blk_mq_queue_data {
 82         struct request *rq;
 83         struct list_head *list;
 84         bool last;
 85 };
 86 
 87 typedef int (queue_rq_fn)(struct blk_mq_hw_ctx *, const struct blk_mq_queue_data *);
 88 typedef struct blk_mq_hw_ctx *(map_queue_fn)(struct request_queue *, const int);
 89 typedef enum blk_eh_timer_return (timeout_fn)(struct request *, bool);
 90 typedef int (init_hctx_fn)(struct blk_mq_hw_ctx *, void *, unsigned int);
 91 typedef void (exit_hctx_fn)(struct blk_mq_hw_ctx *, unsigned int);
 92 typedef int (init_request_fn)(void *, struct request *, unsigned int,
 93                 unsigned int, unsigned int);
 94 typedef void (exit_request_fn)(void *, struct request *, unsigned int,
 95                 unsigned int);
 96 
 97 typedef void (busy_iter_fn)(struct blk_mq_hw_ctx *, struct request *, void *,
 98                 bool);
 99 typedef void (busy_tag_iter_fn)(struct request *, void *, bool);
100 
101 struct blk_mq_ops {
102         /*
103          * Queue request
104          */
105         queue_rq_fn             *queue_rq;
106 
107         /*
108          * Map to specific hardware queue
109          */
110         map_queue_fn            *map_queue;
111 
112         /*
113          * Called on request timeout
114          */
115         timeout_fn              *timeout;
116 
117         softirq_done_fn         *complete;
118 
119         /*
120          * Called when the block layer side of a hardware queue has been
121          * set up, allowing the driver to allocate/init matching structures.
122          * Ditto for exit/teardown.
123          */
124         init_hctx_fn            *init_hctx;
125         exit_hctx_fn            *exit_hctx;
126 
127         /*
128          * Called for every command allocated by the block layer to allow
129          * the driver to set up driver specific data.
130          *
131          * Tag greater than or equal to queue_depth is for setting up
132          * flush request.
133          *
134          * Ditto for exit/teardown.
135          */
136         init_request_fn         *init_request;
137         exit_request_fn         *exit_request;
138 };
139 
140 enum {
141         BLK_MQ_RQ_QUEUE_OK      = 0,    /* queued fine */
142         BLK_MQ_RQ_QUEUE_BUSY    = 1,    /* requeue IO for later */
143         BLK_MQ_RQ_QUEUE_ERROR   = 2,    /* end IO with error */
144 
145         BLK_MQ_F_SHOULD_MERGE   = 1 << 0,
146         BLK_MQ_F_TAG_SHARED     = 1 << 1,
147         BLK_MQ_F_SG_MERGE       = 1 << 2,
148         BLK_MQ_F_DEFER_ISSUE    = 1 << 4,
149         BLK_MQ_F_ALLOC_POLICY_START_BIT = 8,
150         BLK_MQ_F_ALLOC_POLICY_BITS = 1,
151 
152         BLK_MQ_S_STOPPED        = 0,
153         BLK_MQ_S_TAG_ACTIVE     = 1,
154 
155         BLK_MQ_MAX_DEPTH        = 10240,
156 
157         BLK_MQ_CPU_WORK_BATCH   = 8,
158 };
159 #define BLK_MQ_FLAG_TO_ALLOC_POLICY(flags) \
160         ((flags >> BLK_MQ_F_ALLOC_POLICY_START_BIT) & \
161                 ((1 << BLK_MQ_F_ALLOC_POLICY_BITS) - 1))
162 #define BLK_ALLOC_POLICY_TO_MQ_FLAG(policy) \
163         ((policy & ((1 << BLK_MQ_F_ALLOC_POLICY_BITS) - 1)) \
164                 << BLK_MQ_F_ALLOC_POLICY_START_BIT)
165 
166 struct request_queue *blk_mq_init_queue(struct blk_mq_tag_set *);
167 struct request_queue *blk_mq_init_allocated_queue(struct blk_mq_tag_set *set,
168                                                   struct request_queue *q);
169 void blk_mq_finish_init(struct request_queue *q);
170 int blk_mq_register_disk(struct gendisk *);
171 void blk_mq_unregister_disk(struct gendisk *);
172 
173 int blk_mq_alloc_tag_set(struct blk_mq_tag_set *set);
174 void blk_mq_free_tag_set(struct blk_mq_tag_set *set);
175 
176 void blk_mq_flush_plug_list(struct blk_plug *plug, bool from_schedule);
177 
178 void blk_mq_insert_request(struct request *, bool, bool, bool);
179 void blk_mq_free_request(struct request *rq);
180 void blk_mq_free_hctx_request(struct blk_mq_hw_ctx *, struct request *rq);
181 bool blk_mq_can_queue(struct blk_mq_hw_ctx *);
182 struct request *blk_mq_alloc_request(struct request_queue *q, int rw,
183                 gfp_t gfp, bool reserved);
184 struct request *blk_mq_tag_to_rq(struct blk_mq_tags *tags, unsigned int tag);
185 struct cpumask *blk_mq_tags_cpumask(struct blk_mq_tags *tags);
186 
187 enum {
188         BLK_MQ_UNIQUE_TAG_BITS = 16,
189         BLK_MQ_UNIQUE_TAG_MASK = (1 << BLK_MQ_UNIQUE_TAG_BITS) - 1,
190 };
191 
192 u32 blk_mq_unique_tag(struct request *rq);
193 
194 static inline u16 blk_mq_unique_tag_to_hwq(u32 unique_tag)
195 {
196         return unique_tag >> BLK_MQ_UNIQUE_TAG_BITS;
197 }
198 
199 static inline u16 blk_mq_unique_tag_to_tag(u32 unique_tag)
200 {
201         return unique_tag & BLK_MQ_UNIQUE_TAG_MASK;
202 }
203 
204 struct blk_mq_hw_ctx *blk_mq_map_queue(struct request_queue *, const int ctx_index);
205 struct blk_mq_hw_ctx *blk_mq_alloc_single_hw_queue(struct blk_mq_tag_set *, unsigned int, int);
206 
207 int blk_mq_request_started(struct request *rq);
208 void blk_mq_start_request(struct request *rq);
209 void blk_mq_end_request(struct request *rq, int error);
210 void __blk_mq_end_request(struct request *rq, int error);
211 
212 void blk_mq_requeue_request(struct request *rq);
213 void blk_mq_add_to_requeue_list(struct request *rq, bool at_head);
214 void blk_mq_cancel_requeue_work(struct request_queue *q);
215 void blk_mq_kick_requeue_list(struct request_queue *q);
216 void blk_mq_abort_requeue_list(struct request_queue *q);
217 void blk_mq_complete_request(struct request *rq, int error);
218 
219 void blk_mq_stop_hw_queue(struct blk_mq_hw_ctx *hctx);
220 void blk_mq_start_hw_queue(struct blk_mq_hw_ctx *hctx);
221 void blk_mq_stop_hw_queues(struct request_queue *q);
222 void blk_mq_start_hw_queues(struct request_queue *q);
223 void blk_mq_start_stopped_hw_queues(struct request_queue *q, bool async);
224 void blk_mq_run_hw_queues(struct request_queue *q, bool async);
225 void blk_mq_delay_queue(struct blk_mq_hw_ctx *hctx, unsigned long msecs);
226 void blk_mq_all_tag_busy_iter(struct blk_mq_tags *tags, busy_tag_iter_fn *fn,
227                 void *priv);
228 void blk_mq_freeze_queue(struct request_queue *q);
229 void blk_mq_unfreeze_queue(struct request_queue *q);
230 void blk_mq_freeze_queue_start(struct request_queue *q);
231 
232 /*
233  * Driver command data is immediately after the request. So subtract request
234  * size to get back to the original request, add request size to get the PDU.
235  */
236 static inline struct request *blk_mq_rq_from_pdu(void *pdu)
237 {
238         return pdu - sizeof(struct request);
239 }
240 static inline void *blk_mq_rq_to_pdu(struct request *rq)
241 {
242         return rq + 1;
243 }
244 
245 #define queue_for_each_hw_ctx(q, hctx, i)                               \
246         for ((i) = 0; (i) < (q)->nr_hw_queues &&                        \
247              ({ hctx = (q)->queue_hw_ctx[i]; 1; }); (i)++)
248 
249 #define queue_for_each_ctx(q, ctx, i)                                   \
250         for ((i) = 0; (i) < (q)->nr_queues &&                           \
251              ({ ctx = per_cpu_ptr((q)->queue_ctx, (i)); 1; }); (i)++)
252 
253 #define hctx_for_each_ctx(hctx, ctx, i)                                 \
254         for ((i) = 0; (i) < (hctx)->nr_ctx &&                           \
255              ({ ctx = (hctx)->ctxs[(i)]; 1; }); (i)++)
256 
257 #define blk_ctx_sum(q, sum)                                             \
258 ({                                                                      \
259         struct blk_mq_ctx *__x;                                         \
260         unsigned int __ret = 0, __i;                                    \
261                                                                         \
262         queue_for_each_ctx((q), __x, __i)                               \
263                 __ret += sum;                                           \
264         __ret;                                                          \
265 })
266 
267 #endif
268 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp