jenna
/
kernel_samsung_sm7125
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

libceph: pass offset and length out of calc_layout()

Browse Source 
The purpose of calc_layout() is to determine, given a file offset
and length and a layout describing the placement of file data across
objects, where in "object space" that data resides.

Specifically, it determines which object should hold the first part
of the specified range of file data, and the offset and length of
data within that object.  The length will not exceed the bounds
of the object, and the caller is informed of that maximum length.

Add two parameters to calc_layout() to allow the object-relative
offset and length to be passed back to the caller.

This is the first steps toward having ceph_osdc_new_request() build
its osd op structure using osd_req_op_extent_init().

Signed-off-by: Alex Elder <elder@inktank.com>
Reviewed-by: Josh Durgin <josh.durgin@inktank.com>
tirimbino
Alex Elder 12 years ago committed by Sage Weil
parent 33803f3300
commit 75d1c941e5
1 changed files with 17 additions and 15 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 32
      net/ceph/osd_client.c

32
net/ceph/osd_client.c
Unescape View File

@ -64,32 +64,31 @@ static int op_has_extent(int op)
* fill osd op in request message. * fill osd op in request message.
*/ */
static int calc_layout(struct ceph_file_layout *layout, u64 off, u64 *plen, static int calc_layout(struct ceph_file_layout *layout, u64 off, u64 *plen,
struct ceph_osd_req_op *op, u64 *bno) struct ceph_osd_req_op *op, u64 *objnum,
u64 *objoff, u64 *objlen)
{ {
u64 orig_len = *plen; u64 orig_len = *plen;
u64 objoff = 0;
u64 objlen = 0;
int r; int r;
/* object extent? */ /* object extent? */
r = ceph_calc_file_object_mapping(layout, off, orig_len, bno, r = ceph_calc_file_object_mapping(layout, off, orig_len, objnum,
&objoff, &objlen); objoff, objlen);
if (r < 0) if (r < 0)
return r; return r;
if (objlen < orig_len) { if (*objlen < orig_len) {
*plen = objlen; *plen = *objlen;
dout(" skipping last %llu, final file extent %llu~%llu\n", dout(" skipping last %llu, final file extent %llu~%llu\n",
orig_len - *plen, off, *plen); orig_len - *plen, off, *plen);
} }
if (op_has_extent(op->op)) { if (op_has_extent(op->op)) {
u32 osize = le32_to_cpu(layout->fl_object_size); u32 osize = le32_to_cpu(layout->fl_object_size);
op->extent.offset = objoff; op->extent.offset = *objoff;
op->extent.length = objlen; op->extent.length = *objlen;
if (op->extent.truncate_size <= off - objoff) { if (op->extent.truncate_size <= off - *objoff) {
op->extent.truncate_size = 0; op->extent.truncate_size = 0;
} else { } else {
op->extent.truncate_size -= off - objoff; op->extent.truncate_size -= off - *objoff;
if (op->extent.truncate_size > osize) if (op->extent.truncate_size > osize)
op->extent.truncate_size = osize; op->extent.truncate_size = osize;
} }
@ -97,7 +96,7 @@ static int calc_layout(struct ceph_file_layout *layout, u64 off, u64 *plen,
if (op->op == CEPH_OSD_OP_WRITE) if (op->op == CEPH_OSD_OP_WRITE)
op->payload_len = *plen; op->payload_len = *plen;
dout("calc_layout bno=%llx %llu~%llu\n", *bno, objoff, objlen); dout("calc_layout objnum=%llx %llu~%llu\n", *objnum, *objoff, *objlen);
return 0; return 0;
} }
@ -572,7 +571,9 @@ struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc,
struct ceph_osd_req_op ops[2]; struct ceph_osd_req_op ops[2];
struct ceph_osd_request *req; struct ceph_osd_request *req;
unsigned int num_op = 1; unsigned int num_op = 1;
u64 bno = 0; u64 objnum = 0;
u64 objoff = 0;
u64 objlen = 0;
int r; int r;
memset(&ops, 0, sizeof ops); memset(&ops, 0, sizeof ops);
@ -593,14 +594,15 @@ struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc,
req->r_flags = flags; req->r_flags = flags;
/* calculate max write size */ /* calculate max write size */
r = calc_layout(layout, off, plen, ops, &bno); r = calc_layout(layout, off, plen, ops, &objnum, &objoff, &objlen);
if (r < 0) { if (r < 0) {
ceph_osdc_put_request(req); ceph_osdc_put_request(req);
return ERR_PTR(r); return ERR_PTR(r);
} }
req->r_file_layout = *layout; /* keep a copy */ req->r_file_layout = *layout; /* keep a copy */
snprintf(req->r_oid, sizeof(req->r_oid), "%llx.%08llx", vino.ino, bno); snprintf(req->r_oid, sizeof(req->r_oid), "%llx.%08llx",
vino.ino, objnum);
req->r_oid_len = strlen(req->r_oid); req->r_oid_len = strlen(req->r_oid);
ceph_osdc_build_request(req, off, num_op, ops, ceph_osdc_build_request(req, off, num_op, ops,

Write Preview
Loading…
Cancel
Save