Searched refs:rq_wait (Results 1 – 6 of 6) sorted by relevance
/Linux-v6.1/block/ |
D | blk-rq-qos.h | 22 struct rq_wait { struct 82 static inline void rq_wait_init(struct rq_wait *rq_wait) in rq_wait_init() argument 84 atomic_set(&rq_wait->inflight, 0); in rq_wait_init() 85 init_waitqueue_head(&rq_wait->wait); in rq_wait_init() 148 typedef bool (acquire_inflight_cb_t)(struct rq_wait *rqw, void *private_data); 149 typedef void (cleanup_cb_t)(struct rq_wait *rqw, void *private_data); 151 void rq_qos_wait(struct rq_wait *rqw, void *private_data, 154 bool rq_wait_inc_below(struct rq_wait *rq_wait, unsigned int limit);
|
D | blk-wbt.c | 105 static inline struct rq_wait *get_rq_wait(struct rq_wb *rwb, in get_rq_wait() 109 return &rwb->rq_wait[WBT_RWQ_KSWAPD]; in get_rq_wait() 111 return &rwb->rq_wait[WBT_RWQ_DISCARD]; in get_rq_wait() 113 return &rwb->rq_wait[WBT_RWQ_BG]; in get_rq_wait() 121 struct rq_wait *rqw = &rwb->rq_wait[i]; in rwb_wake_all() 128 static void wbt_rqw_done(struct rq_wb *rwb, struct rq_wait *rqw, in wbt_rqw_done() 173 struct rq_wait *rqw; in __wbt_done() 496 static bool wbt_inflight_cb(struct rq_wait *rqw, void *private_data) in wbt_inflight_cb() 502 static void wbt_cleanup_cb(struct rq_wait *rqw, void *private_data) in wbt_cleanup_cb() 515 struct rq_wait *rqw = get_rq_wait(rwb, wb_acct); in __wbt_wait() [all …]
|
D | blk-wbt.h | 69 struct rq_wait rq_wait[WBT_NUM_RWQ]; member 83 ret += atomic_read(&rwb->rq_wait[i].inflight); in wbt_inflight()
|
D | blk-rq-qos.c | 21 bool rq_wait_inc_below(struct rq_wait *rq_wait, unsigned int limit) in rq_wait_inc_below() argument 23 return atomic_inc_below(&rq_wait->inflight, limit); in rq_wait_inc_below() 200 struct rq_wait *rqw; 243 void rq_qos_wait(struct rq_wait *rqw, void *private_data, in rq_qos_wait()
|
D | blk-iolatency.c | 145 struct rq_wait rq_wait; member 274 static void iolat_cleanup_cb(struct rq_wait *rqw, void *private_data) in iolat_cleanup_cb() 280 static bool iolat_acquire_inflight(struct rq_wait *rqw, void *private_data) in iolat_acquire_inflight() 291 struct rq_wait *rqw = &iolat->rq_wait; in __blkcg_iolatency_throttle() 388 wake_up_all(&iolat->rq_wait.wait); in scale_change() 457 wake_up_all(&iolat->rq_wait.wait); in check_scale_change() 595 struct rq_wait *rqw; in blkcg_iolatency_done_bio() 620 rqw = &iolat->rq_wait; in blkcg_iolatency_done_bio() 995 rq_wait_init(&iolat->rq_wait); in iolatency_pd_init()
|
/Linux-v6.1/fs/ |
D | aio.c | 133 struct ctx_rq_wait *rq_wait; member 627 if (ctx->rq_wait && atomic_dec_and_test(&ctx->rq_wait->count)) in free_ioctx_reqs() 628 complete(&ctx->rq_wait->comp); in free_ioctx_reqs() 873 ctx->rq_wait = wait; in kill_ioctx()
|