aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph
diff options
context:
space:
mode:
Diffstat (limited to 'fs/ceph')
-rw-r--r--fs/ceph/messenger.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/fs/ceph/messenger.c b/fs/ceph/messenger.c
index cdaaa131add3..e7b91e093f54 100644
--- a/fs/ceph/messenger.c
+++ b/fs/ceph/messenger.c
@@ -1379,6 +1379,7 @@ static int read_partial_message(struct ceph_connection *con)
1379 con->in_base_pos = -front_len - middle_len - data_len - 1379 con->in_base_pos = -front_len - middle_len - data_len -
1380 sizeof(m->footer); 1380 sizeof(m->footer);
1381 con->in_tag = CEPH_MSGR_TAG_READY; 1381 con->in_tag = CEPH_MSGR_TAG_READY;
1382 con->in_seq++;
1382 return 0; 1383 return 0;
1383 } 1384 }
1384 if (IS_ERR(con->in_msg)) { 1385 if (IS_ERR(con->in_msg)) {
@@ -2030,6 +2031,7 @@ void ceph_con_revoke_message(struct ceph_connection *con, struct ceph_msg *msg)
2030 ceph_msg_put(con->in_msg); 2031 ceph_msg_put(con->in_msg);
2031 con->in_msg = NULL; 2032 con->in_msg = NULL;
2032 con->in_tag = CEPH_MSGR_TAG_READY; 2033 con->in_tag = CEPH_MSGR_TAG_READY;
2034 con->in_seq++;
2033 } else { 2035 } else {
2034 dout("con_revoke_pages %p msg %p pages %p no-op\n", 2036 dout("con_revoke_pages %p msg %p pages %p no-op\n",
2035 con, con->in_msg, msg); 2037 con, con->in_msg, msg);