提交 7d250b94 编写于 作者: A Alex Elder 提交者: Sage Weil

rbd: kill rbd_req_coll and rbd_request

The two remaining callers of rbd_do_request() always pass a null
collection pointer, so the "coll" and "coll_index" parameters are
not needed.  There is no other use of that data structure, so it
can be eliminated.

Deleting them means there is no need to allocate a rbd_request
structure for the callback function.  And since that's the only use
of *that* structure, it too can be eliminated.
Signed-off-by: NAlex Elder <elder@inktank.com>
Reviewed-by: NJosh Durgin <josh.durgin@inktank.com>
上级 2250a71b
...@@ -162,25 +162,6 @@ struct rbd_client { ...@@ -162,25 +162,6 @@ struct rbd_client {
struct list_head node; struct list_head node;
}; };
/*
* a request completion status
*/
struct rbd_req_status {
int done;
s32 rc;
u64 bytes;
};
/*
* a collection of requests
*/
struct rbd_req_coll {
int total;
int num_done;
struct kref kref;
struct rbd_req_status status[0];
};
struct rbd_img_request; struct rbd_img_request;
typedef void (*rbd_img_callback_t)(struct rbd_img_request *); typedef void (*rbd_img_callback_t)(struct rbd_img_request *);
...@@ -242,18 +223,6 @@ struct rbd_img_request { ...@@ -242,18 +223,6 @@ struct rbd_img_request {
#define for_each_obj_request_safe(ireq, oreq, n) \ #define for_each_obj_request_safe(ireq, oreq, n) \
list_for_each_entry_safe_reverse(oreq, n, &ireq->obj_requests, links) list_for_each_entry_safe_reverse(oreq, n, &ireq->obj_requests, links)
/*
* a single io request
*/
struct rbd_request {
struct request *rq; /* blk layer request */
struct bio *bio; /* cloned bio */
struct page **pages; /* list of used pages */
u64 len;
int coll_index;
struct rbd_req_coll *coll;
};
struct rbd_snap { struct rbd_snap {
struct device dev; struct device dev;
const char *name; const char *name;
...@@ -1195,21 +1164,18 @@ static int rbd_do_request(struct request *rq, ...@@ -1195,21 +1164,18 @@ static int rbd_do_request(struct request *rq,
int num_pages, int num_pages,
int flags, int flags,
struct ceph_osd_req_op *op, struct ceph_osd_req_op *op,
struct rbd_req_coll *coll,
int coll_index,
void (*rbd_cb)(struct ceph_osd_request *, void (*rbd_cb)(struct ceph_osd_request *,
struct ceph_msg *), struct ceph_msg *),
u64 *ver) u64 *ver)
{ {
struct ceph_osd_client *osdc; struct ceph_osd_client *osdc;
struct ceph_osd_request *osd_req; struct ceph_osd_request *osd_req;
struct rbd_request *rbd_req = NULL;
struct timespec mtime = CURRENT_TIME; struct timespec mtime = CURRENT_TIME;
int ret; int ret;
dout("rbd_do_request object_name=%s ofs=%llu len=%llu coll=%p[%d]\n", dout("rbd_do_request object_name=%s ofs=%llu len=%llu\n",
object_name, (unsigned long long) ofs, object_name, (unsigned long long) ofs,
(unsigned long long) len, coll, coll_index); (unsigned long long) len);
osdc = &rbd_dev->rbd_client->client->osdc; osdc = &rbd_dev->rbd_client->client->osdc;
osd_req = ceph_osdc_alloc_request(osdc, snapc, 1, false, GFP_NOIO); osd_req = ceph_osdc_alloc_request(osdc, snapc, 1, false, GFP_NOIO);
...@@ -1223,22 +1189,8 @@ static int rbd_do_request(struct request *rq, ...@@ -1223,22 +1189,8 @@ static int rbd_do_request(struct request *rq,
bio_get(osd_req->r_bio); bio_get(osd_req->r_bio);
} }
if (coll) {
ret = -ENOMEM;
rbd_req = kmalloc(sizeof(*rbd_req), GFP_NOIO);
if (!rbd_req)
goto done_osd_req;
rbd_req->rq = rq;
rbd_req->bio = bio;
rbd_req->pages = pages;
rbd_req->len = len;
rbd_req->coll = coll;
rbd_req->coll_index = coll_index;
}
osd_req->r_callback = rbd_cb; osd_req->r_callback = rbd_cb;
osd_req->r_priv = rbd_req; osd_req->r_priv = NULL;
strncpy(osd_req->r_oid, object_name, sizeof(osd_req->r_oid)); 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_oid_len = strlen(osd_req->r_oid);
...@@ -1274,8 +1226,6 @@ static int rbd_do_request(struct request *rq, ...@@ -1274,8 +1226,6 @@ static int rbd_do_request(struct request *rq,
done_err: done_err:
if (bio) if (bio)
bio_chain_put(osd_req->r_bio); bio_chain_put(osd_req->r_bio);
kfree(rbd_req);
done_osd_req:
ceph_osdc_put_request(osd_req); ceph_osdc_put_request(osd_req);
return ret; return ret;
...@@ -1314,7 +1264,6 @@ static int rbd_req_sync_op(struct rbd_device *rbd_dev, ...@@ -1314,7 +1264,6 @@ static int rbd_req_sync_op(struct rbd_device *rbd_dev,
pages, num_pages, pages, num_pages,
flags, flags,
op, op,
NULL, 0,
NULL, NULL,
ver); ver);
if (ret < 0) if (ret < 0)
...@@ -1390,7 +1339,6 @@ static int rbd_req_sync_notify_ack(struct rbd_device *rbd_dev, ...@@ -1390,7 +1339,6 @@ static int rbd_req_sync_notify_ack(struct rbd_device *rbd_dev,
NULL, 0, NULL, 0,
CEPH_OSD_FLAG_READ, CEPH_OSD_FLAG_READ,
op, op,
NULL, 0,
rbd_simple_req_cb, NULL); rbd_simple_req_cb, NULL);
rbd_osd_req_op_destroy(op); rbd_osd_req_op_destroy(op);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册