Home
last modified time | relevance | path

Searched refs:ioc (Results 1 – 6 of 6) sorted by relevance

/block/
Dblk-ioc.c25 void get_io_context(struct io_context *ioc) in get_io_context() argument
27 BUG_ON(atomic_long_read(&ioc->refcount) <= 0); in get_io_context()
28 atomic_long_inc(&ioc->refcount); in get_io_context()
56 struct io_context *ioc = icq->ioc; in ioc_destroy_icq() local
60 lockdep_assert_held(&ioc->lock); in ioc_destroy_icq()
63 radix_tree_delete(&ioc->icq_tree, icq->q->id); in ioc_destroy_icq()
72 if (rcu_dereference_raw(ioc->icq_hint) == icq) in ioc_destroy_icq()
73 rcu_assign_pointer(ioc->icq_hint, NULL); in ioc_destroy_icq()
91 struct io_context *ioc = container_of(work, struct io_context, in ioc_release_fn() local
101 spin_lock_irqsave_nested(&ioc->lock, flags, 1); in ioc_release_fn()
[all …]
Dblk-core.c765 put_io_context(rq->elv.icq->ioc); in blk_free_request()
775 static inline int ioc_batching(struct request_queue *q, struct io_context *ioc) in ioc_batching() argument
777 if (!ioc) in ioc_batching()
785 return ioc->nr_batch_requests == q->nr_batching || in ioc_batching()
786 (ioc->nr_batch_requests > 0 in ioc_batching()
787 && time_before(jiffies, ioc->last_waited + BLK_BATCH_TIME)); in ioc_batching()
796 static void ioc_set_batching(struct request_queue *q, struct io_context *ioc) in ioc_set_batching() argument
798 if (!ioc || ioc_batching(q, ioc)) in ioc_set_batching()
801 ioc->nr_batch_requests = q->nr_batching; in ioc_set_batching()
802 ioc->last_waited = jiffies; in ioc_set_batching()
[all …]
Dblk.h188 void get_io_context(struct io_context *ioc);
189 struct io_cq *ioc_lookup_icq(struct io_context *ioc, struct request_queue *q);
190 struct io_cq *ioc_create_icq(struct io_context *ioc, struct request_queue *q,
DMakefile6 blk-flush.o blk-settings.o blk-ioc.o blk-map.o \
Dblk-cgroup.c906 struct io_context *ioc; in blkcg_can_attach() local
912 ioc = task->io_context; in blkcg_can_attach()
913 if (ioc && atomic_read(&ioc->nr_tasks) > 1) in blkcg_can_attach()
Dcfq-iosched.c871 struct io_context *ioc) in cfq_cic_lookup() argument
873 if (ioc) in cfq_cic_lookup()
874 return icq_to_cic(ioc_lookup_icq(ioc, cfqd->queue)); in cfq_cic_lookup()
2485 put_io_context(cfqd->active_cic->icq.ioc); in __cfq_slice_expired()
2738 if (!cic || !atomic_read(&cic->icq.ioc->active_ref)) in cfq_arm_slice_timer()
3293 atomic_long_inc(&cic->icq.ioc->refcount); in cfq_dispatch_request()
3476 int ioprio = cic->icq.ioc->ioprio; in check_ioprio_changed()
3732 else if (!atomic_read(&cic->icq.ioc->active_ref) || in cfq_update_idle_window()