Lines Matching defs:c_ctx
23 struct pblk_c_ctx *c_ctx)
30 for (i = 0; i < c_ctx->nr_valid; i++) {
32 int pos = c_ctx->sentry + i;
52 if (c_ctx->nr_padded)
53 pblk_bio_free_pages(pblk, rqd->bio, c_ctx->nr_valid,
54 c_ctx->nr_padded);
60 ret = pblk_rb_sync_advance(&pblk->rwb, c_ctx->nr_valid);
70 struct pblk_c_ctx *c_ctx)
72 list_del(&c_ctx->list);
73 return pblk_end_w_bio(pblk, rqd, c_ctx);
77 struct pblk_c_ctx *c_ctx)
84 atomic_long_sub(c_ctx->nr_valid, &pblk->inflight_writes);
86 pblk_up_rq(pblk, c_ctx->lun_bitmap);
89 if (pos == c_ctx->sentry) {
90 pos = pblk_end_w_bio(pblk, rqd, c_ctx);
101 WARN_ON(nvm_rq_from_c_ctx(c_ctx) != rqd);
102 list_add_tail(&c_ctx->list, &pblk->compl_list);
186 static void pblk_queue_resubmit(struct pblk *pblk, struct pblk_c_ctx *c_ctx)
195 r_ctx->sentry = c_ctx->sentry;
196 r_ctx->nr_valid = c_ctx->nr_valid;
197 r_ctx->nr_padded = c_ctx->nr_padded;
204 atomic_long_add(c_ctx->nr_valid, &pblk->recov_writes);
214 struct pblk_c_ctx *c_ctx = nvm_rq_to_pdu(rqd);
220 pblk_queue_resubmit(pblk, c_ctx);
222 pblk_up_rq(pblk, c_ctx->lun_bitmap);
223 if (c_ctx->nr_padded)
224 pblk_bio_free_pages(pblk, rqd->bio, c_ctx->nr_valid,
225 c_ctx->nr_padded);
255 struct pblk_c_ctx *c_ctx = nvm_rq_to_pdu(rqd);
268 pblk_complete_write(pblk, rqd, c_ctx);
320 struct pblk_c_ctx *c_ctx = nvm_rq_to_pdu(rqd);
321 unsigned int valid = c_ctx->nr_valid;
322 unsigned int padded = c_ctx->nr_padded;
330 c_ctx->lun_bitmap = lun_bitmap;
339 ret = pblk_map_rq(pblk, rqd, c_ctx->sentry, lun_bitmap,
342 ret = pblk_map_erase_rq(pblk, rqd, c_ctx->sentry, lun_bitmap,
547 struct pblk_c_ctx *c_ctx = nvm_rq_to_pdu(rqd);
550 if (c_ctx->nr_padded)
551 pblk_bio_free_pages(pblk, bio, c_ctx->nr_valid,
552 c_ctx->nr_padded);