m->trace.event("async enqueueing message");
out_queue[m->get_priority()].emplace_back(
out_queue_entry_t{is_prepared, m});
- ldout(cct, 15) << __func__ << " inline write is denied, reschedule m=" << m
+ ldout(cct, 15) << __func__ << " message queued for async transmission m=" << m
<< dendl;
if (((!replacing && can_write) || state == STANDBY) && !write_in_progress) {
write_in_progress = true;
if (peer_global_seq < exproto->peer_global_seq &&
exproto->client_cookie && client_cookie &&
exproto->client_cookie != client_cookie) {
- ldout(cct, 1) << __func__ << " client has clearly restarted (peer_global_seq < ex_peer_global_seq && cookie changed), "
- << "dropping existing connection=" << existing << " in favor of new one" << dendl;
+ ldout(cct, 1) << __func__ << " client has clearly restarted (peer_global_seq="
+ << peer_global_seq << " < ex_peer_global_seq=" << exproto->peer_global_seq
+ << " && cookie changed: client_cookie=" << client_cookie << " != ex_client_cookie="
+ << exproto->client_cookie << "), "
+ << "dropping existing_connection=" << existing << " in favor of new_connection=" << connection << dendl;
existing->protocol->stop();
existing->dispatch_queue->queue_reset(existing.get());
l.unlock();
flags = flags | CEPH_MSG_CONNECT_LOSSY;
}
- uint64_t gs = messenger->get_global_seq();
+ global_seq = messenger->get_global_seq();
auto server_ident = ServerIdentFrame::Encode(
messenger->get_myaddrs(),
messenger->get_myname().num(),
- gs,
+ global_seq,
connection->policy.features_supported,
connection->policy.features_required | msgr2_required,
flags,
ldout(cct, 5) << __func__ << " sending identification:"
<< " addrs=" << messenger->get_myaddrs()
<< " gid=" << messenger->get_myname().num()
- << " global_seq=" << gs << " features_supported=" << std::hex
+ << " global_seq=" << global_seq << " features_supported=" << std::hex
<< connection->policy.features_supported
<< " features_required="
<< (connection->policy.features_required | msgr2_required)