Skip to content

Commit

Permalink
rbd: pass num_op with ops array
Browse files Browse the repository at this point in the history
Add a num_op parameter to rbd_do_request() and rbd_req_sync_op() to
indicate the number of entries in the array.  The callers of these
functions always know how many entries are in the array, so just
pass that information down.

This is in anticipation of eliminating the extra zero-filled entry
in these ops arrays.

Signed-off-by: Alex Elder <elder@inktank.com>
Reviewed-by: Josh Durgin <josh.durgin@inktank.com>
  • Loading branch information
Alex Elder committed Jan 17, 2013
1 parent 54a5400 commit d07c095
Showing 1 changed file with 9 additions and 7 deletions.
16 changes: 9 additions & 7 deletions drivers/block/rbd.c
Original file line number Diff line number Diff line change
Expand Up @@ -1119,6 +1119,7 @@ static int rbd_do_request(struct request *rq,
struct page **pages,
int num_pages,
int flags,
unsigned int num_op,
struct ceph_osd_req_op *ops,
struct rbd_req_coll *coll,
int coll_index,
Expand Down Expand Up @@ -1259,6 +1260,7 @@ static void rbd_simple_req_cb(struct ceph_osd_request *osd_req,
*/
static int rbd_req_sync_op(struct rbd_device *rbd_dev,
int flags,
unsigned int num_op,
struct ceph_osd_req_op *ops,
const char *object_name,
u64 ofs, u64 inbound_size,
Expand All @@ -1281,7 +1283,7 @@ static int rbd_req_sync_op(struct rbd_device *rbd_dev,
object_name, ofs, inbound_size, NULL,
pages, num_pages,
flags,
ops,
num_op, ops,
NULL, 0,
NULL,
linger_req, ver);
Expand Down Expand Up @@ -1351,7 +1353,7 @@ static int rbd_do_op(struct request *rq,
bio,
NULL, 0,
flags,
ops,
1, ops,
coll, coll_index,
rbd_req_cb, 0, NULL);
if (ret < 0)
Expand Down Expand Up @@ -1380,7 +1382,7 @@ static int rbd_req_sync_read(struct rbd_device *rbd_dev,
return -ENOMEM;

ret = rbd_req_sync_op(rbd_dev, CEPH_OSD_FLAG_READ,
ops, object_name, ofs, len, buf, NULL, ver);
1, ops, object_name, ofs, len, buf, NULL, ver);
rbd_destroy_ops(ops);

return ret;
Expand Down Expand Up @@ -1408,7 +1410,7 @@ static int rbd_req_sync_notify_ack(struct rbd_device *rbd_dev,
rbd_dev->header_name, 0, 0, NULL,
NULL, 0,
CEPH_OSD_FLAG_READ,
ops,
1, ops,
NULL, 0,
rbd_simple_req_cb, 0, NULL);

Expand Down Expand Up @@ -1460,7 +1462,7 @@ static int rbd_req_sync_watch(struct rbd_device *rbd_dev)

ret = rbd_req_sync_op(rbd_dev,
CEPH_OSD_FLAG_WRITE | CEPH_OSD_FLAG_ONDISK,
ops,
1, ops,
rbd_dev->header_name,
0, 0, NULL,
&rbd_dev->watch_request, NULL);
Expand Down Expand Up @@ -1497,7 +1499,7 @@ static int rbd_req_sync_unwatch(struct rbd_device *rbd_dev)

ret = rbd_req_sync_op(rbd_dev,
CEPH_OSD_FLAG_WRITE | CEPH_OSD_FLAG_ONDISK,
ops,
1, ops,
rbd_dev->header_name,
0, 0, NULL, NULL, NULL);

Expand Down Expand Up @@ -1548,7 +1550,7 @@ static int rbd_req_sync_exec(struct rbd_device *rbd_dev,
ops[0].cls.indata = outbound;
ops[0].cls.indata_len = outbound_size;

ret = rbd_req_sync_op(rbd_dev, CEPH_OSD_FLAG_READ, ops,
ret = rbd_req_sync_op(rbd_dev, CEPH_OSD_FLAG_READ, 1, ops,
object_name, 0, inbound_size, inbound,
NULL, ver);

Expand Down

0 comments on commit d07c095

Please sign in to comment.