We should not initiate a connection if we are a lossy server; just drop
the message.
}
}
if (!pipe) {
- if (lazy) {
+ Policy& policy = get_policy(dest_type);
+ if (policy.lossy && policy.server) {
+ dout(20) << "submit_message " << *m << " remote, " << dest_addr << ", lossy server for target type "
+ << ceph_entity_type_name(dest_type) << ", no session, dropping." << dendl;
+ m->put();
+ } else if (lazy) {
dout(20) << "submit_message " << *m << " remote, " << dest_addr << ", lazy, dropping." << dendl;
m->put();
} else {