blkdev.h 46 KB

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