Signed-off-by: Haomai Wang <haomai@xsky.com>
<< " Drop message " << m << dendl;
m->put();
} else {
- out_q[m->get_priority()].push_back(make_pair(bl, m));
+ out_q[m->get_priority()].emplace_back(std::move(bl), m);
ldout(async_msgr->cct, 15) << __func__ << " inline write is denied, reschedule m=" << m << dendl;
center->dispatch_event_external(write_handler);
}
void _send_keepalive_or_ack(bool ack=false, utime_t *t=NULL);
ssize_t write_message(Message *m, bufferlist& bl);
ssize_t _reply_accept(char tag, ceph_msg_connect &connect, ceph_msg_connect_reply &reply,
- bufferlist authorizer_reply) {
+ bufferlist &authorizer_reply) {
bufferlist reply_bl;
reply.tag = tag;
reply.features = ((uint64_t)connect.features & policy.features_supported) | policy.features_required;