|
@@ -1162,126 +1162,6 @@ static void rbd_osd_req_op_destroy(struct ceph_osd_req_op *op)
|
|
|
kfree(op);
|
|
|
}
|
|
|
|
|
|
-/*
|
|
|
- * Send ceph osd request
|
|
|
- */
|
|
|
-static int rbd_do_request(struct request *rq,
|
|
|
- struct rbd_device *rbd_dev,
|
|
|
- struct ceph_snap_context *snapc,
|
|
|
- u64 snapid,
|
|
|
- const char *object_name, u64 ofs, u64 len,
|
|
|
- struct bio *bio,
|
|
|
- struct page **pages,
|
|
|
- int num_pages,
|
|
|
- int flags,
|
|
|
- struct ceph_osd_req_op *op,
|
|
|
- void (*rbd_cb)(struct ceph_osd_request *,
|
|
|
- struct ceph_msg *),
|
|
|
- u64 *ver)
|
|
|
-{
|
|
|
- struct ceph_osd_client *osdc;
|
|
|
- struct ceph_osd_request *osd_req;
|
|
|
- struct timespec mtime = CURRENT_TIME;
|
|
|
- int ret;
|
|
|
-
|
|
|
- dout("rbd_do_request object_name=%s ofs=%llu len=%llu\n",
|
|
|
- object_name, (unsigned long long) ofs,
|
|
|
- (unsigned long long) len);
|
|
|
-
|
|
|
- osdc = &rbd_dev->rbd_client->client->osdc;
|
|
|
- osd_req = ceph_osdc_alloc_request(osdc, snapc, 1, false, GFP_NOIO);
|
|
|
- if (!osd_req)
|
|
|
- return -ENOMEM;
|
|
|
-
|
|
|
- osd_req->r_flags = flags;
|
|
|
- osd_req->r_pages = pages;
|
|
|
- if (bio) {
|
|
|
- osd_req->r_bio = bio;
|
|
|
- bio_get(osd_req->r_bio);
|
|
|
- }
|
|
|
-
|
|
|
- osd_req->r_callback = rbd_cb;
|
|
|
- osd_req->r_priv = NULL;
|
|
|
-
|
|
|
- strncpy(osd_req->r_oid, object_name, sizeof(osd_req->r_oid));
|
|
|
- osd_req->r_oid_len = strlen(osd_req->r_oid);
|
|
|
-
|
|
|
- osd_req->r_file_layout = rbd_dev->layout; /* struct */
|
|
|
- osd_req->r_num_pages = calc_pages_for(ofs, len);
|
|
|
- osd_req->r_page_alignment = ofs & ~PAGE_MASK;
|
|
|
-
|
|
|
- ceph_osdc_build_request(osd_req, ofs, len, 1, op,
|
|
|
- snapc, snapid, &mtime);
|
|
|
-
|
|
|
- if (op->op == CEPH_OSD_OP_WATCH && op->watch.flag) {
|
|
|
- ceph_osdc_set_request_linger(osdc, osd_req);
|
|
|
- rbd_dev->watch_request = osd_req;
|
|
|
- }
|
|
|
-
|
|
|
- ret = ceph_osdc_start_request(osdc, osd_req, false);
|
|
|
- if (ret < 0)
|
|
|
- goto done_err;
|
|
|
-
|
|
|
- if (!rbd_cb) {
|
|
|
- u64 version;
|
|
|
-
|
|
|
- ret = ceph_osdc_wait_request(osdc, osd_req);
|
|
|
- version = le64_to_cpu(osd_req->r_reassert_version.version);
|
|
|
- if (ver)
|
|
|
- *ver = version;
|
|
|
- dout("reassert_ver=%llu\n", (unsigned long long) version);
|
|
|
- ceph_osdc_put_request(osd_req);
|
|
|
- }
|
|
|
- return ret;
|
|
|
-
|
|
|
-done_err:
|
|
|
- if (bio)
|
|
|
- bio_chain_put(osd_req->r_bio);
|
|
|
- ceph_osdc_put_request(osd_req);
|
|
|
-
|
|
|
- return ret;
|
|
|
-}
|
|
|
-
|
|
|
-/*
|
|
|
- * Do a synchronous ceph osd operation
|
|
|
- */
|
|
|
-static int rbd_req_sync_op(struct rbd_device *rbd_dev,
|
|
|
- int flags,
|
|
|
- struct ceph_osd_req_op *op,
|
|
|
- const char *object_name,
|
|
|
- u64 ofs, u64 inbound_size,
|
|
|
- char *inbound,
|
|
|
- u64 *ver)
|
|
|
-{
|
|
|
- int ret;
|
|
|
- struct page **pages;
|
|
|
- int num_pages;
|
|
|
-
|
|
|
- rbd_assert(op != NULL);
|
|
|
-
|
|
|
- num_pages = calc_pages_for(ofs, inbound_size);
|
|
|
- pages = ceph_alloc_page_vector(num_pages, GFP_KERNEL);
|
|
|
- if (IS_ERR(pages))
|
|
|
- return PTR_ERR(pages);
|
|
|
-
|
|
|
- ret = rbd_do_request(NULL, rbd_dev, NULL, CEPH_NOSNAP,
|
|
|
- object_name, ofs, inbound_size, NULL,
|
|
|
- pages, num_pages,
|
|
|
- flags,
|
|
|
- op,
|
|
|
- NULL,
|
|
|
- ver);
|
|
|
- if (ret < 0)
|
|
|
- goto done;
|
|
|
-
|
|
|
- if ((flags & CEPH_OSD_FLAG_READ) && inbound)
|
|
|
- ret = ceph_copy_from_page_vector(pages, inbound, ofs, ret);
|
|
|
-
|
|
|
-done:
|
|
|
- ceph_release_page_vector(pages, num_pages);
|
|
|
- return ret;
|
|
|
-}
|
|
|
-
|
|
|
static int rbd_obj_request_submit(struct ceph_osd_client *osdc,
|
|
|
struct rbd_obj_request *obj_request)
|
|
|
{
|
|
@@ -1317,45 +1197,6 @@ static void rbd_obj_request_complete(struct rbd_obj_request *obj_request)
|
|
|
complete_all(&obj_request->completion);
|
|
|
}
|
|
|
|
|
|
-/*
|
|
|
- * Synchronous osd object method call
|
|
|
- */
|
|
|
-static int rbd_req_sync_exec(struct rbd_device *rbd_dev,
|
|
|
- const char *object_name,
|
|
|
- const char *class_name,
|
|
|
- const char *method_name,
|
|
|
- const char *outbound,
|
|
|
- size_t outbound_size,
|
|
|
- char *inbound,
|
|
|
- size_t inbound_size,
|
|
|
- u64 *ver)
|
|
|
-{
|
|
|
- struct ceph_osd_req_op *op;
|
|
|
- int ret;
|
|
|
-
|
|
|
- /*
|
|
|
- * Any input parameters required by the method we're calling
|
|
|
- * will be sent along with the class and method names as
|
|
|
- * part of the message payload. That data and its size are
|
|
|
- * supplied via the indata and indata_len fields (named from
|
|
|
- * the perspective of the server side) in the OSD request
|
|
|
- * operation.
|
|
|
- */
|
|
|
- op = rbd_osd_req_op_create(CEPH_OSD_OP_CALL, class_name,
|
|
|
- method_name, outbound, outbound_size);
|
|
|
- if (!op)
|
|
|
- return -ENOMEM;
|
|
|
-
|
|
|
- ret = rbd_req_sync_op(rbd_dev, CEPH_OSD_FLAG_READ, op,
|
|
|
- object_name, 0, inbound_size, inbound,
|
|
|
- ver);
|
|
|
-
|
|
|
- rbd_osd_req_op_destroy(op);
|
|
|
-
|
|
|
- dout("cls_exec returned %d\n", ret);
|
|
|
- return ret;
|
|
|
-}
|
|
|
-
|
|
|
static void rbd_osd_read_callback(struct rbd_obj_request *obj_request,
|
|
|
struct ceph_osd_op *op)
|
|
|
{
|
|
@@ -2831,7 +2672,6 @@ static int _rbd_dev_v2_snap_size(struct rbd_device *rbd_dev, u64 snap_id,
|
|
|
__le64 size;
|
|
|
} __attribute__ ((packed)) size_buf = { 0 };
|
|
|
|
|
|
- (void) rbd_req_sync_exec; /* Avoid a warning */
|
|
|
ret = rbd_obj_method_sync(rbd_dev, rbd_dev->header_name,
|
|
|
"rbd", "get_size",
|
|
|
(char *) &snapid, sizeof (snapid),
|