Lines Matching refs:osd_req
182 osd_req_op_raw_data_in(struct ceph_osd_request *osd_req, unsigned int which)
184 BUG_ON(which >= osd_req->r_num_ops);
186 return &osd_req->r_ops[which].raw_data_in;
190 osd_req_op_extent_osd_data(struct ceph_osd_request *osd_req,
193 return osd_req_op_data(osd_req, which, extent, osd_data);
197 void osd_req_op_raw_data_in_pages(struct ceph_osd_request *osd_req,
204 osd_data = osd_req_op_raw_data_in(osd_req, which);
210 void osd_req_op_extent_osd_data_pages(struct ceph_osd_request *osd_req,
217 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
223 void osd_req_op_extent_osd_data_pagelist(struct ceph_osd_request *osd_req,
228 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
234 void osd_req_op_extent_osd_data_bio(struct ceph_osd_request *osd_req,
241 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
247 void osd_req_op_extent_osd_data_bvecs(struct ceph_osd_request *osd_req,
258 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
263 void osd_req_op_extent_osd_data_bvec_pos(struct ceph_osd_request *osd_req,
269 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
276 * @osd_req: The request to set up
280 void osd_req_op_extent_osd_iter(struct ceph_osd_request *osd_req,
285 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
291 struct ceph_osd_request *osd_req,
296 osd_data = osd_req_op_data(osd_req, which, cls, request_info);
301 struct ceph_osd_request *osd_req,
306 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
308 osd_req->r_ops[which].cls.indata_len += pagelist->length;
309 osd_req->r_ops[which].indata_len += pagelist->length;
313 void osd_req_op_cls_request_data_pages(struct ceph_osd_request *osd_req,
319 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
322 osd_req->r_ops[which].cls.indata_len += length;
323 osd_req->r_ops[which].indata_len += length;
327 void osd_req_op_cls_request_data_bvecs(struct ceph_osd_request *osd_req,
338 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
340 osd_req->r_ops[which].cls.indata_len += bytes;
341 osd_req->r_ops[which].indata_len += bytes;
345 void osd_req_op_cls_response_data_pages(struct ceph_osd_request *osd_req,
351 osd_data = osd_req_op_data(osd_req, which, cls, response_data);
394 static void osd_req_op_data_release(struct ceph_osd_request *osd_req,
399 BUG_ON(which >= osd_req->r_num_ops);
400 op = &osd_req->r_ops[which];
741 osd_req_op_init(struct ceph_osd_request *osd_req, unsigned int which,
746 BUG_ON(which >= osd_req->r_num_ops);
749 op = &osd_req->r_ops[which];
758 void osd_req_op_extent_init(struct ceph_osd_request *osd_req,
763 struct ceph_osd_req_op *op = osd_req_op_init(osd_req, which,
782 void osd_req_op_extent_update(struct ceph_osd_request *osd_req,
788 BUG_ON(which >= osd_req->r_num_ops);
789 op = &osd_req->r_ops[which];
802 void osd_req_op_extent_dup_last(struct ceph_osd_request *osd_req,
807 BUG_ON(which + 1 >= osd_req->r_num_ops);
809 prev_op = &osd_req->r_ops[which];
810 op = osd_req_op_init(osd_req, which + 1, prev_op->op, prev_op->flags);
824 int osd_req_op_cls_init(struct ceph_osd_request *osd_req, unsigned int which,
833 op = osd_req_op_init(osd_req, which, CEPH_OSD_OP_CALL, 0);
857 osd_req_op_cls_request_info_pagelist(osd_req, which, pagelist);
867 int osd_req_op_xattr_init(struct ceph_osd_request *osd_req, unsigned int which,
871 struct ceph_osd_req_op *op = osd_req_op_init(osd_req, which,
941 void osd_req_op_alloc_hint_init(struct ceph_osd_request *osd_req,
949 op = osd_req_op_init(osd_req, which, CEPH_OSD_OP_SETALLOCHINT, 0);