if (!is_queued() && can_write == CANWRITE) {
if (!can_fast_prepare)
prepare_send_message(get_features(), m, bl);
+ logger->inc(l_msgr_send_messages_inline);
if (write_message(m, bl) < 0) {
ldout(async_msgr->cct, 1) << __func__ << " send msg failed" << dendl;
// we want to handle fault within internal thread
l_msgr_first = 94000,
l_msgr_recv_messages,
l_msgr_send_messages,
+ l_msgr_send_messages_inline,
l_msgr_recv_bytes,
l_msgr_send_bytes,
l_msgr_created_connections,
plb.add_u64_counter(l_msgr_recv_messages, "msgr_recv_messages", "Network received messages");
plb.add_u64_counter(l_msgr_send_messages, "msgr_send_messages", "Network sent messages");
+ plb.add_u64_counter(l_msgr_send_messages_inline, "msgr_send_messages_inline", "Network sent inline messages");
plb.add_u64_counter(l_msgr_recv_bytes, "msgr_recv_bytes", "Network received bytes");
plb.add_u64_counter(l_msgr_send_bytes, "msgr_send_bytes", "Network received bytes");
plb.add_u64_counter(l_msgr_created_connections, "msgr_active_connections", "Active connection number");