Lines Matching refs:pblk
21 void pblk_write_to_cache(struct pblk *pblk, struct bio *bio, in pblk_write_to_cache() argument
24 struct request_queue *q = pblk->dev->q; in pblk_write_to_cache()
33 &pblk->disk->part0); in pblk_write_to_cache()
40 ret = pblk_rb_may_write_user(&pblk->rwb, bio, nr_entries, &bpos); in pblk_write_to_cache()
46 pblk_pipeline_stop(pblk); in pblk_write_to_cache()
55 pblk_write_kick(pblk); in pblk_write_to_cache()
66 pos = pblk_rb_wrap_pos(&pblk->rwb, bpos + i); in pblk_write_to_cache()
67 pblk_rb_write_entry_user(&pblk->rwb, data, w_ctx, pos); in pblk_write_to_cache()
72 atomic64_add(nr_entries, &pblk->user_wa); in pblk_write_to_cache()
75 atomic_long_add(nr_entries, &pblk->inflight_writes); in pblk_write_to_cache()
76 atomic_long_add(nr_entries, &pblk->req_writes); in pblk_write_to_cache()
79 pblk_rl_inserted(&pblk->rl, nr_entries); in pblk_write_to_cache()
82 generic_end_io_acct(q, REQ_OP_WRITE, &pblk->disk->part0, start_time); in pblk_write_to_cache()
83 pblk_write_should_kick(pblk); in pblk_write_to_cache()
93 int pblk_write_gc_to_cache(struct pblk *pblk, struct pblk_gc_rq *gc_rq) in pblk_write_gc_to_cache() argument
105 if (!pblk_rb_may_write_gc(&pblk->rwb, gc_rq->secs_to_gc, &bpos)) { in pblk_write_gc_to_cache()
119 pos = pblk_rb_wrap_pos(&pblk->rwb, bpos + valid_entries); in pblk_write_gc_to_cache()
120 pblk_rb_write_entry_gc(&pblk->rwb, data, w_ctx, gc_rq->line, in pblk_write_gc_to_cache()
130 atomic64_add(valid_entries, &pblk->gc_wa); in pblk_write_gc_to_cache()
133 atomic_long_add(valid_entries, &pblk->inflight_writes); in pblk_write_gc_to_cache()
134 atomic_long_add(valid_entries, &pblk->recov_gc_writes); in pblk_write_gc_to_cache()
137 pblk_write_should_kick(pblk); in pblk_write_gc_to_cache()