From mboxrd@z Thu Jan 1 00:00:00 1970 From: Alex Elder Subject: [PATCH 3/4] libceph: clean up ceph_osd_new_request() Date: Fri, 29 Mar 2013 16:32:27 -0500 Message-ID: <5156086B.7070002@inktank.com> References: <5156080E.9040603@inktank.com> Mime-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Return-path: Received: from mail-ie0-f178.google.com ([209.85.223.178]:53505 "EHLO mail-ie0-f178.google.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1756793Ab3C2Vc3 (ORCPT ); Fri, 29 Mar 2013 17:32:29 -0400 Received: by mail-ie0-f178.google.com with SMTP id bn7so929527ieb.37 for ; Fri, 29 Mar 2013 14:32:29 -0700 (PDT) In-Reply-To: <5156080E.9040603@inktank.com> Sender: ceph-devel-owner@vger.kernel.org List-ID: To: "ceph-devel@vger.kernel.org" All callers of ceph_osd_new_request() pass either CEPH_OSD_OP_READ or CEPH_OSD_OP_WRITE as the opcode value. The function assumes it by filling in the extent fields in the ops array it builds. So just assert that is the case, and don't bother calling op_has_extent() before filling in the first osd operation in the array. Define some local variables to gather the information to fill into the first op, and then fill in the op array all in one place. Signed-off-by: Alex Elder --- net/ceph/osd_client.c | 50 ++++++++++++++++++++++--------------------------- 1 file changed, 22 insertions(+), 28 deletions(-) diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c index 0eb417b..7136060 100644 --- a/net/ceph/osd_client.c +++ b/net/ceph/osd_client.c @@ -32,12 +32,6 @@ static void __unregister_linger_request(struct ceph_osd_client *osdc, static void __send_request(struct ceph_osd_client *osdc, struct ceph_osd_request *req); -static int op_has_extent(int op) -{ - return (op == CEPH_OSD_OP_READ || - op == CEPH_OSD_OP_WRITE); -} - /* * Implement client access to distributed object storage cluster. * @@ -554,22 +548,15 @@ struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, { struct ceph_osd_req_op ops[2]; struct ceph_osd_request *req; - unsigned int num_op = 1; + unsigned int num_op = do_sync ? 2 : 1; u64 objnum = 0; u64 objoff = 0; u64 objlen = 0; + u32 object_size; + u64 object_base; int r; - memset(&ops, 0, sizeof ops); - - ops[0].op = opcode; - ops[0].extent.truncate_seq = truncate_seq; - ops[0].extent.truncate_size = truncate_size; - - if (do_sync) { - ops[1].op = CEPH_OSD_OP_STARTSYNC; - num_op++; - } + BUG_ON(opcode != CEPH_OSD_OP_READ && opcode != CEPH_OSD_OP_WRITE); req = ceph_osdc_alloc_request(osdc, snapc, num_op, use_mempool, GFP_NOFS); @@ -584,21 +571,28 @@ struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc, return ERR_PTR(r); } - if (op_has_extent(ops[0].op)) { - u32 osize = le32_to_cpu(layout->fl_object_size); - ops[0].extent.offset = objoff; - ops[0].extent.length = objlen; - if (ops[0].extent.truncate_size <= off - objoff) { - ops[0].extent.truncate_size = 0; - } else { - ops[0].extent.truncate_size -= off - objoff; - if (ops[0].extent.truncate_size > osize) - ops[0].extent.truncate_size = osize; - } + object_size = le32_to_cpu(layout->fl_object_size); + object_base = off - objoff; + if (truncate_size <= object_base) { + truncate_size = 0; + } else { + truncate_size -= object_base; + if (truncate_size > object_size) + truncate_size = object_size; } + + memset(&ops, 0, sizeof ops); + ops[0].op = opcode; + ops[0].extent.offset = objoff; + ops[0].extent.length = objlen; + ops[0].extent.truncate_size = truncate_size; + ops[0].extent.truncate_seq = truncate_seq; if (ops[0].op == CEPH_OSD_OP_WRITE) ops[0].payload_len = *plen; + if (do_sync) + ops[1].op = CEPH_OSD_OP_STARTSYNC; + req->r_file_layout = *layout; /* keep a copy */ snprintf(req->r_oid, sizeof(req->r_oid), "%llx.%08llx", -- 1.7.9.5