diff options
Diffstat (limited to 'fs/ceph')
-rw-r--r-- | fs/ceph/messenger.c | 2 |
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); |