Blame view
block/blk.h
4.46 KB
8324aa91d block: split tag ... |
1 2 |
#ifndef BLK_INTERNAL_H #define BLK_INTERNAL_H |
86db1e297 block: continue l... |
3 4 5 6 7 |
/* Amount of time in which a process may batch requests */ #define BLK_BATCH_TIME (HZ/50UL) /* Number of requests a "batching" process may submit */ #define BLK_BATCH_REQ 32 |
8324aa91d block: split tag ... |
8 9 |
extern struct kmem_cache *blk_requestq_cachep; extern struct kobj_type blk_queue_ktype; |
86db1e297 block: continue l... |
10 11 12 |
void init_request_from_bio(struct request *req, struct bio *bio); void blk_rq_bio_prep(struct request_queue *q, struct request *rq, struct bio *bio); |
a411f4bbb block: Un-export ... |
13 14 |
int blk_rq_append_bio(struct request_queue *q, struct request *rq, struct bio *bio); |
9934c8c04 block: implement ... |
15 |
void blk_dequeue_request(struct request *rq); |
8324aa91d block: split tag ... |
16 |
void __blk_queue_free_tags(struct request_queue *q); |
86db1e297 block: continue l... |
17 18 |
void blk_unplug_work(struct work_struct *work); void blk_unplug_timeout(unsigned long data); |
242f9dcb8 block: unify requ... |
19 20 21 |
void blk_rq_timed_out_timer(unsigned long data); void blk_delete_timer(struct request *); void blk_add_timer(struct request *); |
f73e2d13a block: remove __g... |
22 |
void __generic_unplug_device(struct request_queue *); |
242f9dcb8 block: unify requ... |
23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
/* * Internal atomic flags for request handling */ enum rq_atomic_flags { REQ_ATOM_COMPLETE = 0, }; /* * EH timer and IO completion will both attempt to 'grab' the request, make * sure that only one of them suceeds */ static inline int blk_mark_rq_complete(struct request *rq) { return test_and_set_bit(REQ_ATOM_COMPLETE, &rq->atomic_flags); } static inline void blk_clear_rq_complete(struct request *rq) { clear_bit(REQ_ATOM_COMPLETE, &rq->atomic_flags); } |
86db1e297 block: continue l... |
44 |
|
158dbda00 block: reorganize... |
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
/* * Internal elevator interface */ #define ELV_ON_HASH(rq) (!hlist_unhashed(&(rq)->hash)) static inline struct request *__elv_next_request(struct request_queue *q) { struct request *rq; while (1) { while (!list_empty(&q->queue_head)) { rq = list_entry_rq(q->queue_head.next); if (blk_do_ordered(q, &rq)) return rq; } if (!q->elevator->ops->elevator_dispatch_fn(q, 0)) return NULL; } } static inline void elv_activate_rq(struct request_queue *q, struct request *rq) { struct elevator_queue *e = q->elevator; if (e->ops->elevator_activate_req_fn) e->ops->elevator_activate_req_fn(q, rq); } static inline void elv_deactivate_rq(struct request_queue *q, struct request *rq) { struct elevator_queue *e = q->elevator; if (e->ops->elevator_deactivate_req_fn) e->ops->elevator_deactivate_req_fn(q, rq); } |
581d4e28d block: add fault ... |
81 82 83 84 85 86 87 88 89 90 91 |
#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 |
86db1e297 block: continue l... |
92 |
struct io_context *current_io_context(gfp_t gfp_flags, int node); |
d6d481969 block: ll_rw_blk.... |
93 94 95 96 97 98 99 |
int ll_back_merge_fn(struct request_queue *q, struct request *req, struct bio *bio); int ll_front_merge_fn(struct request_queue *q, struct request *req, struct bio *bio); int attempt_back_merge(struct request_queue *q, struct request *rq); int attempt_front_merge(struct request_queue *q, struct request *rq); void blk_recalc_rq_segments(struct request *rq); |
d6d481969 block: ll_rw_blk.... |
100 |
|
8324aa91d block: split tag ... |
101 |
void blk_queue_congestion_threshold(struct request_queue *q); |
ff88972c8 proper prototype ... |
102 |
int blk_dev_init(void); |
f600abe2d block: fix bad sp... |
103 104 |
void elv_quiesce_start(struct request_queue *q); void elv_quiesce_end(struct request_queue *q); |
6c7e8cee6 block: elevator q... |
105 |
|
8324aa91d block: split tag ... |
106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 |
/* * Return the threshold (number of used requests) at which the queue is * considered to be congested. It include a little hysteresis to keep the * context switch rate down. */ static inline int queue_congestion_on_threshold(struct request_queue *q) { return q->nr_congestion_on; } /* * The threshold at which a queue is considered to be uncongested */ static inline int queue_congestion_off_threshold(struct request_queue *q) { return q->nr_congestion_off; } |
7ba1ba12e block: Block laye... |
123 124 125 126 127 128 129 |
#if defined(CONFIG_BLK_DEV_INTEGRITY) #define rq_for_each_integrity_segment(bvl, _rq, _iter) \ __rq_for_each_bio(_iter.bio, _rq) \ bip_for_each_vec(bvl, _iter.bio->bi_integrity, _iter.i) #endif /* BLK_DEV_INTEGRITY */ |
c7c22e4d5 block: add suppor... |
130 131 132 |
static inline int blk_cpu_to_group(int cpu) { #ifdef CONFIG_SCHED_MC |
be4d638c1 cpumask: Replace ... |
133 134 |
const struct cpumask *mask = cpu_coregroup_mask(cpu); return cpumask_first(mask); |
c7c22e4d5 block: add suppor... |
135 |
#elif defined(CONFIG_SCHED_SMT) |
c69fc56de cpumask: use topo... |
136 |
return cpumask_first(topology_thread_cpumask(cpu)); |
c7c22e4d5 block: add suppor... |
137 138 139 140 |
#else return cpu; #endif } |
c2553b584 block: make blk_d... |
141 142 143 144 145 |
/* * 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 |
3c4198e87 block: fix no dis... |
146 |
* c) it's a file system request or a discard request |
c2553b584 block: make blk_d... |
147 |
*/ |
26308eab6 block: fix incons... |
148 |
static inline int blk_do_io_stat(struct request *rq) |
fb8ec18c3 block: fix oops i... |
149 |
{ |
3c4198e87 block: fix no dis... |
150 151 |
return rq->rq_disk && blk_rq_io_stat(rq) && (blk_fs_request(rq) || blk_discard_rq(rq)); |
fb8ec18c3 block: fix oops i... |
152 |
} |
8324aa91d block: split tag ... |
153 |
#endif |