Searched refs:rqw (Results 1 – 4 of 4) sorted by relevance
| /linux-6.3-rc2/block/ |
| A D | blk-rq-qos.c | 200 struct rq_wait *rqw; member
217 if (!data->cb(data->rqw, data->private_data)) in rq_qos_wake_function()
243 void rq_qos_wait(struct rq_wait *rqw, void *private_data, in rq_qos_wait() argument
253 .rqw = rqw, in rq_qos_wait()
259 has_sleeper = wq_has_sleeper(&rqw->wait); in rq_qos_wait()
260 if (!has_sleeper && acquire_inflight_cb(rqw, private_data)) in rq_qos_wait()
263 has_sleeper = !prepare_to_wait_exclusive(&rqw->wait, &data.wq, in rq_qos_wait()
269 if (!has_sleeper && acquire_inflight_cb(rqw, private_data)) { in rq_qos_wait()
270 finish_wait(&rqw->wait, &data.wq); in rq_qos_wait()
279 cleanup_cb(rqw, private_data); in rq_qos_wait()
[all …]
|
| A D | blk-wbt.c | 189 struct rq_wait *rqw = &rwb->rq_wait[i]; in rwb_wake_all() local
191 if (wq_has_sleeper(&rqw->wait)) in rwb_wake_all()
192 wake_up_all(&rqw->wait); in rwb_wake_all()
201 inflight = atomic_dec_return(&rqw->inflight); in wbt_rqw_done()
230 if (wq_has_sleeper(&rqw->wait)) { in wbt_rqw_done()
234 wake_up_all(&rqw->wait); in wbt_rqw_done()
241 struct rq_wait *rqw; in __wbt_done() local
246 rqw = get_rq_wait(rwb, wb_acct); in __wbt_done()
247 wbt_rqw_done(rwb, rqw, wb_acct); in __wbt_done()
595 wbt_rqw_done(data->rwb, rqw, data->wb_acct); in wbt_cleanup_cb()
[all …]
|
| A D | blk-iolatency.c | 274 static void iolat_cleanup_cb(struct rq_wait *rqw, void *private_data) in iolat_cleanup_cb() argument
276 atomic_dec(&rqw->inflight); in iolat_cleanup_cb()
277 wake_up(&rqw->wait); in iolat_cleanup_cb()
283 return rq_wait_inc_below(rqw, iolat->max_depth); in iolat_acquire_inflight()
291 struct rq_wait *rqw = &iolat->rq_wait; in __blkcg_iolatency_throttle() local
305 atomic_inc(&rqw->inflight); in __blkcg_iolatency_throttle()
309 rq_qos_wait(rqw, iolat, iolat_acquire_inflight, iolat_cleanup_cb); in __blkcg_iolatency_throttle()
594 struct rq_wait *rqw; in blkcg_iolatency_done_bio() local
619 rqw = &iolat->rq_wait; in blkcg_iolatency_done_bio()
621 inflight = atomic_dec_return(&rqw->inflight); in blkcg_iolatency_done_bio()
[all …]
|
| A D | blk-rq-qos.h | 92 typedef bool (acquire_inflight_cb_t)(struct rq_wait *rqw, void *private_data);
93 typedef void (cleanup_cb_t)(struct rq_wait *rqw, void *private_data);
95 void rq_qos_wait(struct rq_wait *rqw, void *private_data,
|
Completed in 9 milliseconds