]> git.ipfire.org Git - thirdparty/linux.git/blame - include/linux/blkdev.h
drivers/net/phy/mdio_bus.c: call put_device on device_register() failure
[thirdparty/linux.git] / include / linux / blkdev.h
CommitLineData
1da177e4
LT
1#ifndef _LINUX_BLKDEV_H
2#define _LINUX_BLKDEV_H
3
85fd0bc9
RK
4#include <linux/sched.h>
5
f5ff8422
JA
6#ifdef CONFIG_BLOCK
7
1da177e4
LT
8#include <linux/major.h>
9#include <linux/genhd.h>
10#include <linux/list.h>
320ae51f 11#include <linux/llist.h>
1da177e4
LT
12#include <linux/timer.h>
13#include <linux/workqueue.h>
14#include <linux/pagemap.h>
15#include <linux/backing-dev.h>
16#include <linux/wait.h>
17#include <linux/mempool.h>
18#include <linux/bio.h>
1da177e4 19#include <linux/stringify.h>
3e6053d7 20#include <linux/gfp.h>
d351af01 21#include <linux/bsg.h>
c7c22e4d 22#include <linux/smp.h>
548bc8e1 23#include <linux/rcupdate.h>
1da177e4
LT
24
25#include <asm/scatterlist.h>
26
de477254 27struct module;
21b2f0c8
CH
28struct scsi_ioctl_command;
29
1da177e4 30struct request_queue;
1da177e4 31struct elevator_queue;
1da177e4 32struct request_pm_state;
2056a782 33struct blk_trace;
3d6392cf
JA
34struct request;
35struct sg_io_hdr;
aa387cc8 36struct bsg_job;
3c798398 37struct blkcg_gq;
1da177e4
LT
38
39#define BLKDEV_MIN_RQ 4
40#define BLKDEV_MAX_RQ 128 /* Default maximum */
41
8bd435b3
TH
42/*
43 * Maximum number of blkcg policies allowed to be registered concurrently.
44 * Defined here to simplify include dependency.
45 */
46#define BLKCG_MAX_POLS 2
47
1da177e4 48struct request;
8ffdc655 49typedef void (rq_end_io_fn)(struct request *, int);
1da177e4 50
5b788ce3
TH
51#define BLK_RL_SYNCFULL (1U << 0)
52#define BLK_RL_ASYNCFULL (1U << 1)
53
1da177e4 54struct request_list {
5b788ce3 55 struct request_queue *q; /* the queue this rl belongs to */
a051661c
TH
56#ifdef CONFIG_BLK_CGROUP
57 struct blkcg_gq *blkg; /* blkg this request pool belongs to */
58#endif
1faa16d2
JA
59 /*
60 * count[], starved[], and wait[] are indexed by
61 * BLK_RW_SYNC/BLK_RW_ASYNC
62 */
8a5ecdd4
TH
63 int count[2];
64 int starved[2];
65 mempool_t *rq_pool;
66 wait_queue_head_t wait[2];
5b788ce3 67 unsigned int flags;
1da177e4
LT
68};
69
4aff5e23
JA
70/*
71 * request command types
72 */
73enum rq_cmd_type_bits {
74 REQ_TYPE_FS = 1, /* fs request */
75 REQ_TYPE_BLOCK_PC, /* scsi command */
76 REQ_TYPE_SENSE, /* sense request */
77 REQ_TYPE_PM_SUSPEND, /* suspend request */
78 REQ_TYPE_PM_RESUME, /* resume request */
79 REQ_TYPE_PM_SHUTDOWN, /* shutdown request */
4aff5e23 80 REQ_TYPE_SPECIAL, /* driver defined type */
4aff5e23
JA
81 /*
82 * for ATA/ATAPI devices. this really doesn't belong here, ide should
83 * use REQ_TYPE_SPECIAL and use rq->cmd[0] with the range of driver
84 * private REQ_LB opcodes to differentiate what type of request this is
85 */
4aff5e23 86 REQ_TYPE_ATA_TASKFILE,
cea2885a 87 REQ_TYPE_ATA_PC,
4aff5e23
JA
88};
89
1da177e4
LT
90#define BLK_MAX_CDB 16
91
92/*
63a71386 93 * try to put the fields that are referenced together in the same cacheline.
4d0d98b6 94 * if you modify this structure, be sure to check block/blk-core.c:blk_rq_init()
63a71386 95 * as well!
1da177e4
LT
96 */
97struct request {
320ae51f
JA
98 union {
99 struct list_head queuelist;
100 struct llist_node ll_list;
101 };
102 union {
103 struct call_single_data csd;
104 struct work_struct mq_flush_data;
105 };
ff856bad 106
165125e1 107 struct request_queue *q;
320ae51f 108 struct blk_mq_ctx *mq_ctx;
e6a1c874 109
5953316d 110 u64 cmd_flags;
4aff5e23 111 enum rq_cmd_type_bits cmd_type;
242f9dcb 112 unsigned long atomic_flags;
1da177e4 113
181fdde3
RK
114 int cpu;
115
a2dec7b3 116 /* the following two fields are internal, NEVER access directly */
a2dec7b3 117 unsigned int __data_len; /* total data len */
181fdde3 118 sector_t __sector; /* sector cursor */
1da177e4
LT
119
120 struct bio *bio;
121 struct bio *biotail;
122
9817064b 123 struct hlist_node hash; /* merge hash */
e6a1c874
JA
124 /*
125 * The rb_node is only used inside the io scheduler, requests
126 * are pruned when moved to the dispatch queue. So let the
c186794d 127 * completion_data share space with the rb_node.
e6a1c874
JA
128 */
129 union {
130 struct rb_node rb_node; /* sort/lookup */
c186794d 131 void *completion_data;
e6a1c874 132 };
9817064b 133
ff7d145f 134 /*
7f1dc8a2 135 * Three pointers are available for the IO schedulers, if they need
c186794d
MS
136 * more they have to dynamically allocate it. Flush requests are
137 * never put on the IO scheduler. So let the flush fields share
a612fddf 138 * space with the elevator data.
ff7d145f 139 */
c186794d 140 union {
a612fddf
TH
141 struct {
142 struct io_cq *icq;
143 void *priv[2];
144 } elv;
145
c186794d
MS
146 struct {
147 unsigned int seq;
148 struct list_head list;
4853abaa 149 rq_end_io_fn *saved_end_io;
c186794d
MS
150 } flush;
151 };
ff7d145f 152
8f34ee75 153 struct gendisk *rq_disk;
09e099d4 154 struct hd_struct *part;
1da177e4 155 unsigned long start_time;
9195291e 156#ifdef CONFIG_BLK_CGROUP
a051661c 157 struct request_list *rl; /* rl this rq is alloced from */
9195291e
DS
158 unsigned long long start_time_ns;
159 unsigned long long io_start_time_ns; /* when passed to hardware */
160#endif
1da177e4
LT
161 /* Number of scatter-gather DMA addr+len pairs after
162 * physical address coalescing is performed.
163 */
164 unsigned short nr_phys_segments;
13f05c8d
MP
165#if defined(CONFIG_BLK_DEV_INTEGRITY)
166 unsigned short nr_integrity_segments;
167#endif
1da177e4 168
8f34ee75
JA
169 unsigned short ioprio;
170
731ec497
TH
171 void *special; /* opaque pointer available for LLD use */
172 char *buffer; /* kaddr of the current segment if available */
1da177e4 173
cdd60262
JA
174 int tag;
175 int errors;
176
1da177e4
LT
177 /*
178 * when request is used as a packet command carrier
179 */
d7e3c324
FT
180 unsigned char __cmd[BLK_MAX_CDB];
181 unsigned char *cmd;
181fdde3 182 unsigned short cmd_len;
1da177e4 183
7a85f889 184 unsigned int extra_len; /* length of alignment and padding */
1da177e4 185 unsigned int sense_len;
c3a4d78c 186 unsigned int resid_len; /* residual count */
1da177e4
LT
187 void *sense;
188
242f9dcb
JA
189 unsigned long deadline;
190 struct list_head timeout_list;
1da177e4 191 unsigned int timeout;
17e01f21 192 int retries;
1da177e4 193
1da177e4 194 /*
c00895ab 195 * completion callback.
1da177e4
LT
196 */
197 rq_end_io_fn *end_io;
198 void *end_io_data;
abae1fde
FT
199
200 /* for bidi */
201 struct request *next_rq;
1da177e4
LT
202};
203
766ca442
FLVC
204static inline unsigned short req_get_ioprio(struct request *req)
205{
206 return req->ioprio;
207}
208
1da177e4 209/*
4aff5e23 210 * State information carried for REQ_TYPE_PM_SUSPEND and REQ_TYPE_PM_RESUME
1da177e4
LT
211 * requests. Some step values could eventually be made generic.
212 */
213struct request_pm_state
214{
215 /* PM state machine step value, currently driver specific */
216 int pm_step;
217 /* requested PM state value (S1, S2, S3, S4, ...) */
218 u32 pm_state;
219 void* data; /* for driver use */
220};
221
222#include <linux/elevator.h>
223
320ae51f
JA
224struct blk_queue_ctx;
225
165125e1 226typedef void (request_fn_proc) (struct request_queue *q);
5a7bbad2 227typedef void (make_request_fn) (struct request_queue *q, struct bio *bio);
165125e1 228typedef int (prep_rq_fn) (struct request_queue *, struct request *);
28018c24 229typedef void (unprep_rq_fn) (struct request_queue *, struct request *);
1da177e4
LT
230
231struct bio_vec;
cc371e66
AK
232struct bvec_merge_data {
233 struct block_device *bi_bdev;
234 sector_t bi_sector;
235 unsigned bi_size;
236 unsigned long bi_rw;
237};
238typedef int (merge_bvec_fn) (struct request_queue *, struct bvec_merge_data *,
239 struct bio_vec *);
ff856bad 240typedef void (softirq_done_fn)(struct request *);
2fb98e84 241typedef int (dma_drain_needed_fn)(struct request *);
ef9e3fac 242typedef int (lld_busy_fn) (struct request_queue *q);
aa387cc8 243typedef int (bsg_job_fn) (struct bsg_job *);
1da177e4 244
242f9dcb
JA
245enum blk_eh_timer_return {
246 BLK_EH_NOT_HANDLED,
247 BLK_EH_HANDLED,
248 BLK_EH_RESET_TIMER,
249};
250
251typedef enum blk_eh_timer_return (rq_timed_out_fn)(struct request *);
252
1da177e4
LT
253enum blk_queue_state {
254 Queue_down,
255 Queue_up,
256};
257
1da177e4
LT
258struct blk_queue_tag {
259 struct request **tag_index; /* map of busy tags */
260 unsigned long *tag_map; /* bit map of free/busy tags */
1da177e4
LT
261 int busy; /* current depth */
262 int max_depth; /* what we will send to device */
ba025082 263 int real_max_depth; /* what the array can hold */
1da177e4
LT
264 atomic_t refcnt; /* map can be shared */
265};
266
abf54393
FT
267#define BLK_SCSI_MAX_CMDS (256)
268#define BLK_SCSI_CMD_PER_LONG (BLK_SCSI_MAX_CMDS / (sizeof(long) * 8))
269
025146e1
MP
270struct queue_limits {
271 unsigned long bounce_pfn;
272 unsigned long seg_boundary_mask;
273
274 unsigned int max_hw_sectors;
275 unsigned int max_sectors;
276 unsigned int max_segment_size;
c72758f3
MP
277 unsigned int physical_block_size;
278 unsigned int alignment_offset;
279 unsigned int io_min;
280 unsigned int io_opt;
67efc925 281 unsigned int max_discard_sectors;
4363ac7c 282 unsigned int max_write_same_sectors;
86b37281
MP
283 unsigned int discard_granularity;
284 unsigned int discard_alignment;
025146e1
MP
285
286 unsigned short logical_block_size;
8a78362c 287 unsigned short max_segments;
13f05c8d 288 unsigned short max_integrity_segments;
025146e1 289
c72758f3 290 unsigned char misaligned;
86b37281 291 unsigned char discard_misaligned;
e692cb66 292 unsigned char cluster;
a934a00a 293 unsigned char discard_zeroes_data;
c78afc62 294 unsigned char raid_partial_stripes_expensive;
025146e1
MP
295};
296
d7b76301 297struct request_queue {
1da177e4
LT
298 /*
299 * Together with queue_head for cacheline sharing
300 */
301 struct list_head queue_head;
302 struct request *last_merge;
b374d18a 303 struct elevator_queue *elevator;
8a5ecdd4
TH
304 int nr_rqs[2]; /* # allocated [a]sync rqs */
305 int nr_rqs_elvpriv; /* # allocated rqs w/ elvpriv */
1da177e4
LT
306
307 /*
a051661c
TH
308 * If blkcg is not used, @q->root_rl serves all requests. If blkcg
309 * is used, root blkg allocates from @q->root_rl and all other
310 * blkgs from their own blkg->rl. Which one to use should be
311 * determined using bio_request_list().
1da177e4 312 */
a051661c 313 struct request_list root_rl;
1da177e4
LT
314
315 request_fn_proc *request_fn;
1da177e4
LT
316 make_request_fn *make_request_fn;
317 prep_rq_fn *prep_rq_fn;
28018c24 318 unprep_rq_fn *unprep_rq_fn;
1da177e4 319 merge_bvec_fn *merge_bvec_fn;
ff856bad 320 softirq_done_fn *softirq_done_fn;
242f9dcb 321 rq_timed_out_fn *rq_timed_out_fn;
2fb98e84 322 dma_drain_needed_fn *dma_drain_needed;
ef9e3fac 323 lld_busy_fn *lld_busy_fn;
1da177e4 324
320ae51f
JA
325 struct blk_mq_ops *mq_ops;
326
327 unsigned int *mq_map;
328
329 /* sw queues */
330 struct blk_mq_ctx *queue_ctx;
331 unsigned int nr_queues;
332
333 /* hw dispatch queues */
334 struct blk_mq_hw_ctx **queue_hw_ctx;
335 unsigned int nr_hw_queues;
336
8922e16c
TH
337 /*
338 * Dispatch queue sorting
339 */
1b47f531 340 sector_t end_sector;
8922e16c 341 struct request *boundary_rq;
8922e16c 342
1da177e4 343 /*
3cca6dc1 344 * Delayed queue handling
1da177e4 345 */
3cca6dc1 346 struct delayed_work delay_work;
1da177e4
LT
347
348 struct backing_dev_info backing_dev_info;
349
350 /*
351 * The queue owner gets to use this for whatever they like.
352 * ll_rw_blk doesn't touch it.
353 */
354 void *queuedata;
355
1da177e4 356 /*
d7b76301 357 * various queue flags, see QUEUE_* below
1da177e4 358 */
d7b76301 359 unsigned long queue_flags;
1da177e4 360
a73f730d
TH
361 /*
362 * ida allocated id for this queue. Used to index queues from
363 * ioctx.
364 */
365 int id;
366
1da177e4 367 /*
d7b76301 368 * queue needs bounce pages for pages above this limit
1da177e4 369 */
d7b76301 370 gfp_t bounce_gfp;
1da177e4
LT
371
372 /*
152587de
JA
373 * protects queue structures from reentrancy. ->__queue_lock should
374 * _never_ be used directly, it is queue private. always use
375 * ->queue_lock.
1da177e4 376 */
152587de 377 spinlock_t __queue_lock;
1da177e4
LT
378 spinlock_t *queue_lock;
379
380 /*
381 * queue kobject
382 */
383 struct kobject kobj;
384
320ae51f
JA
385 /*
386 * mq queue kobject
387 */
388 struct kobject mq_kobj;
389
6c954667
LM
390#ifdef CONFIG_PM_RUNTIME
391 struct device *dev;
392 int rpm_status;
393 unsigned int nr_pending;
394#endif
395
1da177e4
LT
396 /*
397 * queue settings
398 */
399 unsigned long nr_requests; /* Max # of requests */
400 unsigned int nr_congestion_on;
401 unsigned int nr_congestion_off;
402 unsigned int nr_batching;
403
fa0ccd83 404 unsigned int dma_drain_size;
d7b76301 405 void *dma_drain_buffer;
e3790c7d 406 unsigned int dma_pad_mask;
1da177e4
LT
407 unsigned int dma_alignment;
408
409 struct blk_queue_tag *queue_tags;
6eca9004 410 struct list_head tag_busy_list;
1da177e4 411
15853af9 412 unsigned int nr_sorted;
0a7ae2ff 413 unsigned int in_flight[2];
24faf6f6
BVA
414 /*
415 * Number of active block driver functions for which blk_drain_queue()
416 * must wait. Must be incremented around functions that unlock the
417 * queue_lock internally, e.g. scsi_request_fn().
418 */
419 unsigned int request_fn_active;
1da177e4 420
242f9dcb
JA
421 unsigned int rq_timeout;
422 struct timer_list timeout;
423 struct list_head timeout_list;
424
a612fddf 425 struct list_head icq_list;
4eef3049 426#ifdef CONFIG_BLK_CGROUP
a2b1693b 427 DECLARE_BITMAP (blkcg_pols, BLKCG_MAX_POLS);
3c798398 428 struct blkcg_gq *root_blkg;
03aa264a 429 struct list_head blkg_list;
4eef3049 430#endif
a612fddf 431
025146e1
MP
432 struct queue_limits limits;
433
1da177e4
LT
434 /*
435 * sg stuff
436 */
437 unsigned int sg_timeout;
438 unsigned int sg_reserved_size;
1946089a 439 int node;
6c5c9341 440#ifdef CONFIG_BLK_DEV_IO_TRACE
2056a782 441 struct blk_trace *blk_trace;
6c5c9341 442#endif
1da177e4 443 /*
4913efe4 444 * for flush operations
1da177e4 445 */
4913efe4 446 unsigned int flush_flags;
f3876930 447 unsigned int flush_not_queueable:1;
3ac0cc45 448 unsigned int flush_queue_delayed:1;
ae1b1539
TH
449 unsigned int flush_pending_idx:1;
450 unsigned int flush_running_idx:1;
451 unsigned long flush_pending_since;
452 struct list_head flush_queue[2];
453 struct list_head flush_data_in_flight;
320ae51f
JA
454 union {
455 struct request flush_rq;
456 struct {
457 spinlock_t mq_flush_lock;
458 struct work_struct mq_flush_work;
459 };
460 };
483f4afc
AV
461
462 struct mutex sysfs_lock;
d351af01 463
d732580b
TH
464 int bypass_depth;
465
d351af01 466#if defined(CONFIG_BLK_DEV_BSG)
aa387cc8
MC
467 bsg_job_fn *bsg_job_fn;
468 int bsg_job_size;
d351af01
FT
469 struct bsg_class_device bsg_dev;
470#endif
e43473b7
VG
471
472#ifdef CONFIG_BLK_DEV_THROTTLING
473 /* Throttle data */
474 struct throtl_data *td;
475#endif
548bc8e1 476 struct rcu_head rcu_head;
320ae51f
JA
477 wait_queue_head_t mq_freeze_wq;
478 struct percpu_counter mq_usage_counter;
479 struct list_head all_q_node;
1da177e4
LT
480};
481
1da177e4
LT
482#define QUEUE_FLAG_QUEUED 1 /* uses generic tag queueing */
483#define QUEUE_FLAG_STOPPED 2 /* queue is stopped */
1faa16d2
JA
484#define QUEUE_FLAG_SYNCFULL 3 /* read queue has been filled */
485#define QUEUE_FLAG_ASYNCFULL 4 /* write queue has been filled */
3f3299d5 486#define QUEUE_FLAG_DYING 5 /* queue being torn down */
d732580b 487#define QUEUE_FLAG_BYPASS 6 /* act as dumb FIFO queue */
c21e6beb
JA
488#define QUEUE_FLAG_BIDI 7 /* queue supports bidi requests */
489#define QUEUE_FLAG_NOMERGES 8 /* disable merge attempts */
5757a6d7 490#define QUEUE_FLAG_SAME_COMP 9 /* complete on same CPU-group */
c21e6beb
JA
491#define QUEUE_FLAG_FAIL_IO 10 /* fake timeout */
492#define QUEUE_FLAG_STACKABLE 11 /* supports request stacking */
493#define QUEUE_FLAG_NONROT 12 /* non-rotational device (SSD) */
88e740f1 494#define QUEUE_FLAG_VIRT QUEUE_FLAG_NONROT /* paravirt device */
c21e6beb
JA
495#define QUEUE_FLAG_IO_STAT 13 /* do IO stats */
496#define QUEUE_FLAG_DISCARD 14 /* supports DISCARD */
497#define QUEUE_FLAG_NOXMERGES 15 /* No extended merges */
498#define QUEUE_FLAG_ADD_RANDOM 16 /* Contributes to random pool */
499#define QUEUE_FLAG_SECDISCARD 17 /* supports SECDISCARD */
5757a6d7 500#define QUEUE_FLAG_SAME_FORCE 18 /* force complete on same CPU */
c246e80d 501#define QUEUE_FLAG_DEAD 19 /* queue tear-down finished */
320ae51f 502#define QUEUE_FLAG_INIT_DONE 20 /* queue is initialized */
bc58ba94
JA
503
504#define QUEUE_FLAG_DEFAULT ((1 << QUEUE_FLAG_IO_STAT) | \
01e97f6b 505 (1 << QUEUE_FLAG_STACKABLE) | \
e2e1a148
JA
506 (1 << QUEUE_FLAG_SAME_COMP) | \
507 (1 << QUEUE_FLAG_ADD_RANDOM))
797e7dbb 508
94eddfbe
JA
509#define QUEUE_FLAG_MQ_DEFAULT ((1 << QUEUE_FLAG_IO_STAT) | \
510 (1 << QUEUE_FLAG_SAME_COMP))
511
8bcb6c7d 512static inline void queue_lockdep_assert_held(struct request_queue *q)
8f45c1a5 513{
8bcb6c7d
AK
514 if (q->queue_lock)
515 lockdep_assert_held(q->queue_lock);
8f45c1a5
LT
516}
517
75ad23bc
NP
518static inline void queue_flag_set_unlocked(unsigned int flag,
519 struct request_queue *q)
520{
521 __set_bit(flag, &q->queue_flags);
522}
523
e48ec690
JA
524static inline int queue_flag_test_and_clear(unsigned int flag,
525 struct request_queue *q)
526{
8bcb6c7d 527 queue_lockdep_assert_held(q);
e48ec690
JA
528
529 if (test_bit(flag, &q->queue_flags)) {
530 __clear_bit(flag, &q->queue_flags);
531 return 1;
532 }
533
534 return 0;
535}
536
537static inline int queue_flag_test_and_set(unsigned int flag,
538 struct request_queue *q)
539{
8bcb6c7d 540 queue_lockdep_assert_held(q);
e48ec690
JA
541
542 if (!test_bit(flag, &q->queue_flags)) {
543 __set_bit(flag, &q->queue_flags);
544 return 0;
545 }
546
547 return 1;
548}
549
75ad23bc
NP
550static inline void queue_flag_set(unsigned int flag, struct request_queue *q)
551{
8bcb6c7d 552 queue_lockdep_assert_held(q);
75ad23bc
NP
553 __set_bit(flag, &q->queue_flags);
554}
555
556static inline void queue_flag_clear_unlocked(unsigned int flag,
557 struct request_queue *q)
558{
559 __clear_bit(flag, &q->queue_flags);
560}
561
0a7ae2ff
JA
562static inline int queue_in_flight(struct request_queue *q)
563{
564 return q->in_flight[0] + q->in_flight[1];
565}
566
75ad23bc
NP
567static inline void queue_flag_clear(unsigned int flag, struct request_queue *q)
568{
8bcb6c7d 569 queue_lockdep_assert_held(q);
75ad23bc
NP
570 __clear_bit(flag, &q->queue_flags);
571}
572
1da177e4
LT
573#define blk_queue_tagged(q) test_bit(QUEUE_FLAG_QUEUED, &(q)->queue_flags)
574#define blk_queue_stopped(q) test_bit(QUEUE_FLAG_STOPPED, &(q)->queue_flags)
3f3299d5 575#define blk_queue_dying(q) test_bit(QUEUE_FLAG_DYING, &(q)->queue_flags)
c246e80d 576#define blk_queue_dead(q) test_bit(QUEUE_FLAG_DEAD, &(q)->queue_flags)
d732580b 577#define blk_queue_bypass(q) test_bit(QUEUE_FLAG_BYPASS, &(q)->queue_flags)
320ae51f 578#define blk_queue_init_done(q) test_bit(QUEUE_FLAG_INIT_DONE, &(q)->queue_flags)
ac9fafa1 579#define blk_queue_nomerges(q) test_bit(QUEUE_FLAG_NOMERGES, &(q)->queue_flags)
488991e2
AB
580#define blk_queue_noxmerges(q) \
581 test_bit(QUEUE_FLAG_NOXMERGES, &(q)->queue_flags)
a68bbddb 582#define blk_queue_nonrot(q) test_bit(QUEUE_FLAG_NONROT, &(q)->queue_flags)
bc58ba94 583#define blk_queue_io_stat(q) test_bit(QUEUE_FLAG_IO_STAT, &(q)->queue_flags)
e2e1a148 584#define blk_queue_add_random(q) test_bit(QUEUE_FLAG_ADD_RANDOM, &(q)->queue_flags)
4ee5eaf4
KU
585#define blk_queue_stackable(q) \
586 test_bit(QUEUE_FLAG_STACKABLE, &(q)->queue_flags)
c15227de 587#define blk_queue_discard(q) test_bit(QUEUE_FLAG_DISCARD, &(q)->queue_flags)
8d57a98c
AH
588#define blk_queue_secdiscard(q) (blk_queue_discard(q) && \
589 test_bit(QUEUE_FLAG_SECDISCARD, &(q)->queue_flags))
1da177e4 590
33659ebb
CH
591#define blk_noretry_request(rq) \
592 ((rq)->cmd_flags & (REQ_FAILFAST_DEV|REQ_FAILFAST_TRANSPORT| \
593 REQ_FAILFAST_DRIVER))
594
595#define blk_account_rq(rq) \
596 (((rq)->cmd_flags & REQ_STARTED) && \
e2a60da7 597 ((rq)->cmd_type == REQ_TYPE_FS))
33659ebb 598
1da177e4 599#define blk_pm_request(rq) \
33659ebb
CH
600 ((rq)->cmd_type == REQ_TYPE_PM_SUSPEND || \
601 (rq)->cmd_type == REQ_TYPE_PM_RESUME)
1da177e4 602
ab780f1e 603#define blk_rq_cpu_valid(rq) ((rq)->cpu != -1)
abae1fde 604#define blk_bidi_rq(rq) ((rq)->next_rq != NULL)
336cdb40
KU
605/* rq->queuelist of dequeued request must be list_empty() */
606#define blk_queued_rq(rq) (!list_empty(&(rq)->queuelist))
1da177e4
LT
607
608#define list_entry_rq(ptr) list_entry((ptr), struct request, queuelist)
609
5953316d 610#define rq_data_dir(rq) (((rq)->cmd_flags & 1) != 0)
1da177e4 611
e692cb66
MP
612static inline unsigned int blk_queue_cluster(struct request_queue *q)
613{
614 return q->limits.cluster;
615}
616
9e2585a8 617/*
1faa16d2 618 * We regard a request as sync, if either a read or a sync write
9e2585a8 619 */
1faa16d2
JA
620static inline bool rw_is_sync(unsigned int rw_flags)
621{
7b6d91da 622 return !(rw_flags & REQ_WRITE) || (rw_flags & REQ_SYNC);
1faa16d2
JA
623}
624
625static inline bool rq_is_sync(struct request *rq)
626{
627 return rw_is_sync(rq->cmd_flags);
628}
629
5b788ce3 630static inline bool blk_rl_full(struct request_list *rl, bool sync)
1da177e4 631{
5b788ce3
TH
632 unsigned int flag = sync ? BLK_RL_SYNCFULL : BLK_RL_ASYNCFULL;
633
634 return rl->flags & flag;
1da177e4
LT
635}
636
5b788ce3 637static inline void blk_set_rl_full(struct request_list *rl, bool sync)
1da177e4 638{
5b788ce3
TH
639 unsigned int flag = sync ? BLK_RL_SYNCFULL : BLK_RL_ASYNCFULL;
640
641 rl->flags |= flag;
1da177e4
LT
642}
643
5b788ce3 644static inline void blk_clear_rl_full(struct request_list *rl, bool sync)
1da177e4 645{
5b788ce3
TH
646 unsigned int flag = sync ? BLK_RL_SYNCFULL : BLK_RL_ASYNCFULL;
647
648 rl->flags &= ~flag;
1da177e4
LT
649}
650
e2a60da7
MP
651static inline bool rq_mergeable(struct request *rq)
652{
653 if (rq->cmd_type != REQ_TYPE_FS)
654 return false;
1da177e4 655
e2a60da7
MP
656 if (rq->cmd_flags & REQ_NOMERGE_FLAGS)
657 return false;
658
659 return true;
660}
1da177e4 661
f31dc1cd
MP
662static inline bool blk_check_merge_flags(unsigned int flags1,
663 unsigned int flags2)
664{
665 if ((flags1 & REQ_DISCARD) != (flags2 & REQ_DISCARD))
666 return false;
667
668 if ((flags1 & REQ_SECURE) != (flags2 & REQ_SECURE))
669 return false;
670
4363ac7c
MP
671 if ((flags1 & REQ_WRITE_SAME) != (flags2 & REQ_WRITE_SAME))
672 return false;
673
f31dc1cd
MP
674 return true;
675}
676
4363ac7c
MP
677static inline bool blk_write_same_mergeable(struct bio *a, struct bio *b)
678{
679 if (bio_data(a) == bio_data(b))
680 return true;
681
682 return false;
683}
684
1da177e4
LT
685/*
686 * q->prep_rq_fn return values
687 */
688#define BLKPREP_OK 0 /* serve it */
689#define BLKPREP_KILL 1 /* fatal error, kill */
690#define BLKPREP_DEFER 2 /* leave on queue */
691
692extern unsigned long blk_max_low_pfn, blk_max_pfn;
693
694/*
695 * standard bounce addresses:
696 *
697 * BLK_BOUNCE_HIGH : bounce all highmem pages
698 * BLK_BOUNCE_ANY : don't bounce anything
699 * BLK_BOUNCE_ISA : bounce pages above ISA DMA boundary
700 */
2472892a
AK
701
702#if BITS_PER_LONG == 32
1da177e4 703#define BLK_BOUNCE_HIGH ((u64)blk_max_low_pfn << PAGE_SHIFT)
2472892a
AK
704#else
705#define BLK_BOUNCE_HIGH -1ULL
706#endif
707#define BLK_BOUNCE_ANY (-1ULL)
bfe17231 708#define BLK_BOUNCE_ISA (DMA_BIT_MASK(24))
1da177e4 709
3d6392cf
JA
710/*
711 * default timeout for SG_IO if none specified
712 */
713#define BLK_DEFAULT_SG_TIMEOUT (60 * HZ)
f2f1fa78 714#define BLK_MIN_SG_TIMEOUT (7 * HZ)
3d6392cf 715
2a7326b5 716#ifdef CONFIG_BOUNCE
1da177e4 717extern int init_emergency_isa_pool(void);
165125e1 718extern void blk_queue_bounce(struct request_queue *q, struct bio **bio);
1da177e4
LT
719#else
720static inline int init_emergency_isa_pool(void)
721{
722 return 0;
723}
165125e1 724static inline void blk_queue_bounce(struct request_queue *q, struct bio **bio)
1da177e4
LT
725{
726}
727#endif /* CONFIG_MMU */
728
152e283f
FT
729struct rq_map_data {
730 struct page **pages;
731 int page_order;
732 int nr_entries;
56c451f4 733 unsigned long offset;
97ae77a1 734 int null_mapped;
ecb554a8 735 int from_user;
152e283f
FT
736};
737
5705f702 738struct req_iterator {
7988613b 739 struct bvec_iter iter;
5705f702
N
740 struct bio *bio;
741};
742
743/* This should not be used directly - use rq_for_each_segment */
1e428079
JA
744#define for_each_bio(_bio) \
745 for (; _bio; _bio = _bio->bi_next)
5705f702 746#define __rq_for_each_bio(_bio, rq) \
1da177e4
LT
747 if ((rq->bio)) \
748 for (_bio = (rq)->bio; _bio; _bio = _bio->bi_next)
749
5705f702
N
750#define rq_for_each_segment(bvl, _rq, _iter) \
751 __rq_for_each_bio(_iter.bio, _rq) \
7988613b 752 bio_for_each_segment(bvl, _iter.bio, _iter.iter)
5705f702 753
4550dd6c 754#define rq_iter_last(bvec, _iter) \
7988613b 755 (_iter.bio->bi_next == NULL && \
4550dd6c 756 bio_iter_last(bvec, _iter.iter))
5705f702 757
2d4dc890
IL
758#ifndef ARCH_IMPLEMENTS_FLUSH_DCACHE_PAGE
759# error "You should define ARCH_IMPLEMENTS_FLUSH_DCACHE_PAGE for your platform"
760#endif
761#if ARCH_IMPLEMENTS_FLUSH_DCACHE_PAGE
762extern void rq_flush_dcache_pages(struct request *rq);
763#else
764static inline void rq_flush_dcache_pages(struct request *rq)
765{
766}
767#endif
768
1da177e4
LT
769extern int blk_register_queue(struct gendisk *disk);
770extern void blk_unregister_queue(struct gendisk *disk);
1da177e4 771extern void generic_make_request(struct bio *bio);
2a4aa30c 772extern void blk_rq_init(struct request_queue *q, struct request *rq);
1da177e4 773extern void blk_put_request(struct request *);
165125e1 774extern void __blk_put_request(struct request_queue *, struct request *);
165125e1 775extern struct request *blk_get_request(struct request_queue *, int, gfp_t);
79eb63e9
BH
776extern struct request *blk_make_request(struct request_queue *, struct bio *,
777 gfp_t);
165125e1 778extern void blk_requeue_request(struct request_queue *, struct request *);
66ac0280
CH
779extern void blk_add_request_payload(struct request *rq, struct page *page,
780 unsigned int len);
82124d60 781extern int blk_rq_check_limits(struct request_queue *q, struct request *rq);
ef9e3fac 782extern int blk_lld_busy(struct request_queue *q);
b0fd271d
KU
783extern int blk_rq_prep_clone(struct request *rq, struct request *rq_src,
784 struct bio_set *bs, gfp_t gfp_mask,
785 int (*bio_ctr)(struct bio *, struct bio *, void *),
786 void *data);
787extern void blk_rq_unprep_clone(struct request *rq);
82124d60
KU
788extern int blk_insert_cloned_request(struct request_queue *q,
789 struct request *rq);
3cca6dc1 790extern void blk_delay_queue(struct request_queue *, unsigned long);
165125e1 791extern void blk_recount_segments(struct request_queue *, struct bio *);
0bfc96cb 792extern int scsi_verify_blk_ioctl(struct block_device *, unsigned int);
577ebb37
PB
793extern int scsi_cmd_blk_ioctl(struct block_device *, fmode_t,
794 unsigned int, void __user *);
74f3c8af
AV
795extern int scsi_cmd_ioctl(struct request_queue *, struct gendisk *, fmode_t,
796 unsigned int, void __user *);
e915e872
AV
797extern int sg_scsi_ioctl(struct request_queue *, struct gendisk *, fmode_t,
798 struct scsi_ioctl_command __user *);
3fcfab16 799
5a7bbad2 800extern void blk_queue_bio(struct request_queue *q, struct bio *bio);
166e1f90 801
3fcfab16
AM
802/*
803 * A queue has just exitted congestion. Note this in the global counter of
804 * congested queues, and wake up anyone who was waiting for requests to be
805 * put back.
806 */
8aa7e847 807static inline void blk_clear_queue_congested(struct request_queue *q, int sync)
3fcfab16 808{
8aa7e847 809 clear_bdi_congested(&q->backing_dev_info, sync);
3fcfab16
AM
810}
811
812/*
813 * A queue has just entered congestion. Flag that in the queue's VM-visible
814 * state flags and increment the global gounter of congested queues.
815 */
8aa7e847 816static inline void blk_set_queue_congested(struct request_queue *q, int sync)
3fcfab16 817{
8aa7e847 818 set_bdi_congested(&q->backing_dev_info, sync);
3fcfab16
AM
819}
820
165125e1
JA
821extern void blk_start_queue(struct request_queue *q);
822extern void blk_stop_queue(struct request_queue *q);
1da177e4 823extern void blk_sync_queue(struct request_queue *q);
165125e1 824extern void __blk_stop_queue(struct request_queue *q);
24ecfbe2 825extern void __blk_run_queue(struct request_queue *q);
165125e1 826extern void blk_run_queue(struct request_queue *);
c21e6beb 827extern void blk_run_queue_async(struct request_queue *q);
a3bce90e 828extern int blk_rq_map_user(struct request_queue *, struct request *,
152e283f
FT
829 struct rq_map_data *, void __user *, unsigned long,
830 gfp_t);
8e5cfc45 831extern int blk_rq_unmap_user(struct bio *);
165125e1
JA
832extern int blk_rq_map_kern(struct request_queue *, struct request *, void *, unsigned int, gfp_t);
833extern int blk_rq_map_user_iov(struct request_queue *, struct request *,
152e283f
FT
834 struct rq_map_data *, struct sg_iovec *, int,
835 unsigned int, gfp_t);
165125e1 836extern int blk_execute_rq(struct request_queue *, struct gendisk *,
994ca9a1 837 struct request *, int);
165125e1 838extern void blk_execute_rq_nowait(struct request_queue *, struct gendisk *,
15fc858a 839 struct request *, int, rq_end_io_fn *);
6e39b69e 840
165125e1 841static inline struct request_queue *bdev_get_queue(struct block_device *bdev)
1da177e4
LT
842{
843 return bdev->bd_disk->queue;
844}
845
5efccd17 846/*
80a761fd
TH
847 * blk_rq_pos() : the current sector
848 * blk_rq_bytes() : bytes left in the entire request
849 * blk_rq_cur_bytes() : bytes left in the current segment
850 * blk_rq_err_bytes() : bytes left till the next error boundary
851 * blk_rq_sectors() : sectors left in the entire request
852 * blk_rq_cur_sectors() : sectors left in the current segment
5efccd17 853 */
5b93629b
TH
854static inline sector_t blk_rq_pos(const struct request *rq)
855{
a2dec7b3 856 return rq->__sector;
2e46e8b2
TH
857}
858
859static inline unsigned int blk_rq_bytes(const struct request *rq)
860{
a2dec7b3 861 return rq->__data_len;
5b93629b
TH
862}
863
2e46e8b2
TH
864static inline int blk_rq_cur_bytes(const struct request *rq)
865{
866 return rq->bio ? bio_cur_bytes(rq->bio) : 0;
867}
5efccd17 868
80a761fd
TH
869extern unsigned int blk_rq_err_bytes(const struct request *rq);
870
5b93629b
TH
871static inline unsigned int blk_rq_sectors(const struct request *rq)
872{
2e46e8b2 873 return blk_rq_bytes(rq) >> 9;
5b93629b
TH
874}
875
876static inline unsigned int blk_rq_cur_sectors(const struct request *rq)
877{
2e46e8b2 878 return blk_rq_cur_bytes(rq) >> 9;
5b93629b
TH
879}
880
f31dc1cd
MP
881static inline unsigned int blk_queue_get_max_sectors(struct request_queue *q,
882 unsigned int cmd_flags)
883{
884 if (unlikely(cmd_flags & REQ_DISCARD))
871dd928 885 return min(q->limits.max_discard_sectors, UINT_MAX >> 9);
f31dc1cd 886
4363ac7c
MP
887 if (unlikely(cmd_flags & REQ_WRITE_SAME))
888 return q->limits.max_write_same_sectors;
889
f31dc1cd
MP
890 return q->limits.max_sectors;
891}
892
893static inline unsigned int blk_rq_get_max_sectors(struct request *rq)
894{
895 struct request_queue *q = rq->q;
896
897 if (unlikely(rq->cmd_type == REQ_TYPE_BLOCK_PC))
898 return q->limits.max_hw_sectors;
899
900 return blk_queue_get_max_sectors(q, rq->cmd_flags);
901}
902
75afb352
JN
903static inline unsigned int blk_rq_count_bios(struct request *rq)
904{
905 unsigned int nr_bios = 0;
906 struct bio *bio;
907
908 __rq_for_each_bio(bio, rq)
909 nr_bios++;
910
911 return nr_bios;
912}
913
9934c8c0
TH
914/*
915 * Request issue related functions.
916 */
917extern struct request *blk_peek_request(struct request_queue *q);
918extern void blk_start_request(struct request *rq);
919extern struct request *blk_fetch_request(struct request_queue *q);
920
1da177e4 921/*
2e60e022
TH
922 * Request completion related functions.
923 *
924 * blk_update_request() completes given number of bytes and updates
925 * the request without completing it.
926 *
f06d9a2b
TH
927 * blk_end_request() and friends. __blk_end_request() must be called
928 * with the request queue spinlock acquired.
1da177e4
LT
929 *
930 * Several drivers define their own end_request and call
3bcddeac
KU
931 * blk_end_request() for parts of the original function.
932 * This prevents code duplication in drivers.
1da177e4 933 */
2e60e022
TH
934extern bool blk_update_request(struct request *rq, int error,
935 unsigned int nr_bytes);
b1f74493
FT
936extern bool blk_end_request(struct request *rq, int error,
937 unsigned int nr_bytes);
938extern void blk_end_request_all(struct request *rq, int error);
939extern bool blk_end_request_cur(struct request *rq, int error);
80a761fd 940extern bool blk_end_request_err(struct request *rq, int error);
b1f74493
FT
941extern bool __blk_end_request(struct request *rq, int error,
942 unsigned int nr_bytes);
943extern void __blk_end_request_all(struct request *rq, int error);
944extern bool __blk_end_request_cur(struct request *rq, int error);
80a761fd 945extern bool __blk_end_request_err(struct request *rq, int error);
2e60e022 946
ff856bad 947extern void blk_complete_request(struct request *);
242f9dcb
JA
948extern void __blk_complete_request(struct request *);
949extern void blk_abort_request(struct request *);
28018c24 950extern void blk_unprep_request(struct request *);
ff856bad 951
1da177e4
LT
952/*
953 * Access functions for manipulating queue properties
954 */
165125e1 955extern struct request_queue *blk_init_queue_node(request_fn_proc *rfn,
1946089a 956 spinlock_t *lock, int node_id);
165125e1 957extern struct request_queue *blk_init_queue(request_fn_proc *, spinlock_t *);
01effb0d
MS
958extern struct request_queue *blk_init_allocated_queue(struct request_queue *,
959 request_fn_proc *, spinlock_t *);
165125e1
JA
960extern void blk_cleanup_queue(struct request_queue *);
961extern void blk_queue_make_request(struct request_queue *, make_request_fn *);
962extern void blk_queue_bounce_limit(struct request_queue *, u64);
72d4cd9f 963extern void blk_limits_max_hw_sectors(struct queue_limits *, unsigned int);
086fa5ff 964extern void blk_queue_max_hw_sectors(struct request_queue *, unsigned int);
8a78362c 965extern void blk_queue_max_segments(struct request_queue *, unsigned short);
165125e1 966extern void blk_queue_max_segment_size(struct request_queue *, unsigned int);
67efc925
CH
967extern void blk_queue_max_discard_sectors(struct request_queue *q,
968 unsigned int max_discard_sectors);
4363ac7c
MP
969extern void blk_queue_max_write_same_sectors(struct request_queue *q,
970 unsigned int max_write_same_sectors);
e1defc4f 971extern void blk_queue_logical_block_size(struct request_queue *, unsigned short);
892b6f90 972extern void blk_queue_physical_block_size(struct request_queue *, unsigned int);
c72758f3
MP
973extern void blk_queue_alignment_offset(struct request_queue *q,
974 unsigned int alignment);
7c958e32 975extern void blk_limits_io_min(struct queue_limits *limits, unsigned int min);
c72758f3 976extern void blk_queue_io_min(struct request_queue *q, unsigned int min);
3c5820c7 977extern void blk_limits_io_opt(struct queue_limits *limits, unsigned int opt);
c72758f3 978extern void blk_queue_io_opt(struct request_queue *q, unsigned int opt);
e475bba2 979extern void blk_set_default_limits(struct queue_limits *lim);
b1bd055d 980extern void blk_set_stacking_limits(struct queue_limits *lim);
c72758f3
MP
981extern int blk_stack_limits(struct queue_limits *t, struct queue_limits *b,
982 sector_t offset);
17be8c24
MP
983extern int bdev_stack_limits(struct queue_limits *t, struct block_device *bdev,
984 sector_t offset);
c72758f3
MP
985extern void disk_stack_limits(struct gendisk *disk, struct block_device *bdev,
986 sector_t offset);
165125e1 987extern void blk_queue_stack_limits(struct request_queue *t, struct request_queue *b);
e3790c7d 988extern void blk_queue_dma_pad(struct request_queue *, unsigned int);
27f8221a 989extern void blk_queue_update_dma_pad(struct request_queue *, unsigned int);
2fb98e84
TH
990extern int blk_queue_dma_drain(struct request_queue *q,
991 dma_drain_needed_fn *dma_drain_needed,
992 void *buf, unsigned int size);
ef9e3fac 993extern void blk_queue_lld_busy(struct request_queue *q, lld_busy_fn *fn);
165125e1
JA
994extern void blk_queue_segment_boundary(struct request_queue *, unsigned long);
995extern void blk_queue_prep_rq(struct request_queue *, prep_rq_fn *pfn);
28018c24 996extern void blk_queue_unprep_rq(struct request_queue *, unprep_rq_fn *ufn);
165125e1
JA
997extern void blk_queue_merge_bvec(struct request_queue *, merge_bvec_fn *);
998extern void blk_queue_dma_alignment(struct request_queue *, int);
11c3e689 999extern void blk_queue_update_dma_alignment(struct request_queue *, int);
165125e1 1000extern void blk_queue_softirq_done(struct request_queue *, softirq_done_fn *);
242f9dcb
JA
1001extern void blk_queue_rq_timed_out(struct request_queue *, rq_timed_out_fn *);
1002extern void blk_queue_rq_timeout(struct request_queue *, unsigned int);
4913efe4 1003extern void blk_queue_flush(struct request_queue *q, unsigned int flush);
f3876930 1004extern void blk_queue_flush_queueable(struct request_queue *q, bool queueable);
1da177e4 1005extern struct backing_dev_info *blk_get_backing_dev_info(struct block_device *bdev);
1da177e4 1006
165125e1 1007extern int blk_rq_map_sg(struct request_queue *, struct request *, struct scatterlist *);
85b9f66a
AH
1008extern int blk_bio_map_sg(struct request_queue *q, struct bio *bio,
1009 struct scatterlist *sglist);
1da177e4 1010extern void blk_dump_rq_flags(struct request *, char *);
1da177e4 1011extern long nr_blockdev_pages(void);
1da177e4 1012
09ac46c4 1013bool __must_check blk_get_queue(struct request_queue *);
165125e1
JA
1014struct request_queue *blk_alloc_queue(gfp_t);
1015struct request_queue *blk_alloc_queue_node(gfp_t, int);
1016extern void blk_put_queue(struct request_queue *);
1da177e4 1017
6c954667
LM
1018/*
1019 * block layer runtime pm functions
1020 */
1021#ifdef CONFIG_PM_RUNTIME
1022extern void blk_pm_runtime_init(struct request_queue *q, struct device *dev);
1023extern int blk_pre_runtime_suspend(struct request_queue *q);
1024extern void blk_post_runtime_suspend(struct request_queue *q, int err);
1025extern void blk_pre_runtime_resume(struct request_queue *q);
1026extern void blk_post_runtime_resume(struct request_queue *q, int err);
1027#else
1028static inline void blk_pm_runtime_init(struct request_queue *q,
1029 struct device *dev) {}
1030static inline int blk_pre_runtime_suspend(struct request_queue *q)
1031{
1032 return -ENOSYS;
1033}
1034static inline void blk_post_runtime_suspend(struct request_queue *q, int err) {}
1035static inline void blk_pre_runtime_resume(struct request_queue *q) {}
1036static inline void blk_post_runtime_resume(struct request_queue *q, int err) {}
1037#endif
1038
316cc67d 1039/*
75df7136
SJ
1040 * blk_plug permits building a queue of related requests by holding the I/O
1041 * fragments for a short period. This allows merging of sequential requests
1042 * into single larger request. As the requests are moved from a per-task list to
1043 * the device's request_queue in a batch, this results in improved scalability
1044 * as the lock contention for request_queue lock is reduced.
1045 *
1046 * It is ok not to disable preemption when adding the request to the plug list
1047 * or when attempting a merge, because blk_schedule_flush_list() will only flush
1048 * the plug list when the task sleeps by itself. For details, please see
1049 * schedule() where blk_schedule_flush_plug() is called.
316cc67d 1050 */
73c10101 1051struct blk_plug {
75df7136
SJ
1052 unsigned long magic; /* detect uninitialized use-cases */
1053 struct list_head list; /* requests */
320ae51f 1054 struct list_head mq_list; /* blk-mq requests */
75df7136 1055 struct list_head cb_list; /* md requires an unplug callback */
73c10101 1056};
55c022bb
SL
1057#define BLK_MAX_REQUEST_COUNT 16
1058
9cbb1750 1059struct blk_plug_cb;
74018dc3 1060typedef void (*blk_plug_cb_fn)(struct blk_plug_cb *, bool);
048c9374
N
1061struct blk_plug_cb {
1062 struct list_head list;
9cbb1750
N
1063 blk_plug_cb_fn callback;
1064 void *data;
048c9374 1065};
9cbb1750
N
1066extern struct blk_plug_cb *blk_check_plugged(blk_plug_cb_fn unplug,
1067 void *data, int size);
73c10101
JA
1068extern void blk_start_plug(struct blk_plug *);
1069extern void blk_finish_plug(struct blk_plug *);
f6603783 1070extern void blk_flush_plug_list(struct blk_plug *, bool);
73c10101
JA
1071
1072static inline void blk_flush_plug(struct task_struct *tsk)
1073{
1074 struct blk_plug *plug = tsk->plug;
1075
a237c1c5
JA
1076 if (plug)
1077 blk_flush_plug_list(plug, false);
1078}
1079
1080static inline void blk_schedule_flush_plug(struct task_struct *tsk)
1081{
1082 struct blk_plug *plug = tsk->plug;
1083
88b996cd 1084 if (plug)
f6603783 1085 blk_flush_plug_list(plug, true);
73c10101
JA
1086}
1087
1088static inline bool blk_needs_flush_plug(struct task_struct *tsk)
1089{
1090 struct blk_plug *plug = tsk->plug;
1091
320ae51f
JA
1092 return plug &&
1093 (!list_empty(&plug->list) ||
1094 !list_empty(&plug->mq_list) ||
1095 !list_empty(&plug->cb_list));
73c10101
JA
1096}
1097
1da177e4
LT
1098/*
1099 * tag stuff
1100 */
4aff5e23 1101#define blk_rq_tagged(rq) ((rq)->cmd_flags & REQ_QUEUED)
165125e1
JA
1102extern int blk_queue_start_tag(struct request_queue *, struct request *);
1103extern struct request *blk_queue_find_tag(struct request_queue *, int);
1104extern void blk_queue_end_tag(struct request_queue *, struct request *);
1105extern int blk_queue_init_tags(struct request_queue *, int, struct blk_queue_tag *);
1106extern void blk_queue_free_tags(struct request_queue *);
1107extern int blk_queue_resize_tags(struct request_queue *, int);
1108extern void blk_queue_invalidate_tags(struct request_queue *);
492dfb48
JB
1109extern struct blk_queue_tag *blk_init_tags(int);
1110extern void blk_free_tags(struct blk_queue_tag *);
1da177e4 1111
f583f492
DS
1112static inline struct request *blk_map_queue_find_tag(struct blk_queue_tag *bqt,
1113 int tag)
1114{
1115 if (unlikely(bqt == NULL || tag >= bqt->real_max_depth))
1116 return NULL;
1117 return bqt->tag_index[tag];
1118}
dd3932ed
CH
1119
1120#define BLKDEV_DISCARD_SECURE 0x01 /* secure discard */
1121
1122extern int blkdev_issue_flush(struct block_device *, gfp_t, sector_t *);
fbd9b09a
DM
1123extern int blkdev_issue_discard(struct block_device *bdev, sector_t sector,
1124 sector_t nr_sects, gfp_t gfp_mask, unsigned long flags);
4363ac7c
MP
1125extern int blkdev_issue_write_same(struct block_device *bdev, sector_t sector,
1126 sector_t nr_sects, gfp_t gfp_mask, struct page *page);
3f14d792 1127extern int blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
dd3932ed 1128 sector_t nr_sects, gfp_t gfp_mask);
2cf6d26a
CH
1129static inline int sb_issue_discard(struct super_block *sb, sector_t block,
1130 sector_t nr_blocks, gfp_t gfp_mask, unsigned long flags)
fb2dce86 1131{
2cf6d26a
CH
1132 return blkdev_issue_discard(sb->s_bdev, block << (sb->s_blocksize_bits - 9),
1133 nr_blocks << (sb->s_blocksize_bits - 9),
1134 gfp_mask, flags);
fb2dce86 1135}
e6fa0be6 1136static inline int sb_issue_zeroout(struct super_block *sb, sector_t block,
a107e5a3 1137 sector_t nr_blocks, gfp_t gfp_mask)
e6fa0be6
LC
1138{
1139 return blkdev_issue_zeroout(sb->s_bdev,
1140 block << (sb->s_blocksize_bits - 9),
1141 nr_blocks << (sb->s_blocksize_bits - 9),
a107e5a3 1142 gfp_mask);
e6fa0be6 1143}
1da177e4 1144
018e0446 1145extern int blk_verify_command(unsigned char *cmd, fmode_t has_write_perm);
0b07de85 1146
eb28d31b
MP
1147enum blk_default_limits {
1148 BLK_MAX_SEGMENTS = 128,
1149 BLK_SAFE_MAX_SECTORS = 255,
1150 BLK_DEF_MAX_SECTORS = 1024,
1151 BLK_MAX_SEGMENT_SIZE = 65536,
1152 BLK_SEG_BOUNDARY_MASK = 0xFFFFFFFFUL,
1153};
0e435ac2 1154
1da177e4
LT
1155#define blkdev_entry_to_request(entry) list_entry((entry), struct request, queuelist)
1156
ae03bf63
MP
1157static inline unsigned long queue_bounce_pfn(struct request_queue *q)
1158{
025146e1 1159 return q->limits.bounce_pfn;
ae03bf63
MP
1160}
1161
1162static inline unsigned long queue_segment_boundary(struct request_queue *q)
1163{
025146e1 1164 return q->limits.seg_boundary_mask;
ae03bf63
MP
1165}
1166
1167static inline unsigned int queue_max_sectors(struct request_queue *q)
1168{
025146e1 1169 return q->limits.max_sectors;
ae03bf63
MP
1170}
1171
1172static inline unsigned int queue_max_hw_sectors(struct request_queue *q)
1173{
025146e1 1174 return q->limits.max_hw_sectors;
ae03bf63
MP
1175}
1176
8a78362c 1177static inline unsigned short queue_max_segments(struct request_queue *q)
ae03bf63 1178{
8a78362c 1179 return q->limits.max_segments;
ae03bf63
MP
1180}
1181
1182static inline unsigned int queue_max_segment_size(struct request_queue *q)
1183{
025146e1 1184 return q->limits.max_segment_size;
ae03bf63
MP
1185}
1186
e1defc4f 1187static inline unsigned short queue_logical_block_size(struct request_queue *q)
1da177e4
LT
1188{
1189 int retval = 512;
1190
025146e1
MP
1191 if (q && q->limits.logical_block_size)
1192 retval = q->limits.logical_block_size;
1da177e4
LT
1193
1194 return retval;
1195}
1196
e1defc4f 1197static inline unsigned short bdev_logical_block_size(struct block_device *bdev)
1da177e4 1198{
e1defc4f 1199 return queue_logical_block_size(bdev_get_queue(bdev));
1da177e4
LT
1200}
1201
c72758f3
MP
1202static inline unsigned int queue_physical_block_size(struct request_queue *q)
1203{
1204 return q->limits.physical_block_size;
1205}
1206
892b6f90 1207static inline unsigned int bdev_physical_block_size(struct block_device *bdev)
ac481c20
MP
1208{
1209 return queue_physical_block_size(bdev_get_queue(bdev));
1210}
1211
c72758f3
MP
1212static inline unsigned int queue_io_min(struct request_queue *q)
1213{
1214 return q->limits.io_min;
1215}
1216
ac481c20
MP
1217static inline int bdev_io_min(struct block_device *bdev)
1218{
1219 return queue_io_min(bdev_get_queue(bdev));
1220}
1221
c72758f3
MP
1222static inline unsigned int queue_io_opt(struct request_queue *q)
1223{
1224 return q->limits.io_opt;
1225}
1226
ac481c20
MP
1227static inline int bdev_io_opt(struct block_device *bdev)
1228{
1229 return queue_io_opt(bdev_get_queue(bdev));
1230}
1231
c72758f3
MP
1232static inline int queue_alignment_offset(struct request_queue *q)
1233{
ac481c20 1234 if (q->limits.misaligned)
c72758f3
MP
1235 return -1;
1236
ac481c20 1237 return q->limits.alignment_offset;
c72758f3
MP
1238}
1239
e03a72e1 1240static inline int queue_limit_alignment_offset(struct queue_limits *lim, sector_t sector)
81744ee4
MP
1241{
1242 unsigned int granularity = max(lim->physical_block_size, lim->io_min);
e03a72e1 1243 unsigned int alignment = (sector << 9) & (granularity - 1);
81744ee4 1244
e03a72e1
MP
1245 return (granularity + lim->alignment_offset - alignment)
1246 & (granularity - 1);
c72758f3
MP
1247}
1248
ac481c20
MP
1249static inline int bdev_alignment_offset(struct block_device *bdev)
1250{
1251 struct request_queue *q = bdev_get_queue(bdev);
1252
1253 if (q->limits.misaligned)
1254 return -1;
1255
1256 if (bdev != bdev->bd_contains)
1257 return bdev->bd_part->alignment_offset;
1258
1259 return q->limits.alignment_offset;
1260}
1261
86b37281
MP
1262static inline int queue_discard_alignment(struct request_queue *q)
1263{
1264 if (q->limits.discard_misaligned)
1265 return -1;
1266
1267 return q->limits.discard_alignment;
1268}
1269
e03a72e1 1270static inline int queue_limit_discard_alignment(struct queue_limits *lim, sector_t sector)
86b37281 1271{
59771079 1272 unsigned int alignment, granularity, offset;
dd3d145d 1273
a934a00a
MP
1274 if (!lim->max_discard_sectors)
1275 return 0;
1276
59771079
LT
1277 /* Why are these in bytes, not sectors? */
1278 alignment = lim->discard_alignment >> 9;
1279 granularity = lim->discard_granularity >> 9;
1280 if (!granularity)
1281 return 0;
1282
1283 /* Offset of the partition start in 'granularity' sectors */
1284 offset = sector_div(sector, granularity);
1285
1286 /* And why do we do this modulus *again* in blkdev_issue_discard()? */
1287 offset = (granularity + alignment - offset) % granularity;
1288
1289 /* Turn it back into bytes, gaah */
1290 return offset << 9;
86b37281
MP
1291}
1292
c6e66634
PB
1293static inline int bdev_discard_alignment(struct block_device *bdev)
1294{
1295 struct request_queue *q = bdev_get_queue(bdev);
1296
1297 if (bdev != bdev->bd_contains)
1298 return bdev->bd_part->discard_alignment;
1299
1300 return q->limits.discard_alignment;
1301}
1302
98262f27
MP
1303static inline unsigned int queue_discard_zeroes_data(struct request_queue *q)
1304{
a934a00a 1305 if (q->limits.max_discard_sectors && q->limits.discard_zeroes_data == 1)
98262f27
MP
1306 return 1;
1307
1308 return 0;
1309}
1310
1311static inline unsigned int bdev_discard_zeroes_data(struct block_device *bdev)
1312{
1313 return queue_discard_zeroes_data(bdev_get_queue(bdev));
1314}
1315
4363ac7c
MP
1316static inline unsigned int bdev_write_same(struct block_device *bdev)
1317{
1318 struct request_queue *q = bdev_get_queue(bdev);
1319
1320 if (q)
1321 return q->limits.max_write_same_sectors;
1322
1323 return 0;
1324}
1325
165125e1 1326static inline int queue_dma_alignment(struct request_queue *q)
1da177e4 1327{
482eb689 1328 return q ? q->dma_alignment : 511;
1da177e4
LT
1329}
1330
14417799 1331static inline int blk_rq_aligned(struct request_queue *q, unsigned long addr,
87904074
FT
1332 unsigned int len)
1333{
1334 unsigned int alignment = queue_dma_alignment(q) | q->dma_pad_mask;
14417799 1335 return !(addr & alignment) && !(len & alignment);
87904074
FT
1336}
1337
1da177e4
LT
1338/* assumes size > 256 */
1339static inline unsigned int blksize_bits(unsigned int size)
1340{
1341 unsigned int bits = 8;
1342 do {
1343 bits++;
1344 size >>= 1;
1345 } while (size > 256);
1346 return bits;
1347}
1348
2befb9e3 1349static inline unsigned int block_size(struct block_device *bdev)
1da177e4
LT
1350{
1351 return bdev->bd_block_size;
1352}
1353
f3876930 1354static inline bool queue_flush_queueable(struct request_queue *q)
1355{
1356 return !q->flush_not_queueable;
1357}
1358
1da177e4
LT
1359typedef struct {struct page *v;} Sector;
1360
1361unsigned char *read_dev_sector(struct block_device *, sector_t, Sector *);
1362
1363static inline void put_dev_sector(Sector p)
1364{
1365 page_cache_release(p.v);
1366}
1367
1368struct work_struct;
18887ad9 1369int kblockd_schedule_work(struct request_queue *q, struct work_struct *work);
320ae51f 1370int kblockd_schedule_delayed_work(struct request_queue *q, struct delayed_work *dwork, unsigned long delay);
1da177e4 1371
9195291e 1372#ifdef CONFIG_BLK_CGROUP
28f4197e
JA
1373/*
1374 * This should not be using sched_clock(). A real patch is in progress
1375 * to fix this up, until that is in place we need to disable preemption
1376 * around sched_clock() in this function and set_io_start_time_ns().
1377 */
9195291e
DS
1378static inline void set_start_time_ns(struct request *req)
1379{
28f4197e 1380 preempt_disable();
9195291e 1381 req->start_time_ns = sched_clock();
28f4197e 1382 preempt_enable();
9195291e
DS
1383}
1384
1385static inline void set_io_start_time_ns(struct request *req)
1386{
28f4197e 1387 preempt_disable();
9195291e 1388 req->io_start_time_ns = sched_clock();
28f4197e 1389 preempt_enable();
9195291e 1390}
84c124da
DS
1391
1392static inline uint64_t rq_start_time_ns(struct request *req)
1393{
1394 return req->start_time_ns;
1395}
1396
1397static inline uint64_t rq_io_start_time_ns(struct request *req)
1398{
1399 return req->io_start_time_ns;
1400}
9195291e
DS
1401#else
1402static inline void set_start_time_ns(struct request *req) {}
1403static inline void set_io_start_time_ns(struct request *req) {}
84c124da
DS
1404static inline uint64_t rq_start_time_ns(struct request *req)
1405{
1406 return 0;
1407}
1408static inline uint64_t rq_io_start_time_ns(struct request *req)
1409{
1410 return 0;
1411}
9195291e
DS
1412#endif
1413
1da177e4
LT
1414#define MODULE_ALIAS_BLOCKDEV(major,minor) \
1415 MODULE_ALIAS("block-major-" __stringify(major) "-" __stringify(minor))
1416#define MODULE_ALIAS_BLOCKDEV_MAJOR(major) \
1417 MODULE_ALIAS("block-major-" __stringify(major) "-*")
1418
7ba1ba12
MP
1419#if defined(CONFIG_BLK_DEV_INTEGRITY)
1420
b24498d4
JA
1421#define INTEGRITY_FLAG_READ 2 /* verify data integrity on read */
1422#define INTEGRITY_FLAG_WRITE 4 /* generate data integrity on write */
7ba1ba12
MP
1423
1424struct blk_integrity_exchg {
1425 void *prot_buf;
1426 void *data_buf;
1427 sector_t sector;
1428 unsigned int data_size;
1429 unsigned short sector_size;
1430 const char *disk_name;
1431};
1432
1433typedef void (integrity_gen_fn) (struct blk_integrity_exchg *);
1434typedef int (integrity_vrfy_fn) (struct blk_integrity_exchg *);
1435typedef void (integrity_set_tag_fn) (void *, void *, unsigned int);
1436typedef void (integrity_get_tag_fn) (void *, void *, unsigned int);
1437
1438struct blk_integrity {
1439 integrity_gen_fn *generate_fn;
1440 integrity_vrfy_fn *verify_fn;
1441 integrity_set_tag_fn *set_tag_fn;
1442 integrity_get_tag_fn *get_tag_fn;
1443
1444 unsigned short flags;
1445 unsigned short tuple_size;
1446 unsigned short sector_size;
1447 unsigned short tag_size;
1448
1449 const char *name;
1450
1451 struct kobject kobj;
1452};
1453
a63a5cf8 1454extern bool blk_integrity_is_initialized(struct gendisk *);
7ba1ba12
MP
1455extern int blk_integrity_register(struct gendisk *, struct blk_integrity *);
1456extern void blk_integrity_unregister(struct gendisk *);
ad7fce93 1457extern int blk_integrity_compare(struct gendisk *, struct gendisk *);
13f05c8d
MP
1458extern int blk_rq_map_integrity_sg(struct request_queue *, struct bio *,
1459 struct scatterlist *);
1460extern int blk_rq_count_integrity_sg(struct request_queue *, struct bio *);
1461extern int blk_integrity_merge_rq(struct request_queue *, struct request *,
1462 struct request *);
1463extern int blk_integrity_merge_bio(struct request_queue *, struct request *,
1464 struct bio *);
7ba1ba12 1465
b04accc4
JA
1466static inline
1467struct blk_integrity *bdev_get_integrity(struct block_device *bdev)
1468{
1469 return bdev->bd_disk->integrity;
1470}
1471
b02739b0
MP
1472static inline struct blk_integrity *blk_get_integrity(struct gendisk *disk)
1473{
1474 return disk->integrity;
1475}
1476
7ba1ba12
MP
1477static inline int blk_integrity_rq(struct request *rq)
1478{
d442cc44
MP
1479 if (rq->bio == NULL)
1480 return 0;
1481
7ba1ba12
MP
1482 return bio_integrity(rq->bio);
1483}
1484
13f05c8d
MP
1485static inline void blk_queue_max_integrity_segments(struct request_queue *q,
1486 unsigned int segs)
1487{
1488 q->limits.max_integrity_segments = segs;
1489}
1490
1491static inline unsigned short
1492queue_max_integrity_segments(struct request_queue *q)
1493{
1494 return q->limits.max_integrity_segments;
1495}
1496
7ba1ba12
MP
1497#else /* CONFIG_BLK_DEV_INTEGRITY */
1498
fd83240a
SR
1499struct bio;
1500struct block_device;
1501struct gendisk;
1502struct blk_integrity;
1503
1504static inline int blk_integrity_rq(struct request *rq)
1505{
1506 return 0;
1507}
1508static inline int blk_rq_count_integrity_sg(struct request_queue *q,
1509 struct bio *b)
1510{
1511 return 0;
1512}
1513static inline int blk_rq_map_integrity_sg(struct request_queue *q,
1514 struct bio *b,
1515 struct scatterlist *s)
1516{
1517 return 0;
1518}
1519static inline struct blk_integrity *bdev_get_integrity(struct block_device *b)
1520{
1521 return 0;
1522}
1523static inline struct blk_integrity *blk_get_integrity(struct gendisk *disk)
1524{
1525 return NULL;
1526}
1527static inline int blk_integrity_compare(struct gendisk *a, struct gendisk *b)
1528{
1529 return 0;
1530}
1531static inline int blk_integrity_register(struct gendisk *d,
1532 struct blk_integrity *b)
1533{
1534 return 0;
1535}
1536static inline void blk_integrity_unregister(struct gendisk *d)
1537{
1538}
1539static inline void blk_queue_max_integrity_segments(struct request_queue *q,
1540 unsigned int segs)
1541{
1542}
1543static inline unsigned short queue_max_integrity_segments(struct request_queue *q)
1544{
1545 return 0;
1546}
1547static inline int blk_integrity_merge_rq(struct request_queue *rq,
1548 struct request *r1,
1549 struct request *r2)
1550{
1551 return 0;
1552}
1553static inline int blk_integrity_merge_bio(struct request_queue *rq,
1554 struct request *r,
1555 struct bio *b)
1556{
1557 return 0;
1558}
1559static inline bool blk_integrity_is_initialized(struct gendisk *g)
1560{
1561 return 0;
1562}
7ba1ba12
MP
1563
1564#endif /* CONFIG_BLK_DEV_INTEGRITY */
1565
08f85851 1566struct block_device_operations {
d4430d62 1567 int (*open) (struct block_device *, fmode_t);
db2a144b 1568 void (*release) (struct gendisk *, fmode_t);
d4430d62
AV
1569 int (*ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
1570 int (*compat_ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
08f85851
AV
1571 int (*direct_access) (struct block_device *, sector_t,
1572 void **, unsigned long *);
77ea887e
TH
1573 unsigned int (*check_events) (struct gendisk *disk,
1574 unsigned int clearing);
1575 /* ->media_changed() is DEPRECATED, use ->check_events() instead */
08f85851 1576 int (*media_changed) (struct gendisk *);
c3e33e04 1577 void (*unlock_native_capacity) (struct gendisk *);
08f85851
AV
1578 int (*revalidate_disk) (struct gendisk *);
1579 int (*getgeo)(struct block_device *, struct hd_geometry *);
b3a27d05
NG
1580 /* this callback is with swap_lock and sometimes page table lock held */
1581 void (*swap_slot_free_notify) (struct block_device *, unsigned long);
08f85851
AV
1582 struct module *owner;
1583};
1584
633a08b8
AV
1585extern int __blkdev_driver_ioctl(struct block_device *, fmode_t, unsigned int,
1586 unsigned long);
9361401e
DH
1587#else /* CONFIG_BLOCK */
1588/*
1589 * stubs for when the block layer is configured out
1590 */
1591#define buffer_heads_over_limit 0
1592
9361401e
DH
1593static inline long nr_blockdev_pages(void)
1594{
1595 return 0;
1596}
1597
1f940bdf
JA
1598struct blk_plug {
1599};
1600
1601static inline void blk_start_plug(struct blk_plug *plug)
73c10101
JA
1602{
1603}
1604
1f940bdf 1605static inline void blk_finish_plug(struct blk_plug *plug)
73c10101
JA
1606{
1607}
1608
1f940bdf 1609static inline void blk_flush_plug(struct task_struct *task)
73c10101
JA
1610{
1611}
1612
a237c1c5
JA
1613static inline void blk_schedule_flush_plug(struct task_struct *task)
1614{
1615}
1616
1617
73c10101
JA
1618static inline bool blk_needs_flush_plug(struct task_struct *tsk)
1619{
1620 return false;
1621}
1622
9361401e
DH
1623#endif /* CONFIG_BLOCK */
1624
1da177e4 1625#endif