|
@@ -2337,7 +2337,7 @@ static int read_partial_message(struct ceph_connection *con)
|
|
con->in_base_pos = -front_len - middle_len - data_len -
|
|
con->in_base_pos = -front_len - middle_len - data_len -
|
|
sizeof(m->footer);
|
|
sizeof(m->footer);
|
|
con->in_tag = CEPH_MSGR_TAG_READY;
|
|
con->in_tag = CEPH_MSGR_TAG_READY;
|
|
- return 0;
|
|
|
|
|
|
+ return 1;
|
|
} else if ((s64)seq - (s64)con->in_seq > 1) {
|
|
} else if ((s64)seq - (s64)con->in_seq > 1) {
|
|
pr_err("read_partial_message bad seq %lld expected %lld\n",
|
|
pr_err("read_partial_message bad seq %lld expected %lld\n",
|
|
seq, con->in_seq + 1);
|
|
seq, con->in_seq + 1);
|
|
@@ -2363,7 +2363,7 @@ static int read_partial_message(struct ceph_connection *con)
|
|
sizeof(m->footer);
|
|
sizeof(m->footer);
|
|
con->in_tag = CEPH_MSGR_TAG_READY;
|
|
con->in_tag = CEPH_MSGR_TAG_READY;
|
|
con->in_seq++;
|
|
con->in_seq++;
|
|
- return 0;
|
|
|
|
|
|
+ return 1;
|
|
}
|
|
}
|
|
|
|
|
|
BUG_ON(!con->in_msg);
|
|
BUG_ON(!con->in_msg);
|