Lines Matching refs:write
102 struct data_update write;
109 struct moving_context *ctxt = io->write.ctxt;
114 bch2_data_update_exit(&io->write);
126 struct moving_io *io = container_of(op, struct moving_io, write.op);
127 struct moving_context *ctxt = io->write.ctxt;
129 if (io->write.op.error)
132 atomic_sub(io->write_sectors, &io->write.ctxt->write_sectors);
133 atomic_dec(&io->write.ctxt->write_ios);
146 struct bch_fs *c = io->write.op.c;
149 bch2_bkey_val_to_text(&buf, c, bkey_i_to_s_c(io->write.k.k));
154 closure_get(&io->write.ctxt->cl);
155 atomic_add(io->write_sectors, &io->write.ctxt->write_sectors);
156 atomic_inc(&io->write.ctxt->write_ios);
158 bch2_data_update_read_done(&io->write, io->rbio.pick.crc);
172 struct moving_context *ctxt = io->write.ctxt;
304 /* write path might have to decompress data: */
315 io->write.ctxt = ctxt;
319 bio_init(&io->write.op.wbio.bio, NULL, io->bi_inline_vecs, pages, 0);
320 bio_set_prio(&io->write.op.wbio.bio,
323 if (bch2_bio_alloc_pages(&io->write.op.wbio.bio, sectors << 9,
338 ret = bch2_data_update_init(trans, iter, ctxt, &io->write, ctxt->wp,
343 io->write.op.end_io = move_write_done;
382 bio_free_pages(&io->write.op.wbio.bio);
722 bch_err_msg(c, ret, "flushing btree write buffer");
1172 bch2_write_op_to_text(out, &io->write.op);