Lines Matching defs:osd_data
123 static void ceph_osd_data_init(struct ceph_osd_data *osd_data)
125 memset(osd_data, 0, sizeof (*osd_data));
126 osd_data->type = CEPH_OSD_DATA_TYPE_NONE;
132 static void ceph_osd_data_pages_init(struct ceph_osd_data *osd_data,
136 osd_data->type = CEPH_OSD_DATA_TYPE_PAGES;
137 osd_data->pages = pages;
138 osd_data->length = length;
139 osd_data->alignment = alignment;
140 osd_data->pages_from_pool = pages_from_pool;
141 osd_data->own_pages = own_pages;
147 static void ceph_osd_data_pagelist_init(struct ceph_osd_data *osd_data,
150 osd_data->type = CEPH_OSD_DATA_TYPE_PAGELIST;
151 osd_data->pagelist = pagelist;
155 static void ceph_osd_data_bio_init(struct ceph_osd_data *osd_data,
159 osd_data->type = CEPH_OSD_DATA_TYPE_BIO;
160 osd_data->bio_pos = *bio_pos;
161 osd_data->bio_length = bio_length;
165 static void ceph_osd_data_bvecs_init(struct ceph_osd_data *osd_data,
169 osd_data->type = CEPH_OSD_DATA_TYPE_BVECS;
170 osd_data->bvec_pos = *bvec_pos;
171 osd_data->num_bvecs = num_bvecs;
186 return osd_req_op_data(osd_req, which, extent, osd_data);
195 struct ceph_osd_data *osd_data;
197 osd_data = osd_req_op_raw_data_in(osd_req, which);
198 ceph_osd_data_pages_init(osd_data, pages, length, alignment,
208 struct ceph_osd_data *osd_data;
210 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
211 ceph_osd_data_pages_init(osd_data, pages, length, alignment,
219 struct ceph_osd_data *osd_data;
221 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
222 ceph_osd_data_pagelist_init(osd_data, pagelist);
232 struct ceph_osd_data *osd_data;
234 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
235 ceph_osd_data_bio_init(osd_data, bio_pos, bio_length);
245 struct ceph_osd_data *osd_data;
251 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
252 ceph_osd_data_bvecs_init(osd_data, &it, num_bvecs);
260 struct ceph_osd_data *osd_data;
262 osd_data = osd_req_op_data(osd_req, which, extent, osd_data);
263 ceph_osd_data_bvecs_init(osd_data, bvec_pos, 0);
271 struct ceph_osd_data *osd_data;
273 osd_data = osd_req_op_data(osd_req, which, cls, request_info);
274 ceph_osd_data_pagelist_init(osd_data, pagelist);
281 struct ceph_osd_data *osd_data;
283 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
284 ceph_osd_data_pagelist_init(osd_data, pagelist);
294 struct ceph_osd_data *osd_data;
296 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
297 ceph_osd_data_pages_init(osd_data, pages, length, alignment,
309 struct ceph_osd_data *osd_data;
315 osd_data = osd_req_op_data(osd_req, which, cls, request_data);
316 ceph_osd_data_bvecs_init(osd_data, &it, num_bvecs);
326 struct ceph_osd_data *osd_data;
328 osd_data = osd_req_op_data(osd_req, which, cls, response_data);
329 ceph_osd_data_pages_init(osd_data, pages, length, alignment,
334 static u64 ceph_osd_data_length(struct ceph_osd_data *osd_data)
336 switch (osd_data->type) {
340 return osd_data->length;
342 return (u64)osd_data->pagelist->length;
345 return (u64)osd_data->bio_length;
348 return osd_data->bvec_pos.iter.bi_size;
350 WARN(true, "unrecognized data type %d\n", (int)osd_data->type);
355 static void ceph_osd_data_release(struct ceph_osd_data *osd_data)
357 if (osd_data->type == CEPH_OSD_DATA_TYPE_PAGES && osd_data->own_pages) {
360 num_pages = calc_pages_for((u64)osd_data->alignment,
361 (u64)osd_data->length);
362 ceph_release_page_vector(osd_data->pages, num_pages);
363 } else if (osd_data->type == CEPH_OSD_DATA_TYPE_PAGELIST) {
364 ceph_pagelist_release(osd_data->pagelist);
366 ceph_osd_data_init(osd_data);
381 ceph_osd_data_release(&op->extent.osd_data);
390 ceph_osd_data_release(&op->xattr.osd_data);
406 ceph_osd_data_release(&op->copy_from.osd_data);
870 ceph_osd_data_pagelist_init(&op->xattr.osd_data, pagelist);
936 struct ceph_osd_data *osd_data)
938 u64 length = ceph_osd_data_length(osd_data);
940 if (osd_data->type == CEPH_OSD_DATA_TYPE_PAGES) {
943 ceph_msg_data_add_pages(msg, osd_data->pages,
944 length, osd_data->alignment, false);
945 } else if (osd_data->type == CEPH_OSD_DATA_TYPE_PAGELIST) {
947 ceph_msg_data_add_pagelist(msg, osd_data->pagelist);
949 } else if (osd_data->type == CEPH_OSD_DATA_TYPE_BIO) {
950 ceph_msg_data_add_bio(msg, &osd_data->bio_pos, length);
952 } else if (osd_data->type == CEPH_OSD_DATA_TYPE_BVECS) {
953 ceph_msg_data_add_bvecs(msg, &osd_data->bvec_pos);
955 BUG_ON(osd_data->type != CEPH_OSD_DATA_TYPE_NONE);
1995 &op->extent.osd_data);
2002 &op->xattr.osd_data);
2010 &op->copy_from.osd_data);
2020 &op->extent.osd_data);
2996 struct ceph_osd_data *osd_data =
2998 void *p = page_address(osd_data->pages[0]);
3001 osd_data->type != CEPH_OSD_DATA_TYPE_PAGES);
5287 ceph_osd_data_pages_init(&op->copy_from.osd_data, pages,