Otherwise it will result in higher priority but later message to be issued
firstly, then peer will receive out-of-order message seq
Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
prepare_send_message(f, m, bl);
Mutex::Locker l(write_lock);
- m->set_seq(out_seq.inc());
// "features" changes will change the payload encoding
if (can_write == NOWRITE || get_features() != f) {
// ensure the correctness of message encoding
int AsyncConnection::write_message(Message *m, bufferlist& bl)
{
assert(can_write == CANWRITE);
+ m->set_seq(out_seq.inc());
if (!policy.lossy) {
// put on sent list