diff options
author | Tejun Heo <tj@kernel.org> | 2011-12-13 18:33:42 -0500 |
---|---|---|
committer | Jens Axboe <axboe@kernel.dk> | 2011-12-13 18:33:42 -0500 |
commit | 47fdd4ca96bf4b28ac4d05d7a6e382df31d3d758 (patch) | |
tree | bcb928575b66511345b00102a7e8cace84526e3e /block/blk-ioc.c | |
parent | a612fddf0d8090f2877305c9168b6c1a34fb5d90 (diff) |
block, cfq: move io_cq lookup to blk-ioc.c
Now that all io_cq related data structures are in block core layer,
io_cq lookup can be moved from cfq-iosched.c to blk-ioc.c.
Lookup logic from cfq_cic_lookup() is moved to ioc_lookup_icq() with
parameter return type changes (cfqd -> request_queue, cfq_io_cq ->
io_cq) and cfq_cic_lookup() becomes thin wrapper around
cfq_cic_lookup().
Signed-off-by: Tejun Heo <tj@kernel.org>
Signed-off-by: Jens Axboe <axboe@kernel.dk>
Diffstat (limited to 'block/blk-ioc.c')
-rw-r--r-- | block/blk-ioc.c | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/block/blk-ioc.c b/block/blk-ioc.c index dc5e69d335a0..87ecc98b8ade 100644 --- a/block/blk-ioc.c +++ b/block/blk-ioc.c | |||
@@ -266,6 +266,42 @@ struct io_context *get_task_io_context(struct task_struct *task, | |||
266 | } | 266 | } |
267 | EXPORT_SYMBOL(get_task_io_context); | 267 | EXPORT_SYMBOL(get_task_io_context); |
268 | 268 | ||
269 | /** | ||
270 | * ioc_lookup_icq - lookup io_cq from ioc | ||
271 | * @ioc: the associated io_context | ||
272 | * @q: the associated request_queue | ||
273 | * | ||
274 | * Look up io_cq associated with @ioc - @q pair from @ioc. Must be called | ||
275 | * with @q->queue_lock held. | ||
276 | */ | ||
277 | struct io_cq *ioc_lookup_icq(struct io_context *ioc, struct request_queue *q) | ||
278 | { | ||
279 | struct io_cq *icq; | ||
280 | |||
281 | lockdep_assert_held(q->queue_lock); | ||
282 | |||
283 | /* | ||
284 | * icq's are indexed from @ioc using radix tree and hint pointer, | ||
285 | * both of which are protected with RCU. All removals are done | ||
286 | * holding both q and ioc locks, and we're holding q lock - if we | ||
287 | * find a icq which points to us, it's guaranteed to be valid. | ||
288 | */ | ||
289 | rcu_read_lock(); | ||
290 | icq = rcu_dereference(ioc->icq_hint); | ||
291 | if (icq && icq->q == q) | ||
292 | goto out; | ||
293 | |||
294 | icq = radix_tree_lookup(&ioc->icq_tree, q->id); | ||
295 | if (icq && icq->q == q) | ||
296 | rcu_assign_pointer(ioc->icq_hint, icq); /* allowed to race */ | ||
297 | else | ||
298 | icq = NULL; | ||
299 | out: | ||
300 | rcu_read_unlock(); | ||
301 | return icq; | ||
302 | } | ||
303 | EXPORT_SYMBOL(ioc_lookup_icq); | ||
304 | |||
269 | void ioc_set_changed(struct io_context *ioc, int which) | 305 | void ioc_set_changed(struct io_context *ioc, int which) |
270 | { | 306 | { |
271 | struct io_cq *icq; | 307 | struct io_cq *icq; |