Lines Matching refs:pblk
21 void pblk_write_to_cache(struct pblk *pblk, struct bio *bio, in pblk_write_to_cache() argument
38 ret = pblk_rb_may_write_user(&pblk->rwb, bio, nr_entries, &bpos); in pblk_write_to_cache()
44 pblk_pipeline_stop(pblk); in pblk_write_to_cache()
53 pblk_write_kick(pblk); in pblk_write_to_cache()
64 pos = pblk_rb_wrap_pos(&pblk->rwb, bpos + i); in pblk_write_to_cache()
65 pblk_rb_write_entry_user(&pblk->rwb, data, w_ctx, pos); in pblk_write_to_cache()
70 atomic64_add(nr_entries, &pblk->user_wa); in pblk_write_to_cache()
73 atomic_long_add(nr_entries, &pblk->inflight_writes); in pblk_write_to_cache()
74 atomic_long_add(nr_entries, &pblk->req_writes); in pblk_write_to_cache()
77 pblk_rl_inserted(&pblk->rl, nr_entries); in pblk_write_to_cache()
81 pblk_write_should_kick(pblk); in pblk_write_to_cache()
91 int pblk_write_gc_to_cache(struct pblk *pblk, struct pblk_gc_rq *gc_rq) in pblk_write_gc_to_cache() argument
103 if (!pblk_rb_may_write_gc(&pblk->rwb, gc_rq->secs_to_gc, &bpos)) { in pblk_write_gc_to_cache()
117 pos = pblk_rb_wrap_pos(&pblk->rwb, bpos + valid_entries); in pblk_write_gc_to_cache()
118 pblk_rb_write_entry_gc(&pblk->rwb, data, w_ctx, gc_rq->line, in pblk_write_gc_to_cache()
128 atomic64_add(valid_entries, &pblk->gc_wa); in pblk_write_gc_to_cache()
131 atomic_long_add(valid_entries, &pblk->inflight_writes); in pblk_write_gc_to_cache()
132 atomic_long_add(valid_entries, &pblk->recov_gc_writes); in pblk_write_gc_to_cache()
135 pblk_write_should_kick(pblk); in pblk_write_gc_to_cache()