Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 373358
b: refs/heads/master
c: 95e072e
h: refs/heads/master
v: v3
  • Loading branch information
Alex Elder authored and Sage Weil committed May 2, 2013
1 parent c7add69 commit e143213
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 13 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 9a5e6d09ddd0cd68ce64c3aa54095e4a0e85b089
refs/heads/master: 95e072eb38f99c724739d91a1f12bb8bfe1619b5
1 change: 0 additions & 1 deletion trunk/include/linux/ceph/osd_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,6 @@ struct ceph_osd_request {

struct ceph_osd_data r_data_in;
struct ceph_osd_data r_data_out;
struct ceph_pagelist r_trail; /* trailing part of data out */
};

struct ceph_osd_event {
Expand Down
23 changes: 12 additions & 11 deletions trunk/net/ceph/osd_client.c
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,6 @@ void ceph_osdc_release_request(struct kref *kref)
}

ceph_put_snap_context(req->r_snapc);
ceph_pagelist_release(&req->r_trail);
if (req->r_mempool)
mempool_free(req, req->r_osdc->req_mempool);
else
Expand Down Expand Up @@ -202,7 +201,6 @@ struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,

req->r_data_in.type = CEPH_OSD_DATA_TYPE_NONE;
req->r_data_out.type = CEPH_OSD_DATA_TYPE_NONE;
ceph_pagelist_init(&req->r_trail);

/* create request message; allow space for oid */
if (use_mempool)
Expand All @@ -227,7 +225,7 @@ static u64 osd_req_encode_op(struct ceph_osd_request *req,
struct ceph_osd_req_op *src)
{
u64 out_data_len = 0;
u64 tmp;
struct ceph_pagelist *pagelist;

dst->op = cpu_to_le16(src->op);

Expand All @@ -246,18 +244,23 @@ static u64 osd_req_encode_op(struct ceph_osd_request *req,
cpu_to_le32(src->extent.truncate_seq);
break;
case CEPH_OSD_OP_CALL:
pagelist = kmalloc(sizeof (*pagelist), GFP_NOFS);
BUG_ON(!pagelist);
ceph_pagelist_init(pagelist);

dst->cls.class_len = src->cls.class_len;
dst->cls.method_len = src->cls.method_len;
dst->cls.indata_len = cpu_to_le32(src->cls.indata_len);

tmp = req->r_trail.length;
ceph_pagelist_append(&req->r_trail, src->cls.class_name,
ceph_pagelist_append(pagelist, src->cls.class_name,
src->cls.class_len);
ceph_pagelist_append(&req->r_trail, src->cls.method_name,
ceph_pagelist_append(pagelist, src->cls.method_name,
src->cls.method_len);
ceph_pagelist_append(&req->r_trail, src->cls.indata,
ceph_pagelist_append(pagelist, src->cls.indata,
src->cls.indata_len);
out_data_len = req->r_trail.length - tmp;

req->r_data_out.type = CEPH_OSD_DATA_TYPE_PAGELIST;
req->r_data_out.pagelist = pagelist;
out_data_len = pagelist->length;
break;
case CEPH_OSD_OP_STARTSYNC:
break;
Expand Down Expand Up @@ -1782,8 +1785,6 @@ int ceph_osdc_start_request(struct ceph_osd_client *osdc,

ceph_osdc_msg_data_set(req->r_reply, &req->r_data_in);
ceph_osdc_msg_data_set(req->r_request, &req->r_data_out);
if (req->r_trail.length)
ceph_msg_data_set_trail(req->r_request, &req->r_trail);

register_request(osdc, req);

Expand Down

0 comments on commit e143213

Please sign in to comment.