Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 373414
b: refs/heads/master
c: 9fc6e06
h: refs/heads/master
v: v3
  • Loading branch information
Alex Elder authored and Sage Weil committed May 2, 2013
1 parent 748a7cd commit 329cbb7
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 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: 6010a451c38b04cf10808a508f33e5bf32e7de63
refs/heads/master: 9fc6e0647180f72392f03a29863b6602e22aa024
8 changes: 4 additions & 4 deletions trunk/net/ceph/osd_client.c
Original file line number Diff line number Diff line change
Expand Up @@ -1293,6 +1293,7 @@ static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg,
u64 reassert_version;
u32 osdmap_epoch;
int already_completed;
u32 bytes;
int i;

tid = le64_to_cpu(msg->hdr.tid);
Expand Down Expand Up @@ -1347,9 +1348,10 @@ static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg,
payload_len += len;
p += sizeof(*op);
}
if (payload_len != le32_to_cpu(msg->hdr.data_len)) {
bytes = le32_to_cpu(msg->hdr.data_len);
if (payload_len != bytes) {
pr_warning("sum of op payload lens %d != data_len %d",
payload_len, le32_to_cpu(msg->hdr.data_len));
payload_len, bytes);
goto bad_put;
}

Expand All @@ -1359,10 +1361,8 @@ static void handle_reply(struct ceph_osd_client *osdc, struct ceph_msg *msg,
req->r_reply_op_result[i] = ceph_decode_32(&p);

if (!req->r_got_reply) {
unsigned int bytes;

req->r_result = result;
bytes = le32_to_cpu(msg->hdr.data_len);
dout("handle_reply result %d bytes %d\n", req->r_result,
bytes);
if (req->r_result == 0)
Expand Down

0 comments on commit 329cbb7

Please sign in to comment.