aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph/messenger.c
diff options
context:
space:
mode:
authorSage Weil <sage@newdream.net>2010-02-20 00:43:23 -0500
committerSage Weil <sage@newdream.net>2010-02-23 17:26:29 -0500
commit5b3a4db3e4009aff918abb1353eb3f4925393a7b (patch)
tree0f55666c827c3dfe31309209b69121e431366739 /fs/ceph/messenger.c
parentbcd2cbd10ce31c950a40c08d7f601f8ff23537b8 (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.c5
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;