| 174 | } |
| 175 | |
| 176 | void AsyncConnection::maybe_start_delay_thread() |
| 177 | { |
| 178 | if (!delay_state) { |
| 179 | async_msgr->cct->_conf.with_val<std::string>( |
| 180 | "ms_inject_delay_type", |
| 181 | [this](const std::string& s) { |
| 182 | if (s.find(ceph_entity_type_name(peer_type)) != std::string::npos) { |
| 183 | ldout(msgr->cct, 1) << __func__ << " setting up a delay queue" |
| 184 | << dendl; |
| 185 | delay_state = new DelayedDelivery(async_msgr, center, dispatch_queue, |
| 186 | conn_id); |
| 187 | } |
| 188 | }); |
| 189 | } |
| 190 | } |
| 191 | |
| 192 | |
| 193 | ssize_t AsyncConnection::read(unsigned len, char *buffer, |
no test coverage detected