diff options
author | Sage Weil <sage@newdream.net> | 2010-02-20 00:43:23 -0500 |
---|---|---|
committer | Sage Weil <sage@newdream.net> | 2010-02-23 17:26:29 -0500 |
commit | 5b3a4db3e4009aff918abb1353eb3f4925393a7b (patch) | |
tree | 0f55666c827c3dfe31309209b69121e431366739 /fs/ceph/messenger.c | |
parent | bcd2cbd10ce31c950a40c08d7f601f8ff23537b8 (diff) |
ceph: fix up unexpected message handling
Fix skipping of unexpected message types from osd, mon.
Clean up pr_info and debug output.
Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'fs/ceph/messenger.c')
-rw-r--r-- | fs/ceph/messenger.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/fs/ceph/messenger.c b/fs/ceph/messenger.c index ca2ad0e5bb28..fdda707aa137 100644 --- a/fs/ceph/messenger.c +++ b/fs/ceph/messenger.c | |||
@@ -1361,7 +1361,7 @@ static int read_partial_message(struct ceph_connection *con) | |||
1361 | con->in_msg = ceph_alloc_msg(con, &con->in_hdr, &skip); | 1361 | con->in_msg = ceph_alloc_msg(con, &con->in_hdr, &skip); |
1362 | if (skip) { | 1362 | if (skip) { |
1363 | /* skip this message */ | 1363 | /* skip this message */ |
1364 | pr_err("alloc_msg returned NULL, skipping message\n"); | 1364 | dout("alloc_msg returned NULL, skipping message\n"); |
1365 | con->in_base_pos = -front_len - middle_len - data_len - | 1365 | con->in_base_pos = -front_len - middle_len - data_len - |
1366 | sizeof(m->footer); | 1366 | sizeof(m->footer); |
1367 | con->in_tag = CEPH_MSGR_TAG_READY; | 1367 | con->in_tag = CEPH_MSGR_TAG_READY; |
@@ -1370,7 +1370,8 @@ static int read_partial_message(struct ceph_connection *con) | |||
1370 | if (IS_ERR(con->in_msg)) { | 1370 | if (IS_ERR(con->in_msg)) { |
1371 | ret = PTR_ERR(con->in_msg); | 1371 | ret = PTR_ERR(con->in_msg); |
1372 | con->in_msg = NULL; | 1372 | con->in_msg = NULL; |
1373 | con->error_msg = "error allocating memory for incoming message"; | 1373 | con->error_msg = |
1374 | "error allocating memory for incoming message"; | ||
1374 | return ret; | 1375 | return ret; |
1375 | } | 1376 | } |
1376 | m = con->in_msg; | 1377 | m = con->in_msg; |