Blame view
block/blk.h
10.8 KB
b24413180 License cleanup: ... |
1 |
/* SPDX-License-Identifier: GPL-2.0 */ |
8324aa91d block: split tag ... |
2 3 |
#ifndef BLK_INTERNAL_H #define BLK_INTERNAL_H |
a73f730d0 block, cfq: move ... |
4 |
#include <linux/idr.h> |
f70ced091 blk-mq: support p... |
5 |
#include <linux/blk-mq.h> |
c39ae60df block: remove ARC... |
6 |
#include <xen/xen.h> |
f70ced091 blk-mq: support p... |
7 |
#include "blk-mq.h" |
c3e221921 block: free sched... |
8 |
#include "blk-mq-sched.h" |
a73f730d0 block, cfq: move ... |
9 |
|
0d2602ca3 blk-mq: improve s... |
10 11 |
/* Max future timer expiry for timeouts */ #define BLK_MAX_TIMEOUT (5 * HZ) |
18fbda91c block: use same b... |
12 13 14 |
#ifdef CONFIG_DEBUG_FS extern struct dentry *blk_debugfs_root; #endif |
7c94e1c15 block: introduce ... |
15 16 17 18 |
struct blk_flush_queue { unsigned int flush_queue_delayed:1; unsigned int flush_pending_idx:1; unsigned int flush_running_idx:1; |
8d6996630 block: fix null p... |
19 |
blk_status_t rq_status; |
7c94e1c15 block: introduce ... |
20 21 22 23 |
unsigned long flush_pending_since; struct list_head flush_queue[2]; struct list_head flush_data_in_flight; struct request *flush_rq; |
0048b4837 blk-mq: fix race ... |
24 25 26 27 28 29 |
/* * flush_rq shares tag with this rq, both can't be active * at the same time */ struct request *orig_rq; |
f7cc2f988 block: Fix a lock... |
30 |
struct lock_class_key key; |
7c94e1c15 block: introduce ... |
31 32 |
spinlock_t mq_flush_lock; }; |
8324aa91d block: split tag ... |
33 34 |
extern struct kmem_cache *blk_requestq_cachep; extern struct kobj_type blk_queue_ktype; |
a73f730d0 block, cfq: move ... |
35 |
extern struct ida blk_queue_ida; |
8324aa91d block: split tag ... |
36 |
|
f9afca4d3 blk-mq: pass in r... |
37 38 |
static inline struct blk_flush_queue * blk_get_flush_queue(struct request_queue *q, struct blk_mq_ctx *ctx) |
7c94e1c15 block: introduce ... |
39 |
{ |
8ccdf4a37 blk-mq: save queu... |
40 |
return blk_mq_map_queue(q, REQ_OP_FLUSH, ctx)->fq; |
7c94e1c15 block: introduce ... |
41 |
} |
09ac46c42 block: misc updat... |
42 43 44 45 |
static inline void __blk_get_queue(struct request_queue *q) { kobject_get(&q->kobj); } |
8d6996630 block: fix null p... |
46 47 48 49 50 |
static inline bool is_flush_rq(struct request *req, struct blk_mq_hw_ctx *hctx) { return hctx->fq->flush_rq == req; } |
f70ced091 blk-mq: support p... |
51 |
struct blk_flush_queue *blk_alloc_flush_queue(struct request_queue *q, |
5b202853f blk-mq: change gf... |
52 |
int node, int cmd_size, gfp_t flags); |
f70ced091 blk-mq: support p... |
53 |
void blk_free_flush_queue(struct blk_flush_queue *q); |
f35526557 block: introduce ... |
54 |
|
3ef28e83a block: generic re... |
55 56 57 58 59 60 61 62 63 64 65 66 |
void blk_freeze_queue(struct request_queue *q); static inline void blk_queue_enter_live(struct request_queue *q) { /* * Given that running in generic_make_request() context * guarantees that a live reference against q_usage_counter has * been established, further references under that same context * need not check that the queue has been frozen (marked dead). */ percpu_ref_get(&q->q_usage_counter); } |
8324aa91d block: split tag ... |
67 |
|
3dccdae54 block: merge BIOV... |
68 69 |
static inline bool biovec_phys_mergeable(struct request_queue *q, struct bio_vec *vec1, struct bio_vec *vec2) |
6a9f5f240 block: simplify B... |
70 |
{ |
3dccdae54 block: merge BIOV... |
71 |
unsigned long mask = queue_segment_boundary(q); |
6e768461c block: remove bve... |
72 73 |
phys_addr_t addr1 = page_to_phys(vec1->bv_page) + vec1->bv_offset; phys_addr_t addr2 = page_to_phys(vec2->bv_page) + vec2->bv_offset; |
3dccdae54 block: merge BIOV... |
74 75 |
if (addr1 + vec1->bv_len != addr2) |
6a9f5f240 block: simplify B... |
76 |
return false; |
0383ad437 block: pass page ... |
77 |
if (xen_domain() && !xen_biovec_phys_mergeable(vec1, vec2->bv_page)) |
6a9f5f240 block: simplify B... |
78 |
return false; |
3dccdae54 block: merge BIOV... |
79 80 |
if ((addr1 | mask) != ((addr2 + vec2->bv_len - 1) | mask)) return false; |
6a9f5f240 block: simplify B... |
81 82 |
return true; } |
27ca1d4ed block: move req_g... |
83 84 85 |
static inline bool __bvec_gap_to_prev(struct request_queue *q, struct bio_vec *bprv, unsigned int offset) { |
df376b2ed block: respect vi... |
86 |
return (offset & queue_virt_boundary(q)) || |
27ca1d4ed block: move req_g... |
87 88 89 90 91 92 93 94 95 96 97 98 99 100 |
((bprv->bv_offset + bprv->bv_len) & queue_virt_boundary(q)); } /* * Check if adding a bio_vec after bprv with offset would create a gap in * the SG list. Most drivers don't care about this, but some do. */ static inline bool bvec_gap_to_prev(struct request_queue *q, struct bio_vec *bprv, unsigned int offset) { if (!queue_virt_boundary(q)) return false; return __bvec_gap_to_prev(q, bprv, offset); } |
1aa0a133f block: mark blk_r... |
101 102 103 104 105 106 107 108 109 110 111 |
static inline void blk_rq_bio_prep(struct request *rq, struct bio *bio, unsigned int nr_segs) { rq->nr_phys_segments = nr_segs; rq->__data_len = bio->bi_iter.bi_size; rq->bio = rq->biotail = bio; rq->ioprio = bio_prio(bio); if (bio->bi_disk) rq->rq_disk = bio->bi_disk; } |
5a48fc147 block: blk_flush_... |
112 113 |
#ifdef CONFIG_BLK_DEV_INTEGRITY void blk_flush_integrity(void); |
7c20f1168 bio-integrity: st... |
114 |
bool __bio_integrity_endio(struct bio *); |
ccbc5d03c block: fix memlea... |
115 |
void bio_integrity_free(struct bio *bio); |
7c20f1168 bio-integrity: st... |
116 117 118 119 120 121 |
static inline bool bio_integrity_endio(struct bio *bio) { if (bio_integrity(bio)) return __bio_integrity_endio(bio); return true; } |
43b729bfe block: move integ... |
122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 |
static inline bool integrity_req_gap_back_merge(struct request *req, struct bio *next) { struct bio_integrity_payload *bip = bio_integrity(req->bio); struct bio_integrity_payload *bip_next = bio_integrity(next); return bvec_gap_to_prev(req->q, &bip->bip_vec[bip->bip_vcnt - 1], bip_next->bip_vec[0].bv_offset); } static inline bool integrity_req_gap_front_merge(struct request *req, struct bio *bio) { struct bio_integrity_payload *bip = bio_integrity(bio); struct bio_integrity_payload *bip_next = bio_integrity(req->bio); return bvec_gap_to_prev(req->q, &bip->bip_vec[bip->bip_vcnt - 1], bip_next->bip_vec[0].bv_offset); } #else /* CONFIG_BLK_DEV_INTEGRITY */ static inline bool integrity_req_gap_back_merge(struct request *req, struct bio *next) { return false; } static inline bool integrity_req_gap_front_merge(struct request *req, struct bio *bio) { return false; } |
5a48fc147 block: blk_flush_... |
153 154 155 |
static inline void blk_flush_integrity(void) { } |
7c20f1168 bio-integrity: st... |
156 157 158 159 |
static inline bool bio_integrity_endio(struct bio *bio) { return true; } |
ccbc5d03c block: fix memlea... |
160 161 162 |
static inline void bio_integrity_free(struct bio *bio) { } |
43b729bfe block: move integ... |
163 |
#endif /* CONFIG_BLK_DEV_INTEGRITY */ |
8324aa91d block: split tag ... |
164 |
|
0d2602ca3 blk-mq: improve s... |
165 |
unsigned long blk_rq_timeout(unsigned long timeout); |
87ee7b112 blk-mq: fix race ... |
166 |
void blk_add_timer(struct request *req); |
320ae51fe blk-mq: new multi... |
167 |
|
14ccb66b3 block: remove the... |
168 169 170 171 |
bool bio_attempt_front_merge(struct request *req, struct bio *bio, unsigned int nr_segs); bool bio_attempt_back_merge(struct request *req, struct bio *bio, unsigned int nr_segs); |
1e739730c block: optionally... |
172 173 |
bool bio_attempt_discard_merge(struct request_queue *q, struct request *req, struct bio *bio); |
320ae51fe blk-mq: new multi... |
174 |
bool blk_attempt_plug_merge(struct request_queue *q, struct bio *bio, |
14ccb66b3 block: remove the... |
175 |
unsigned int nr_segs, struct request **same_queue_rq); |
320ae51fe blk-mq: new multi... |
176 177 178 |
void blk_account_io_start(struct request *req, bool new_io); void blk_account_io_completion(struct request *req, unsigned int bytes); |
522a77756 block: consolidat... |
179 |
void blk_account_io_done(struct request *req, u64 now); |
320ae51fe blk-mq: new multi... |
180 |
|
242f9dcb8 block: unify requ... |
181 |
/* |
158dbda00 block: reorganize... |
182 183 |
* Internal elevator interface */ |
e80640213 block: split out ... |
184 |
#define ELV_ON_HASH(rq) ((rq)->rq_flags & RQF_HASHED) |
158dbda00 block: reorganize... |
185 |
|
ae1b15396 block: reimplemen... |
186 |
void blk_insert_flush(struct request *rq); |
dd831006d block: misc clean... |
187 |
|
954b4a5ce block: Change ele... |
188 |
void elevator_init_mq(struct request_queue *q); |
d48ece209 blk-mq: init hctx... |
189 190 |
int elevator_switch_mq(struct request_queue *q, struct elevator_type *new_e); |
c3e221921 block: free sched... |
191 |
void __elevator_exit(struct request_queue *, struct elevator_queue *); |
cecf5d87f block: split .sys... |
192 |
int elv_register_queue(struct request_queue *q, bool uevent); |
83d016ac8 block: Unexport e... |
193 |
void elv_unregister_queue(struct request_queue *q); |
c3e221921 block: free sched... |
194 195 196 |
static inline void elevator_exit(struct request_queue *q, struct elevator_queue *e) { |
284b94be1 blk-mq: move lock... |
197 |
lockdep_assert_held(&q->sysfs_lock); |
c3e221921 block: free sched... |
198 199 200 |
blk_mq_sched_free_requests(q); __elevator_exit(q, e); } |
807d4af2f block: add a __di... |
201 |
struct hd_struct *__disk_get_part(struct gendisk *disk, int partno); |
581d4e28d block: add fault ... |
202 203 204 205 206 207 208 209 210 211 212 |
#ifdef CONFIG_FAIL_IO_TIMEOUT int blk_should_fake_timeout(struct request_queue *); ssize_t part_timeout_show(struct device *, struct device_attribute *, char *); ssize_t part_timeout_store(struct device *, struct device_attribute *, const char *, size_t); #else static inline int blk_should_fake_timeout(struct request_queue *q) { return 0; } #endif |
14ccb66b3 block: remove the... |
213 214 215 216 217 218 |
void __blk_queue_split(struct request_queue *q, struct bio **bio, unsigned int *nr_segs); int ll_back_merge_fn(struct request *req, struct bio *bio, unsigned int nr_segs); int ll_front_merge_fn(struct request *req, struct bio *bio, unsigned int nr_segs); |
b973cb7e8 blk-merge: return... |
219 220 |
struct request *attempt_back_merge(struct request_queue *q, struct request *rq); struct request *attempt_front_merge(struct request_queue *q, struct request *rq); |
5e84ea3a9 block: attempt to... |
221 222 |
int blk_attempt_req_merge(struct request_queue *q, struct request *rq, struct request *next); |
e9cd19c0c block: simplify b... |
223 |
unsigned int blk_recalc_rq_segments(struct request *rq); |
80a761fd3 block: implement ... |
224 |
void blk_rq_set_mixed_merge(struct request *rq); |
050c8ea80 block: separate o... |
225 |
bool blk_rq_merge_ok(struct request *rq, struct bio *bio); |
34fe7c054 block: enumify EL... |
226 |
enum elv_merge blk_try_merge(struct request *rq, struct bio *bio); |
d6d481969 block: ll_rw_blk.... |
227 |
|
ff88972c8 proper prototype ... |
228 |
int blk_dev_init(void); |
c2553b584 block: make blk_d... |
229 230 231 232 233 |
/* * Contribute to IO statistics IFF: * * a) it's attached to a gendisk, and * b) the queue had IO stats enabled when this request was started, and |
e2a60da74 block: Clean up s... |
234 |
* c) it's a file system request |
c2553b584 block: make blk_d... |
235 |
*/ |
599d067dd block: change ret... |
236 |
static inline bool blk_do_io_stat(struct request *rq) |
fb8ec18c3 block: fix oops i... |
237 |
{ |
33659ebba block: remove wra... |
238 |
return rq->rq_disk && |
e80640213 block: split out ... |
239 |
(rq->rq_flags & RQF_IO_STAT) && |
57292b58d block: introduce ... |
240 |
!blk_rq_is_passthrough(rq); |
fb8ec18c3 block: fix oops i... |
241 |
} |
6cf7677f1 block: move req_s... |
242 243 244 245 246 247 |
static inline void req_set_nomerge(struct request_queue *q, struct request *req) { req->cmd_flags |= REQ_NOMERGE; if (req == q->last_merge) q->last_merge = NULL; } |
f2dbd76a0 block, cfq: repla... |
248 |
/* |
1adfc5e41 block: make sure ... |
249 250 251 252 253 254 255 256 257 258 |
* The max size one bio can handle is UINT_MAX becasue bvec_iter.bi_size * is defined as 'unsigned int', meantime it has to aligned to with logical * block size which is the minimum accepted unit by hardware. */ static inline unsigned int bio_allowed_max_sectors(struct request_queue *q) { return round_down(UINT_MAX, queue_logical_block_size(q)) >> 9; } /* |
f2dbd76a0 block, cfq: repla... |
259 260 261 |
* Internal io_context interface */ void get_io_context(struct io_context *ioc); |
47fdd4ca9 block, cfq: move ... |
262 |
struct io_cq *ioc_lookup_icq(struct io_context *ioc, struct request_queue *q); |
24acfc34f block: interface ... |
263 264 |
struct io_cq *ioc_create_icq(struct io_context *ioc, struct request_queue *q, gfp_t gfp_mask); |
7e5a87944 block, cfq: move ... |
265 |
void ioc_clear_queue(struct request_queue *q); |
f2dbd76a0 block, cfq: repla... |
266 |
|
24acfc34f block: interface ... |
267 |
int create_task_io_context(struct task_struct *task, gfp_t gfp_mask, int node); |
f2dbd76a0 block, cfq: repla... |
268 269 270 |
/** * create_io_context - try to create task->io_context |
f2dbd76a0 block, cfq: repla... |
271 272 273 |
* @gfp_mask: allocation mask * @node: allocation node * |
24acfc34f block: interface ... |
274 275 276 |
* If %current->io_context is %NULL, allocate a new io_context and install * it. Returns the current %current->io_context which may be %NULL if * allocation failed. |
f2dbd76a0 block, cfq: repla... |
277 278 |
* * Note that this function can't be called with IRQ disabled because |
24acfc34f block: interface ... |
279 |
* task_lock which protects %current->io_context is IRQ-unsafe. |
f2dbd76a0 block, cfq: repla... |
280 |
*/ |
24acfc34f block: interface ... |
281 |
static inline struct io_context *create_io_context(gfp_t gfp_mask, int node) |
f2dbd76a0 block, cfq: repla... |
282 283 |
{ WARN_ON_ONCE(irqs_disabled()); |
24acfc34f block: interface ... |
284 285 286 |
if (unlikely(!current->io_context)) create_task_io_context(current, gfp_mask, node); return current->io_context; |
f2dbd76a0 block, cfq: repla... |
287 288 289 290 291 |
} /* * Internal throttling interface */ |
bc9fcbf9c block: move blk_t... |
292 |
#ifdef CONFIG_BLK_DEV_THROTTLING |
c9a929dde block: fix reques... |
293 |
extern void blk_throtl_drain(struct request_queue *q); |
bc9fcbf9c block: move blk_t... |
294 295 |
extern int blk_throtl_init(struct request_queue *q); extern void blk_throtl_exit(struct request_queue *q); |
d61fcfa4b blk-throttle: cho... |
296 |
extern void blk_throtl_register_queue(struct request_queue *q); |
bc9fcbf9c block: move blk_t... |
297 |
#else /* CONFIG_BLK_DEV_THROTTLING */ |
c9a929dde block: fix reques... |
298 |
static inline void blk_throtl_drain(struct request_queue *q) { } |
bc9fcbf9c block: move blk_t... |
299 300 |
static inline int blk_throtl_init(struct request_queue *q) { return 0; } static inline void blk_throtl_exit(struct request_queue *q) { } |
d61fcfa4b blk-throttle: cho... |
301 |
static inline void blk_throtl_register_queue(struct request_queue *q) { } |
bc9fcbf9c block: move blk_t... |
302 |
#endif /* CONFIG_BLK_DEV_THROTTLING */ |
297e3d854 blk-throttle: mak... |
303 304 305 306 |
#ifdef CONFIG_BLK_DEV_THROTTLING_LOW extern ssize_t blk_throtl_sample_time_show(struct request_queue *q, char *page); extern ssize_t blk_throtl_sample_time_store(struct request_queue *q, const char *page, size_t count); |
9e234eeaf blk-throttle: add... |
307 |
extern void blk_throtl_bio_endio(struct bio *bio); |
b9147dd1b blk-throttle: add... |
308 |
extern void blk_throtl_stat_add(struct request *rq, u64 time); |
9e234eeaf blk-throttle: add... |
309 310 |
#else static inline void blk_throtl_bio_endio(struct bio *bio) { } |
b9147dd1b blk-throttle: add... |
311 |
static inline void blk_throtl_stat_add(struct request *rq, u64 time) { } |
297e3d854 blk-throttle: mak... |
312 |
#endif |
bc9fcbf9c block: move blk_t... |
313 |
|
3bce016a4 block: move bounc... |
314 315 316 317 318 319 320 321 322 323 324 325 |
#ifdef CONFIG_BOUNCE extern int init_emergency_isa_pool(void); extern void blk_queue_bounce(struct request_queue *q, struct bio **bio); #else static inline int init_emergency_isa_pool(void) { return 0; } static inline void blk_queue_bounce(struct request_queue *q, struct bio **bio) { } #endif /* CONFIG_BOUNCE */ |
d70675121 block: introduce ... |
326 327 328 329 330 |
#ifdef CONFIG_BLK_CGROUP_IOLATENCY extern int blk_iolatency_init(struct request_queue *q); #else static inline int blk_iolatency_init(struct request_queue *q) { return 0; } #endif |
a2d6b3a2d block: Improve zo... |
331 |
struct bio *blk_next_bio(struct bio *bio, unsigned int nr_pages, gfp_t gfp); |
bf5054569 block: Introduce ... |
332 333 334 335 336 |
#ifdef CONFIG_BLK_DEV_ZONED void blk_queue_free_zone_bitmaps(struct request_queue *q); #else static inline void blk_queue_free_zone_bitmaps(struct request_queue *q) {} #endif |
bc9fcbf9c block: move blk_t... |
337 |
#endif /* BLK_INTERNAL_H */ |